Documentation ¶
Index ¶
- Constants
- type AliasContext
- func (ac *AliasContext) Action() string
- func (c *AliasContext) ActionableList() []string
- func (c *AliasContext) Builder() *criterias.Builder
- func (ac *AliasContext) Config(container *gabs.Container) error
- func (c *AliasContext) Container() *gabs.Container
- func (c *AliasContext) GetAsync() bool
- func (c *AliasContext) GetNumberOfWorkers() int
- func (c *AliasContext) GetQueueLength() int
- func (c *AliasContext) GetRetryCount() int
- func (c *AliasContext) Options() options.Optionable
- func (c *AliasContext) SetList(list ...string)
- func (c *AliasContext) SetOptions(options options.Optionable) error
- type CloseIndicesContext
- func (cic *CloseIndicesContext) Action() string
- func (c *CloseIndicesContext) ActionableList() []string
- func (c *CloseIndicesContext) Builder() *criterias.Builder
- func (cic *CloseIndicesContext) Config(container *gabs.Container) error
- func (c *CloseIndicesContext) Container() *gabs.Container
- func (c *CloseIndicesContext) GetAsync() bool
- func (c *CloseIndicesContext) GetNumberOfWorkers() int
- func (c *CloseIndicesContext) GetQueueLength() int
- func (c *CloseIndicesContext) GetRetryCount() int
- func (c *CloseIndicesContext) Options() options.Optionable
- func (c *CloseIndicesContext) SetList(list ...string)
- func (c *CloseIndicesContext) SetOptions(options options.Optionable) error
- type Contextable
- type CreateIndexContext
- func (cic *CreateIndexContext) Action() string
- func (c *CreateIndexContext) ActionableList() []string
- func (c *CreateIndexContext) Builder() *criterias.Builder
- func (cic *CreateIndexContext) Config(container *gabs.Container) error
- func (c *CreateIndexContext) Container() *gabs.Container
- func (c *CreateIndexContext) GetAsync() bool
- func (c *CreateIndexContext) GetNumberOfWorkers() int
- func (c *CreateIndexContext) GetQueueLength() int
- func (c *CreateIndexContext) GetRetryCount() int
- func (c *CreateIndexContext) Options() options.Optionable
- func (c *CreateIndexContext) SetList(list ...string)
- func (c *CreateIndexContext) SetOptions(options options.Optionable) error
- type CreateRepositoryContext
- func (crc *CreateRepositoryContext) Action() string
- func (c *CreateRepositoryContext) ActionableList() []string
- func (c *CreateRepositoryContext) Builder() *criterias.Builder
- func (crc *CreateRepositoryContext) Config(container *gabs.Container) error
- func (c *CreateRepositoryContext) Container() *gabs.Container
- func (c *CreateRepositoryContext) GetAsync() bool
- func (c *CreateRepositoryContext) GetNumberOfWorkers() int
- func (c *CreateRepositoryContext) GetQueueLength() int
- func (c *CreateRepositoryContext) GetRetryCount() int
- func (c *CreateRepositoryContext) Options() options.Optionable
- func (c *CreateRepositoryContext) SetList(list ...string)
- func (c *CreateRepositoryContext) SetOptions(options options.Optionable) error
- type DeleteIndicesContext
- func (dic *DeleteIndicesContext) Action() string
- func (c *DeleteIndicesContext) ActionableList() []string
- func (c *DeleteIndicesContext) Builder() *criterias.Builder
- func (dic *DeleteIndicesContext) Config(container *gabs.Container) error
- func (c *DeleteIndicesContext) Container() *gabs.Container
- func (c *DeleteIndicesContext) GetAsync() bool
- func (c *DeleteIndicesContext) GetNumberOfWorkers() int
- func (c *DeleteIndicesContext) GetQueueLength() int
- func (c *DeleteIndicesContext) GetRetryCount() int
- func (c *DeleteIndicesContext) Options() options.Optionable
- func (c *DeleteIndicesContext) SetList(list ...string)
- func (c *DeleteIndicesContext) SetOptions(options options.Optionable) error
- type DeleteRepositoriesContext
- func (drc *DeleteRepositoriesContext) Action() string
- func (c *DeleteRepositoriesContext) ActionableList() []string
- func (c *DeleteRepositoriesContext) Builder() *criterias.Builder
- func (drc *DeleteRepositoriesContext) Config(container *gabs.Container) error
- func (c *DeleteRepositoriesContext) Container() *gabs.Container
- func (c *DeleteRepositoriesContext) GetAsync() bool
- func (c *DeleteRepositoriesContext) GetNumberOfWorkers() int
- func (c *DeleteRepositoriesContext) GetQueueLength() int
- func (c *DeleteRepositoriesContext) GetRetryCount() int
- func (c *DeleteRepositoriesContext) Options() options.Optionable
- func (c *DeleteRepositoriesContext) SetList(list ...string)
- func (c *DeleteRepositoriesContext) SetOptions(options options.Optionable) error
- type DeleteSnapshotsContext
- func (dsc *DeleteSnapshotsContext) Action() string
- func (c *DeleteSnapshotsContext) ActionableList() []string
- func (c *DeleteSnapshotsContext) Builder() *criterias.Builder
- func (dsc *DeleteSnapshotsContext) Config(container *gabs.Container) error
- func (c *DeleteSnapshotsContext) Container() *gabs.Container
- func (c *DeleteSnapshotsContext) GetAsync() bool
- func (c *DeleteSnapshotsContext) GetNumberOfWorkers() int
- func (c *DeleteSnapshotsContext) GetQueueLength() int
- func (c *DeleteSnapshotsContext) GetRetryCount() int
- func (c *DeleteSnapshotsContext) Options() options.Optionable
- func (c *DeleteSnapshotsContext) SetList(list ...string)
- func (c *DeleteSnapshotsContext) SetOptions(options options.Optionable) error
- type DumpContext
- func (dc *DumpContext) Action() string
- func (c *DumpContext) ActionableList() []string
- func (c *DumpContext) Builder() *criterias.Builder
- func (dc *DumpContext) Config(container *gabs.Container) error
- func (c *DumpContext) Container() *gabs.Container
- func (c *DumpContext) GetAsync() bool
- func (c *DumpContext) GetNumberOfWorkers() int
- func (c *DumpContext) GetQueueLength() int
- func (c *DumpContext) GetRetryCount() int
- func (c *DumpContext) Options() options.Optionable
- func (c *DumpContext) SetList(list ...string)
- func (c *DumpContext) SetOptions(options options.Optionable) error
- type ImportDumpContext
- func (idc *ImportDumpContext) Action() string
- func (c *ImportDumpContext) ActionableList() []string
- func (c *ImportDumpContext) Builder() *criterias.Builder
- func (idc *ImportDumpContext) Config(container *gabs.Container) error
- func (c *ImportDumpContext) Container() *gabs.Container
- func (c *ImportDumpContext) GetAsync() bool
- func (c *ImportDumpContext) GetNumberOfWorkers() int
- func (c *ImportDumpContext) GetQueueLength() int
- func (c *ImportDumpContext) GetRetryCount() int
- func (c *ImportDumpContext) Options() options.Optionable
- func (c *ImportDumpContext) SetList(list ...string)
- func (c *ImportDumpContext) SetOptions(options options.Optionable) error
- type IndexSettingsContext
- func (isc *IndexSettingsContext) Action() string
- func (c *IndexSettingsContext) ActionableList() []string
- func (c *IndexSettingsContext) Builder() *criterias.Builder
- func (isc *IndexSettingsContext) Config(container *gabs.Container) error
- func (c *IndexSettingsContext) Container() *gabs.Container
- func (c *IndexSettingsContext) GetAsync() bool
- func (c *IndexSettingsContext) GetNumberOfWorkers() int
- func (c *IndexSettingsContext) GetQueueLength() int
- func (c *IndexSettingsContext) GetRetryCount() int
- func (c *IndexSettingsContext) Options() options.Optionable
- func (c *IndexSettingsContext) SetList(list ...string)
- func (c *IndexSettingsContext) SetOptions(options options.Optionable) error
- type ListIndicesContext
- func (lic *ListIndicesContext) Action() string
- func (c *ListIndicesContext) ActionableList() []string
- func (c *ListIndicesContext) Builder() *criterias.Builder
- func (lic *ListIndicesContext) Config(container *gabs.Container) error
- func (c *ListIndicesContext) Container() *gabs.Container
- func (c *ListIndicesContext) GetAsync() bool
- func (c *ListIndicesContext) GetNumberOfWorkers() int
- func (c *ListIndicesContext) GetQueueLength() int
- func (c *ListIndicesContext) GetRetryCount() int
- func (c *ListIndicesContext) Options() options.Optionable
- func (c *ListIndicesContext) SetList(list ...string)
- func (c *ListIndicesContext) SetOptions(options options.Optionable) error
- type ListSnapshotsContext
- func (ls *ListSnapshotsContext) Action() string
- func (c *ListSnapshotsContext) ActionableList() []string
- func (c *ListSnapshotsContext) Builder() *criterias.Builder
- func (ls *ListSnapshotsContext) Config(container *gabs.Container) error
- func (c *ListSnapshotsContext) Container() *gabs.Container
- func (c *ListSnapshotsContext) GetAsync() bool
- func (c *ListSnapshotsContext) GetNumberOfWorkers() int
- func (c *ListSnapshotsContext) GetQueueLength() int
- func (c *ListSnapshotsContext) GetRetryCount() int
- func (c *ListSnapshotsContext) Options() options.Optionable
- func (c *ListSnapshotsContext) SetList(list ...string)
- func (c *ListSnapshotsContext) SetOptions(options options.Optionable) error
- type MutateContext
- func (mc *MutateContext) Action() string
- func (c *MutateContext) ActionableList() []string
- func (c *MutateContext) Builder() *criterias.Builder
- func (mc *MutateContext) Config(container *gabs.Container) error
- func (c *MutateContext) Container() *gabs.Container
- func (c *MutateContext) GetAsync() bool
- func (c *MutateContext) GetNumberOfWorkers() int
- func (c *MutateContext) GetQueueLength() int
- func (c *MutateContext) GetRetryCount() int
- func (c *MutateContext) Options() options.Optionable
- func (c *MutateContext) SetList(list ...string)
- func (c *MutateContext) SetOptions(options options.Optionable) error
- type OpenIndicesContext
- func (oic *OpenIndicesContext) Action() string
- func (c *OpenIndicesContext) ActionableList() []string
- func (c *OpenIndicesContext) Builder() *criterias.Builder
- func (oic *OpenIndicesContext) Config(container *gabs.Container) error
- func (c *OpenIndicesContext) Container() *gabs.Container
- func (c *OpenIndicesContext) GetAsync() bool
- func (c *OpenIndicesContext) GetNumberOfWorkers() int
- func (c *OpenIndicesContext) GetQueueLength() int
- func (c *OpenIndicesContext) GetRetryCount() int
- func (c *OpenIndicesContext) Options() options.Optionable
- func (c *OpenIndicesContext) SetList(list ...string)
- func (c *OpenIndicesContext) SetOptions(options options.Optionable) error
- type RestoreContext
- func (rc *RestoreContext) Action() string
- func (c *RestoreContext) ActionableList() []string
- func (c *RestoreContext) Builder() *criterias.Builder
- func (rc *RestoreContext) Config(container *gabs.Container) error
- func (c *RestoreContext) Container() *gabs.Container
- func (c *RestoreContext) GetAsync() bool
- func (c *RestoreContext) GetNumberOfWorkers() int
- func (c *RestoreContext) GetQueueLength() int
- func (c *RestoreContext) GetRetryCount() int
- func (c *RestoreContext) Options() options.Optionable
- func (c *RestoreContext) SetList(list ...string)
- func (c *RestoreContext) SetOptions(options options.Optionable) error
- type RolloverContext
- func (rc *RolloverContext) Action() string
- func (c *RolloverContext) ActionableList() []string
- func (c *RolloverContext) Builder() *criterias.Builder
- func (rc *RolloverContext) Config(container *gabs.Container) error
- func (c *RolloverContext) Container() *gabs.Container
- func (c *RolloverContext) GetAsync() bool
- func (c *RolloverContext) GetNumberOfWorkers() int
- func (c *RolloverContext) GetQueueLength() int
- func (c *RolloverContext) GetRetryCount() int
- func (c *RolloverContext) Options() options.Optionable
- func (c *RolloverContext) SetList(list ...string)
- func (c *RolloverContext) SetOptions(options options.Optionable) error
- type SnapshotContext
- func (sc *SnapshotContext) Action() string
- func (c *SnapshotContext) ActionableList() []string
- func (c *SnapshotContext) Builder() *criterias.Builder
- func (sc *SnapshotContext) Config(container *gabs.Container) error
- func (c *SnapshotContext) Container() *gabs.Container
- func (c *SnapshotContext) GetAsync() bool
- func (c *SnapshotContext) GetNumberOfWorkers() int
- func (c *SnapshotContext) GetQueueLength() int
- func (c *SnapshotContext) GetRetryCount() int
- func (c *SnapshotContext) Options() options.Optionable
- func (c *SnapshotContext) SetList(list ...string)
- func (c *SnapshotContext) SetOptions(options options.Optionable) error
- type WatchContext
- func (wc *WatchContext) Action() string
- func (c *WatchContext) ActionableList() []string
- func (c *WatchContext) Builder() *criterias.Builder
- func (wc *WatchContext) Config(container *gabs.Container) error
- func (c *WatchContext) Container() *gabs.Container
- func (c *WatchContext) GetAsync() bool
- func (c *WatchContext) GetNumberOfWorkers() int
- func (c *WatchContext) GetQueueLength() int
- func (c *WatchContext) GetRetryCount() int
- func (c *WatchContext) Options() options.Optionable
- func (c *WatchContext) SetList(list ...string)
- func (c *WatchContext) SetOptions(options options.Optionable) error
Constants ¶
View Source
const DEFAULT_NUMBER_OF_WORKERS int = 10
View Source
const DEFAULT_QUEUE_LENGTH int = 1000
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AliasContext ¶
type AliasContext struct {
// contains filtered or unexported fields
}
func (*AliasContext) Action ¶
func (ac *AliasContext) Action() string
func (*AliasContext) ActionableList ¶
func (c *AliasContext) ActionableList() []string
func (*AliasContext) GetNumberOfWorkers ¶
func (c *AliasContext) GetNumberOfWorkers() int
func (*AliasContext) GetQueueLength ¶
func (c *AliasContext) GetQueueLength() int
func (*AliasContext) GetRetryCount ¶
func (c *AliasContext) GetRetryCount() int
func (*AliasContext) Options ¶
func (c *AliasContext) Options() options.Optionable
func (*AliasContext) SetOptions ¶
func (c *AliasContext) SetOptions(options options.Optionable) error
type CloseIndicesContext ¶
type CloseIndicesContext struct {
// contains filtered or unexported fields
}
func (*CloseIndicesContext) Action ¶
func (cic *CloseIndicesContext) Action() string
func (*CloseIndicesContext) ActionableList ¶
func (c *CloseIndicesContext) ActionableList() []string
func (*CloseIndicesContext) Config ¶
func (cic *CloseIndicesContext) Config(container *gabs.Container) error
func (*CloseIndicesContext) GetNumberOfWorkers ¶
func (c *CloseIndicesContext) GetNumberOfWorkers() int
func (*CloseIndicesContext) GetQueueLength ¶
func (c *CloseIndicesContext) GetQueueLength() int
func (*CloseIndicesContext) GetRetryCount ¶
func (c *CloseIndicesContext) GetRetryCount() int
func (*CloseIndicesContext) Options ¶
func (c *CloseIndicesContext) Options() options.Optionable
func (*CloseIndicesContext) SetOptions ¶
func (c *CloseIndicesContext) SetOptions(options options.Optionable) error
type Contextable ¶
type Contextable interface { Action() string Container() *gabs.Container GetAsync() bool GetNumberOfWorkers() int GetQueueLength() int GetRetryCount() int Options() options.Optionable Builder() *criterias.Builder ActionableList() []string Config(container *gabs.Container) error SetOptions(options options.Optionable) error SetList(list ...string) // contains filtered or unexported methods }
type CreateIndexContext ¶
type CreateIndexContext struct {
// contains filtered or unexported fields
}
func (*CreateIndexContext) Action ¶
func (cic *CreateIndexContext) Action() string
func (*CreateIndexContext) ActionableList ¶
func (c *CreateIndexContext) ActionableList() []string
func (*CreateIndexContext) Config ¶
func (cic *CreateIndexContext) Config(container *gabs.Container) error
func (*CreateIndexContext) GetNumberOfWorkers ¶
func (c *CreateIndexContext) GetNumberOfWorkers() int
func (*CreateIndexContext) GetQueueLength ¶
func (c *CreateIndexContext) GetQueueLength() int
func (*CreateIndexContext) GetRetryCount ¶
func (c *CreateIndexContext) GetRetryCount() int
func (*CreateIndexContext) Options ¶
func (c *CreateIndexContext) Options() options.Optionable
func (*CreateIndexContext) SetOptions ¶
func (c *CreateIndexContext) SetOptions(options options.Optionable) error
type CreateRepositoryContext ¶
type CreateRepositoryContext struct {
// contains filtered or unexported fields
}
func (*CreateRepositoryContext) Action ¶
func (crc *CreateRepositoryContext) Action() string
func (*CreateRepositoryContext) ActionableList ¶
func (c *CreateRepositoryContext) ActionableList() []string
func (*CreateRepositoryContext) Config ¶
func (crc *CreateRepositoryContext) Config(container *gabs.Container) error
func (*CreateRepositoryContext) GetNumberOfWorkers ¶
func (c *CreateRepositoryContext) GetNumberOfWorkers() int
func (*CreateRepositoryContext) GetQueueLength ¶
func (c *CreateRepositoryContext) GetQueueLength() int
func (*CreateRepositoryContext) GetRetryCount ¶
func (c *CreateRepositoryContext) GetRetryCount() int
func (*CreateRepositoryContext) Options ¶
func (c *CreateRepositoryContext) Options() options.Optionable
func (*CreateRepositoryContext) SetOptions ¶
func (c *CreateRepositoryContext) SetOptions(options options.Optionable) error
type DeleteIndicesContext ¶
type DeleteIndicesContext struct {
// contains filtered or unexported fields
}
func (*DeleteIndicesContext) Action ¶
func (dic *DeleteIndicesContext) Action() string
func (*DeleteIndicesContext) ActionableList ¶
func (c *DeleteIndicesContext) ActionableList() []string
func (*DeleteIndicesContext) Config ¶
func (dic *DeleteIndicesContext) Config(container *gabs.Container) error
func (*DeleteIndicesContext) GetNumberOfWorkers ¶
func (c *DeleteIndicesContext) GetNumberOfWorkers() int
func (*DeleteIndicesContext) GetQueueLength ¶
func (c *DeleteIndicesContext) GetQueueLength() int
func (*DeleteIndicesContext) GetRetryCount ¶
func (c *DeleteIndicesContext) GetRetryCount() int
func (*DeleteIndicesContext) Options ¶
func (c *DeleteIndicesContext) Options() options.Optionable
func (*DeleteIndicesContext) SetOptions ¶
func (c *DeleteIndicesContext) SetOptions(options options.Optionable) error
type DeleteRepositoriesContext ¶
type DeleteRepositoriesContext struct {
// contains filtered or unexported fields
}
func (*DeleteRepositoriesContext) Action ¶
func (drc *DeleteRepositoriesContext) Action() string
func (*DeleteRepositoriesContext) ActionableList ¶
func (c *DeleteRepositoriesContext) ActionableList() []string
func (*DeleteRepositoriesContext) Config ¶
func (drc *DeleteRepositoriesContext) Config(container *gabs.Container) error
func (*DeleteRepositoriesContext) GetNumberOfWorkers ¶
func (c *DeleteRepositoriesContext) GetNumberOfWorkers() int
func (*DeleteRepositoriesContext) GetQueueLength ¶
func (c *DeleteRepositoriesContext) GetQueueLength() int
func (*DeleteRepositoriesContext) GetRetryCount ¶
func (c *DeleteRepositoriesContext) GetRetryCount() int
func (*DeleteRepositoriesContext) Options ¶
func (c *DeleteRepositoriesContext) Options() options.Optionable
func (*DeleteRepositoriesContext) SetList ¶
func (c *DeleteRepositoriesContext) SetList(list ...string)
func (*DeleteRepositoriesContext) SetOptions ¶
func (c *DeleteRepositoriesContext) SetOptions(options options.Optionable) error
type DeleteSnapshotsContext ¶
type DeleteSnapshotsContext struct {
// contains filtered or unexported fields
}
func (*DeleteSnapshotsContext) Action ¶
func (dsc *DeleteSnapshotsContext) Action() string
func (*DeleteSnapshotsContext) ActionableList ¶
func (c *DeleteSnapshotsContext) ActionableList() []string
func (*DeleteSnapshotsContext) Config ¶
func (dsc *DeleteSnapshotsContext) Config(container *gabs.Container) error
func (*DeleteSnapshotsContext) GetNumberOfWorkers ¶
func (c *DeleteSnapshotsContext) GetNumberOfWorkers() int
func (*DeleteSnapshotsContext) GetQueueLength ¶
func (c *DeleteSnapshotsContext) GetQueueLength() int
func (*DeleteSnapshotsContext) GetRetryCount ¶
func (c *DeleteSnapshotsContext) GetRetryCount() int
func (*DeleteSnapshotsContext) Options ¶
func (c *DeleteSnapshotsContext) Options() options.Optionable
func (*DeleteSnapshotsContext) SetOptions ¶
func (c *DeleteSnapshotsContext) SetOptions(options options.Optionable) error
type DumpContext ¶
type DumpContext struct {
// contains filtered or unexported fields
}
func (*DumpContext) Action ¶
func (dc *DumpContext) Action() string
func (*DumpContext) ActionableList ¶
func (c *DumpContext) ActionableList() []string
func (*DumpContext) GetNumberOfWorkers ¶
func (c *DumpContext) GetNumberOfWorkers() int
func (*DumpContext) GetQueueLength ¶
func (c *DumpContext) GetQueueLength() int
func (*DumpContext) GetRetryCount ¶
func (c *DumpContext) GetRetryCount() int
func (*DumpContext) Options ¶
func (c *DumpContext) Options() options.Optionable
func (*DumpContext) SetOptions ¶
func (c *DumpContext) SetOptions(options options.Optionable) error
type ImportDumpContext ¶
type ImportDumpContext struct {
// contains filtered or unexported fields
}
func (*ImportDumpContext) Action ¶
func (idc *ImportDumpContext) Action() string
func (*ImportDumpContext) ActionableList ¶
func (c *ImportDumpContext) ActionableList() []string
func (*ImportDumpContext) Config ¶
func (idc *ImportDumpContext) Config(container *gabs.Container) error
func (*ImportDumpContext) GetNumberOfWorkers ¶
func (c *ImportDumpContext) GetNumberOfWorkers() int
func (*ImportDumpContext) GetQueueLength ¶
func (c *ImportDumpContext) GetQueueLength() int
func (*ImportDumpContext) GetRetryCount ¶
func (c *ImportDumpContext) GetRetryCount() int
func (*ImportDumpContext) Options ¶
func (c *ImportDumpContext) Options() options.Optionable
func (*ImportDumpContext) SetOptions ¶
func (c *ImportDumpContext) SetOptions(options options.Optionable) error
type IndexSettingsContext ¶
type IndexSettingsContext struct {
// contains filtered or unexported fields
}
func (*IndexSettingsContext) Action ¶
func (isc *IndexSettingsContext) Action() string
func (*IndexSettingsContext) ActionableList ¶
func (c *IndexSettingsContext) ActionableList() []string
func (*IndexSettingsContext) Config ¶
func (isc *IndexSettingsContext) Config(container *gabs.Container) error
func (*IndexSettingsContext) GetNumberOfWorkers ¶
func (c *IndexSettingsContext) GetNumberOfWorkers() int
func (*IndexSettingsContext) GetQueueLength ¶
func (c *IndexSettingsContext) GetQueueLength() int
func (*IndexSettingsContext) GetRetryCount ¶
func (c *IndexSettingsContext) GetRetryCount() int
func (*IndexSettingsContext) Options ¶
func (c *IndexSettingsContext) Options() options.Optionable
func (*IndexSettingsContext) SetOptions ¶
func (c *IndexSettingsContext) SetOptions(options options.Optionable) error
type ListIndicesContext ¶
type ListIndicesContext struct {
// contains filtered or unexported fields
}
func (*ListIndicesContext) Action ¶
func (lic *ListIndicesContext) Action() string
func (*ListIndicesContext) ActionableList ¶
func (c *ListIndicesContext) ActionableList() []string
func (*ListIndicesContext) Config ¶
func (lic *ListIndicesContext) Config(container *gabs.Container) error
func (*ListIndicesContext) GetNumberOfWorkers ¶
func (c *ListIndicesContext) GetNumberOfWorkers() int
func (*ListIndicesContext) GetQueueLength ¶
func (c *ListIndicesContext) GetQueueLength() int
func (*ListIndicesContext) GetRetryCount ¶
func (c *ListIndicesContext) GetRetryCount() int
func (*ListIndicesContext) Options ¶
func (c *ListIndicesContext) Options() options.Optionable
func (*ListIndicesContext) SetOptions ¶
func (c *ListIndicesContext) SetOptions(options options.Optionable) error
type ListSnapshotsContext ¶
type ListSnapshotsContext struct {
// contains filtered or unexported fields
}
func (*ListSnapshotsContext) Action ¶
func (ls *ListSnapshotsContext) Action() string
func (*ListSnapshotsContext) ActionableList ¶
func (c *ListSnapshotsContext) ActionableList() []string
func (*ListSnapshotsContext) Config ¶
func (ls *ListSnapshotsContext) Config(container *gabs.Container) error
func (*ListSnapshotsContext) GetNumberOfWorkers ¶
func (c *ListSnapshotsContext) GetNumberOfWorkers() int
func (*ListSnapshotsContext) GetQueueLength ¶
func (c *ListSnapshotsContext) GetQueueLength() int
func (*ListSnapshotsContext) GetRetryCount ¶
func (c *ListSnapshotsContext) GetRetryCount() int
func (*ListSnapshotsContext) Options ¶
func (c *ListSnapshotsContext) Options() options.Optionable
func (*ListSnapshotsContext) SetOptions ¶
func (c *ListSnapshotsContext) SetOptions(options options.Optionable) error
type MutateContext ¶
type MutateContext struct {
// contains filtered or unexported fields
}
func (*MutateContext) Action ¶
func (mc *MutateContext) Action() string
func (*MutateContext) ActionableList ¶
func (c *MutateContext) ActionableList() []string
func (*MutateContext) GetNumberOfWorkers ¶
func (c *MutateContext) GetNumberOfWorkers() int
func (*MutateContext) GetQueueLength ¶
func (c *MutateContext) GetQueueLength() int
func (*MutateContext) GetRetryCount ¶
func (c *MutateContext) GetRetryCount() int
func (*MutateContext) Options ¶
func (c *MutateContext) Options() options.Optionable
func (*MutateContext) SetOptions ¶
func (c *MutateContext) SetOptions(options options.Optionable) error
type OpenIndicesContext ¶
type OpenIndicesContext struct {
// contains filtered or unexported fields
}
func (*OpenIndicesContext) Action ¶
func (oic *OpenIndicesContext) Action() string
func (*OpenIndicesContext) ActionableList ¶
func (c *OpenIndicesContext) ActionableList() []string
func (*OpenIndicesContext) Config ¶
func (oic *OpenIndicesContext) Config(container *gabs.Container) error
func (*OpenIndicesContext) GetNumberOfWorkers ¶
func (c *OpenIndicesContext) GetNumberOfWorkers() int
func (*OpenIndicesContext) GetQueueLength ¶
func (c *OpenIndicesContext) GetQueueLength() int
func (*OpenIndicesContext) GetRetryCount ¶
func (c *OpenIndicesContext) GetRetryCount() int
func (*OpenIndicesContext) Options ¶
func (c *OpenIndicesContext) Options() options.Optionable
func (*OpenIndicesContext) SetOptions ¶
func (c *OpenIndicesContext) SetOptions(options options.Optionable) error
type RestoreContext ¶
type RestoreContext struct {
// contains filtered or unexported fields
}
func (*RestoreContext) Action ¶
func (rc *RestoreContext) Action() string
func (*RestoreContext) ActionableList ¶
func (c *RestoreContext) ActionableList() []string
func (*RestoreContext) GetNumberOfWorkers ¶
func (c *RestoreContext) GetNumberOfWorkers() int
func (*RestoreContext) GetQueueLength ¶
func (c *RestoreContext) GetQueueLength() int
func (*RestoreContext) GetRetryCount ¶
func (c *RestoreContext) GetRetryCount() int
func (*RestoreContext) Options ¶
func (c *RestoreContext) Options() options.Optionable
func (*RestoreContext) SetOptions ¶
func (c *RestoreContext) SetOptions(options options.Optionable) error
type RolloverContext ¶
type RolloverContext struct {
// contains filtered or unexported fields
}
func (*RolloverContext) Action ¶
func (rc *RolloverContext) Action() string
func (*RolloverContext) ActionableList ¶
func (c *RolloverContext) ActionableList() []string
func (*RolloverContext) GetNumberOfWorkers ¶
func (c *RolloverContext) GetNumberOfWorkers() int
func (*RolloverContext) GetQueueLength ¶
func (c *RolloverContext) GetQueueLength() int
func (*RolloverContext) GetRetryCount ¶
func (c *RolloverContext) GetRetryCount() int
func (*RolloverContext) Options ¶
func (c *RolloverContext) Options() options.Optionable
func (*RolloverContext) SetOptions ¶
func (c *RolloverContext) SetOptions(options options.Optionable) error
type SnapshotContext ¶
type SnapshotContext struct {
// contains filtered or unexported fields
}
func (*SnapshotContext) Action ¶
func (sc *SnapshotContext) Action() string
func (*SnapshotContext) ActionableList ¶
func (c *SnapshotContext) ActionableList() []string
func (*SnapshotContext) GetNumberOfWorkers ¶
func (c *SnapshotContext) GetNumberOfWorkers() int
func (*SnapshotContext) GetQueueLength ¶
func (c *SnapshotContext) GetQueueLength() int
func (*SnapshotContext) GetRetryCount ¶
func (c *SnapshotContext) GetRetryCount() int
func (*SnapshotContext) Options ¶
func (c *SnapshotContext) Options() options.Optionable
func (*SnapshotContext) SetOptions ¶
func (c *SnapshotContext) SetOptions(options options.Optionable) error
type WatchContext ¶
type WatchContext struct {
// contains filtered or unexported fields
}
func (*WatchContext) Action ¶
func (wc *WatchContext) Action() string
func (*WatchContext) ActionableList ¶
func (c *WatchContext) ActionableList() []string
func (*WatchContext) GetNumberOfWorkers ¶
func (c *WatchContext) GetNumberOfWorkers() int
func (*WatchContext) GetQueueLength ¶
func (c *WatchContext) GetQueueLength() int
func (*WatchContext) GetRetryCount ¶
func (c *WatchContext) GetRetryCount() int
func (*WatchContext) Options ¶
func (c *WatchContext) Options() options.Optionable
func (*WatchContext) SetOptions ¶
func (c *WatchContext) SetOptions(options options.Optionable) error
Source Files ¶
- alias_context.go
- close_indices_context.go
- context.go
- contracts.go
- create_index_context.go
- create_repository_context.go
- delete_indices_context.go
- delete_repositories_context.go
- delete_snapshots_context.go
- dump_context.go
- import_context.go
- index_settings_context.go
- list_indices_context.go
- list_snapshots_context.go
- mutate_context.go
- open_indices_context.go
- restore_context.go
- rollover_context.go
- snapshot_context.go
- util.go
- watch_context.go
Click to show internal directories.
Click to hide internal directories.