contexts

package
v0.0.0-...-e59334c Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 28, 2020 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Index

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) Builder

func (c *AliasContext) Builder() *criterias.Builder

func (*AliasContext) Config

func (ac *AliasContext) Config(container *gabs.Container) error

func (*AliasContext) Container

func (c *AliasContext) Container() *gabs.Container

func (*AliasContext) GetAsync

func (c *AliasContext) GetAsync() bool

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) SetList

func (c *AliasContext) SetList(list ...string)

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) Builder

func (c *CloseIndicesContext) Builder() *criterias.Builder

func (*CloseIndicesContext) Config

func (cic *CloseIndicesContext) Config(container *gabs.Container) error

func (*CloseIndicesContext) Container

func (c *CloseIndicesContext) Container() *gabs.Container

func (*CloseIndicesContext) GetAsync

func (c *CloseIndicesContext) GetAsync() bool

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) SetList

func (c *CloseIndicesContext) SetList(list ...string)

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
}

func New

func New(config *gabs.Container) (Contextable, error)

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) Builder

func (c *CreateIndexContext) Builder() *criterias.Builder

func (*CreateIndexContext) Config

func (cic *CreateIndexContext) Config(container *gabs.Container) error

func (*CreateIndexContext) Container

func (c *CreateIndexContext) Container() *gabs.Container

func (*CreateIndexContext) GetAsync

func (c *CreateIndexContext) GetAsync() bool

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) SetList

func (c *CreateIndexContext) SetList(list ...string)

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) Builder

func (c *CreateRepositoryContext) Builder() *criterias.Builder

func (*CreateRepositoryContext) Config

func (crc *CreateRepositoryContext) Config(container *gabs.Container) error

func (*CreateRepositoryContext) Container

func (c *CreateRepositoryContext) Container() *gabs.Container

func (*CreateRepositoryContext) GetAsync

func (c *CreateRepositoryContext) GetAsync() bool

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) SetList

func (c *CreateRepositoryContext) SetList(list ...string)

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) Builder

func (c *DeleteIndicesContext) Builder() *criterias.Builder

func (*DeleteIndicesContext) Config

func (dic *DeleteIndicesContext) Config(container *gabs.Container) error

func (*DeleteIndicesContext) Container

func (c *DeleteIndicesContext) Container() *gabs.Container

func (*DeleteIndicesContext) GetAsync

func (c *DeleteIndicesContext) GetAsync() bool

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) SetList

func (c *DeleteIndicesContext) SetList(list ...string)

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) Builder

func (c *DeleteRepositoriesContext) Builder() *criterias.Builder

func (*DeleteRepositoriesContext) Config

func (drc *DeleteRepositoriesContext) Config(container *gabs.Container) error

func (*DeleteRepositoriesContext) Container

func (c *DeleteRepositoriesContext) Container() *gabs.Container

func (*DeleteRepositoriesContext) GetAsync

func (c *DeleteRepositoriesContext) GetAsync() bool

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) Builder

func (c *DeleteSnapshotsContext) Builder() *criterias.Builder

func (*DeleteSnapshotsContext) Config

func (dsc *DeleteSnapshotsContext) Config(container *gabs.Container) error

func (*DeleteSnapshotsContext) Container

func (c *DeleteSnapshotsContext) Container() *gabs.Container

func (*DeleteSnapshotsContext) GetAsync

func (c *DeleteSnapshotsContext) GetAsync() bool

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) SetList

func (c *DeleteSnapshotsContext) SetList(list ...string)

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) Builder

func (c *DumpContext) Builder() *criterias.Builder

func (*DumpContext) Config

func (dc *DumpContext) Config(container *gabs.Container) error

func (*DumpContext) Container

func (c *DumpContext) Container() *gabs.Container

func (*DumpContext) GetAsync

func (c *DumpContext) GetAsync() bool

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) SetList

func (c *DumpContext) SetList(list ...string)

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) Builder

func (c *ImportDumpContext) Builder() *criterias.Builder

func (*ImportDumpContext) Config

func (idc *ImportDumpContext) Config(container *gabs.Container) error

func (*ImportDumpContext) Container

func (c *ImportDumpContext) Container() *gabs.Container

func (*ImportDumpContext) GetAsync

func (c *ImportDumpContext) GetAsync() bool

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) SetList

func (c *ImportDumpContext) SetList(list ...string)

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) Builder

func (c *IndexSettingsContext) Builder() *criterias.Builder

func (*IndexSettingsContext) Config

func (isc *IndexSettingsContext) Config(container *gabs.Container) error

func (*IndexSettingsContext) Container

func (c *IndexSettingsContext) Container() *gabs.Container

func (*IndexSettingsContext) GetAsync

func (c *IndexSettingsContext) GetAsync() bool

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) SetList

func (c *IndexSettingsContext) SetList(list ...string)

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) Builder

func (c *ListIndicesContext) Builder() *criterias.Builder

func (*ListIndicesContext) Config

func (lic *ListIndicesContext) Config(container *gabs.Container) error

func (*ListIndicesContext) Container

func (c *ListIndicesContext) Container() *gabs.Container

func (*ListIndicesContext) GetAsync

func (c *ListIndicesContext) GetAsync() bool

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) SetList

func (c *ListIndicesContext) SetList(list ...string)

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) Builder

func (c *ListSnapshotsContext) Builder() *criterias.Builder

func (*ListSnapshotsContext) Config

func (ls *ListSnapshotsContext) Config(container *gabs.Container) error

func (*ListSnapshotsContext) Container

func (c *ListSnapshotsContext) Container() *gabs.Container

func (*ListSnapshotsContext) GetAsync

func (c *ListSnapshotsContext) GetAsync() bool

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) SetList

func (c *ListSnapshotsContext) SetList(list ...string)

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) Builder

func (c *MutateContext) Builder() *criterias.Builder

func (*MutateContext) Config

func (mc *MutateContext) Config(container *gabs.Container) error

func (*MutateContext) Container

func (c *MutateContext) Container() *gabs.Container

func (*MutateContext) GetAsync

func (c *MutateContext) GetAsync() bool

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) SetList

func (c *MutateContext) SetList(list ...string)

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) Builder

func (c *OpenIndicesContext) Builder() *criterias.Builder

func (*OpenIndicesContext) Config

func (oic *OpenIndicesContext) Config(container *gabs.Container) error

func (*OpenIndicesContext) Container

func (c *OpenIndicesContext) Container() *gabs.Container

func (*OpenIndicesContext) GetAsync

func (c *OpenIndicesContext) GetAsync() bool

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) SetList

func (c *OpenIndicesContext) SetList(list ...string)

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) Builder

func (c *RestoreContext) Builder() *criterias.Builder

func (*RestoreContext) Config

func (rc *RestoreContext) Config(container *gabs.Container) error

func (*RestoreContext) Container

func (c *RestoreContext) Container() *gabs.Container

func (*RestoreContext) GetAsync

func (c *RestoreContext) GetAsync() bool

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) SetList

func (c *RestoreContext) SetList(list ...string)

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) Builder

func (c *RolloverContext) Builder() *criterias.Builder

func (*RolloverContext) Config

func (rc *RolloverContext) Config(container *gabs.Container) error

func (*RolloverContext) Container

func (c *RolloverContext) Container() *gabs.Container

func (*RolloverContext) GetAsync

func (c *RolloverContext) GetAsync() bool

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) SetList

func (c *RolloverContext) SetList(list ...string)

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) Builder

func (c *SnapshotContext) Builder() *criterias.Builder

func (*SnapshotContext) Config

func (sc *SnapshotContext) Config(container *gabs.Container) error

func (*SnapshotContext) Container

func (c *SnapshotContext) Container() *gabs.Container

func (*SnapshotContext) GetAsync

func (c *SnapshotContext) GetAsync() bool

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) SetList

func (c *SnapshotContext) SetList(list ...string)

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) Builder

func (c *WatchContext) Builder() *criterias.Builder

func (*WatchContext) Config

func (wc *WatchContext) Config(container *gabs.Container) error

func (*WatchContext) Container

func (c *WatchContext) Container() *gabs.Container

func (*WatchContext) GetAsync

func (c *WatchContext) GetAsync() bool

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) SetList

func (c *WatchContext) SetList(list ...string)

func (*WatchContext) SetOptions

func (c *WatchContext) SetOptions(options options.Optionable) error

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL