Documentation ¶
Index ¶
- type Repository
- func (repo *Repository) Delete(index string) error
- func (repo *Repository) FindIndexContent(index, sortingField string) (*io.ReadCloser, error)
- func (repo *Repository) FindLastUpdate(index, sortingField string) (*time.Time, error)
- func (repo *Repository) FindLastUpdateOrEpochDate(index, sortingField string) (*time.Time, error)
- func (repo *Repository) GetBulkIndexer(index string) (esutil.BulkIndexer, error)
- func (repo *Repository) Refresh(index string) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Repository ¶
type Repository struct {
// contains filtered or unexported fields
}
func NewClient ¶
func NewClient(config *config.ImportConfig) (*Repository, error)
func NewDefaultClient ¶
func NewDefaultClient() (*Repository, error)
func (*Repository) Delete ¶
func (repo *Repository) Delete(index string) error
func (*Repository) FindIndexContent ¶
func (repo *Repository) FindIndexContent(index, sortingField string) (*io.ReadCloser, error)
func (*Repository) FindLastUpdate ¶
func (repo *Repository) FindLastUpdate(index, sortingField string) (*time.Time, error)
func (*Repository) FindLastUpdateOrEpochDate ¶
func (repo *Repository) FindLastUpdateOrEpochDate(index, sortingField string) (*time.Time, error)
func (*Repository) GetBulkIndexer ¶
func (repo *Repository) GetBulkIndexer(index string) (esutil.BulkIndexer, error)
func (*Repository) Refresh ¶
func (repo *Repository) Refresh(index string) error
Click to show internal directories.
Click to hide internal directories.