options

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: 5 Imported by: 0

Documentation

Index

Constants

View Source 
const DEFAULT_BATCH_SIZE int = 10000
View Source 
const DEFAULT_DUMP_CONCURRENCY int = 5
View Source 
const DEFAULT_DUMP_KEEP_ALIVE int = 5
View Source 
const DEFAULT_DUMP_MAX_EXECUTION_TIME int = 1
View Source 
const DEFAULT_DUMP_SIZE int = 2500
View Source 
const DEFAULT_MAX_EXECUTION_TIME int = 1
View Source 
const FS_REPOSITORY string = "fs"
View Source 
const GCS_REPOSITORY string = "gcs"

Variables

This section is empty.

Functions

This section is empty.

Types

type Alert 

type Alert struct {
	NotificationChannel string `json:"notification_channel"`
	Text                string `json:"text"`
	// contains filtered or unexported fields
}

func (*Alert) Payload 

func (a *Alert) Payload() *gabs.Container

type AliasExtraSettingsOption 

type AliasExtraSettingsOption struct {
	Routing       string                 `json:"routing"`
	SearchRouting string                 `json:"search_routing"`
	Filter        map[string]interface{} `json:"filter"`
}

type AliasOptions 

type AliasOptions struct {
	ExtraSettings *AliasExtraSettingsOption `json:"extra_settings"`
	Name          string                    `json:"name"`
	Type          string                    `json:"type"`
	// contains filtered or unexported fields
}

func (*AliasOptions) BindFlags 

func (ao *AliasOptions) BindFlags(flags *pflag.FlagSet) error

func (*AliasOptions) Exists 

func (do *AliasOptions) Exists(value string) bool

func (*AliasOptions) FillFromContainer 

func (ao *AliasOptions) FillFromContainer(container *gabs.Container) error

func (*AliasOptions) Get 

func (do *AliasOptions) Get(value string) interface{}

func (*AliasOptions) GetContainer 

func (do *AliasOptions) GetContainer() *gabs.Container

func (*AliasOptions) GetDisableAction 

func (do *AliasOptions) GetDisableAction() bool

func (*AliasOptions) IsNotifiable 

func (do *AliasOptions) IsNotifiable() bool

func (*AliasOptions) IsSnapshot 

func (do *AliasOptions) IsSnapshot() bool

func (*AliasOptions) String 

func (do *AliasOptions) String(value string) string

func (*AliasOptions) TimeoutInSeconds 

func (do *AliasOptions) TimeoutInSeconds() string

func (*AliasOptions) Validate 

func (ao *AliasOptions) Validate() error

func (AliasOptions) ValidateNotifiableOptions 

func (do AliasOptions) ValidateNotifiableOptions() error

type CloseIndicesOptions 

type CloseIndicesOptions struct {
	// contains filtered or unexported fields
}

func (*CloseIndicesOptions) BindFlags 

func (cio *CloseIndicesOptions) BindFlags(flags *pflag.FlagSet) error

func (*CloseIndicesOptions) Exists 

func (do *CloseIndicesOptions) Exists(value string) bool

func (*CloseIndicesOptions) FillFromContainer 

func (cio *CloseIndicesOptions) FillFromContainer(container *gabs.Container) error

func (*CloseIndicesOptions) Get 

func (do *CloseIndicesOptions) Get(value string) interface{}

func (*CloseIndicesOptions) GetContainer 

func (do *CloseIndicesOptions) GetContainer() *gabs.Container

func (*CloseIndicesOptions) GetDisableAction 

func (do *CloseIndicesOptions) GetDisableAction() bool

func (*CloseIndicesOptions) IsNotifiable 

func (do *CloseIndicesOptions) IsNotifiable() bool

func (*CloseIndicesOptions) IsSnapshot 

func (do *CloseIndicesOptions) IsSnapshot() bool

func (*CloseIndicesOptions) String 

func (do *CloseIndicesOptions) String(value string) string

func (*CloseIndicesOptions) TimeoutInSeconds 

func (do *CloseIndicesOptions) TimeoutInSeconds() string

func (*CloseIndicesOptions) Validate 

func (cio *CloseIndicesOptions) Validate() error

func (CloseIndicesOptions) ValidateNotifiableOptions 

func (do CloseIndicesOptions) ValidateNotifiableOptions() error

type CreateIndexOptions 

type CreateIndexOptions struct {
	Name          string                 `json:"name"`
	ExtraSettings map[string]interface{} `json:"extra_settings"`
	// contains filtered or unexported fields
}

func (*CreateIndexOptions) BindFlags 

func (cio *CreateIndexOptions) BindFlags(flags *pflag.FlagSet) error

func (*CreateIndexOptions) Exists 

func (do *CreateIndexOptions) Exists(value string) bool

func (*CreateIndexOptions) FillFromContainer 

func (cio *CreateIndexOptions) FillFromContainer(container *gabs.Container) error

func (*CreateIndexOptions) Get 

func (do *CreateIndexOptions) Get(value string) interface{}

func (*CreateIndexOptions) GetContainer 

func (do *CreateIndexOptions) GetContainer() *gabs.Container

func (*CreateIndexOptions) GetDisableAction 

func (do *CreateIndexOptions) GetDisableAction() bool

func (*CreateIndexOptions) IsNotifiable 

func (do *CreateIndexOptions) IsNotifiable() bool

func (*CreateIndexOptions) IsSnapshot 

func (do *CreateIndexOptions) IsSnapshot() bool

func (*CreateIndexOptions) String 

func (do *CreateIndexOptions) String(value string) string

func (*CreateIndexOptions) TimeoutInSeconds 

func (do *CreateIndexOptions) TimeoutInSeconds() string

func (*CreateIndexOptions) Validate 

func (cio *CreateIndexOptions) Validate() error

func (CreateIndexOptions) ValidateNotifiableOptions 

func (do CreateIndexOptions) ValidateNotifiableOptions() error

type CreateRepositoryOptions 

type CreateRepositoryOptions struct {
	Compress                  bool   `json:"compress"`
	ChunkSize                 string `json:"chunk_size"`
	MaxRestoreBytesPerSecond  string `json:"max_restore_bytes_per_second"`
	MaxSnapshotBytesPerSecond string `json:"max_snapshot_bytes_per_second"`
	Location                  string `json:"location"`
	Repository                string `json:"repository"`
	RepoType                  string `json:"repo_type"`
	Verify                    bool   `json:"verify"`
	Bucket                    string `json:"bucket"`
	// contains filtered or unexported fields
}

func (*CreateRepositoryOptions) BindFlags 

func (cro *CreateRepositoryOptions) BindFlags(flags *pflag.FlagSet) error

func (*CreateRepositoryOptions) Exists 

func (do *CreateRepositoryOptions) Exists(value string) bool

func (*CreateRepositoryOptions) FillFromContainer 

func (cro *CreateRepositoryOptions) FillFromContainer(container *gabs.Container) error

func (*CreateRepositoryOptions) Get 

func (do *CreateRepositoryOptions) Get(value string) interface{}

func (*CreateRepositoryOptions) GetContainer 

func (do *CreateRepositoryOptions) GetContainer() *gabs.Container

func (*CreateRepositoryOptions) GetDisableAction 

func (do *CreateRepositoryOptions) GetDisableAction() bool

func (*CreateRepositoryOptions) IsNotifiable 

func (do *CreateRepositoryOptions) IsNotifiable() bool

func (*CreateRepositoryOptions) IsSnapshot 

func (do *CreateRepositoryOptions) IsSnapshot() bool

func (*CreateRepositoryOptions) String 

func (do *CreateRepositoryOptions) String(value string) string

func (*CreateRepositoryOptions) TimeoutInSeconds 

func (do *CreateRepositoryOptions) TimeoutInSeconds() string

func (*CreateRepositoryOptions) Validate 

func (cro *CreateRepositoryOptions) Validate() error

func (CreateRepositoryOptions) ValidateNotifiableOptions 

func (do CreateRepositoryOptions) ValidateNotifiableOptions() error

type DeleteIndicesOptions 

type DeleteIndicesOptions struct {
	// contains filtered or unexported fields
}

func (*DeleteIndicesOptions) BindFlags 

func (dio *DeleteIndicesOptions) BindFlags(flags *pflag.FlagSet) error

func (*DeleteIndicesOptions) Exists 

func (do *DeleteIndicesOptions) Exists(value string) bool

func (*DeleteIndicesOptions) FillFromContainer 

func (dio *DeleteIndicesOptions) FillFromContainer(container *gabs.Container) error

func (*DeleteIndicesOptions) Get 

func (do *DeleteIndicesOptions) Get(value string) interface{}

func (*DeleteIndicesOptions) GetContainer 

func (do *DeleteIndicesOptions) GetContainer() *gabs.Container

func (*DeleteIndicesOptions) GetDisableAction 

func (do *DeleteIndicesOptions) GetDisableAction() bool

func (*DeleteIndicesOptions) IsNotifiable 

func (do *DeleteIndicesOptions) IsNotifiable() bool

func (*DeleteIndicesOptions) IsSnapshot 

func (do *DeleteIndicesOptions) IsSnapshot() bool

func (*DeleteIndicesOptions) String 

func (do *DeleteIndicesOptions) String(value string) string

func (*DeleteIndicesOptions) TimeoutInSeconds 

func (do *DeleteIndicesOptions) TimeoutInSeconds() string

func (*DeleteIndicesOptions) Validate 

func (dio *DeleteIndicesOptions) Validate() error

func (DeleteIndicesOptions) ValidateNotifiableOptions 

func (do DeleteIndicesOptions) ValidateNotifiableOptions() error

type DeleteRepositoriesOptions 

type DeleteRepositoriesOptions struct {
	Repositories string `json:"repositories"`
	// contains filtered or unexported fields
}

func (*DeleteRepositoriesOptions) BindFlags 

func (dro *DeleteRepositoriesOptions) BindFlags(flags *pflag.FlagSet) error

func (*DeleteRepositoriesOptions) Exists 

func (do *DeleteRepositoriesOptions) Exists(value string) bool

func (*DeleteRepositoriesOptions) FillFromContainer 

func (dro *DeleteRepositoriesOptions) FillFromContainer(container *gabs.Container) error

func (*DeleteRepositoriesOptions) Get 

func (do *DeleteRepositoriesOptions) Get(value string) interface{}

func (*DeleteRepositoriesOptions) GetContainer 

func (do *DeleteRepositoriesOptions) GetContainer() *gabs.Container

func (*DeleteRepositoriesOptions) GetDisableAction 

func (do *DeleteRepositoriesOptions) GetDisableAction() bool

func (*DeleteRepositoriesOptions) IsNotifiable 

func (do *DeleteRepositoriesOptions) IsNotifiable() bool

func (*DeleteRepositoriesOptions) IsSnapshot 

func (do *DeleteRepositoriesOptions) IsSnapshot() bool

func (*DeleteRepositoriesOptions) String 

func (do *DeleteRepositoriesOptions) String(value string) string

func (*DeleteRepositoriesOptions) TimeoutInSeconds 

func (do *DeleteRepositoriesOptions) TimeoutInSeconds() string

func (*DeleteRepositoriesOptions) Validate 

func (dro *DeleteRepositoriesOptions) Validate() error

func (DeleteRepositoriesOptions) ValidateNotifiableOptions 

func (do DeleteRepositoriesOptions) ValidateNotifiableOptions() error

type DeleteSnapshotsOptions 

type DeleteSnapshotsOptions struct {
	RetryCount    int `json:"retry_count"`
	RetryInterval int `json:"retry_interval"`
	// contains filtered or unexported fields
}

func (*DeleteSnapshotsOptions) BindFlags 

func (dso *DeleteSnapshotsOptions) BindFlags(flags *pflag.FlagSet) error

func (*DeleteSnapshotsOptions) FillFromContainer 

func (dso *DeleteSnapshotsOptions) FillFromContainer(container *gabs.Container) error

func (*DeleteSnapshotsOptions) IsSnapshot 

func (bso *DeleteSnapshotsOptions) IsSnapshot() bool

func (*DeleteSnapshotsOptions) Validate 

func (dso *DeleteSnapshotsOptions) Validate() error

type DumpOptions 

type DumpOptions struct {
	Criteria            []*QueryCriteria `json:"criteria"`
	MaxExecutionTime    int              `json:"max_execution_time"`
	Repository          string           `json:"repository"`
	Name                string           `json:"name"`
	Path                string           `json:"path"`
	Bucket              string           `json:"bucket"`
	CredentialsFilePath string           `json:"credentials_file_path"`
	KeepAlive           int              `json:"keep_alive"`
	Concurrency         int              `json:"concurrency"`
	Size                int              `json:"size"`
	// contains filtered or unexported fields
}

func (*DumpOptions) BindFlags 

func (do *DumpOptions) BindFlags(flags *pflag.FlagSet) error

func (*DumpOptions) Exists 

func (do *DumpOptions) Exists(value string) bool

func (*DumpOptions) FillFromContainer 

func (do *DumpOptions) FillFromContainer(container *gabs.Container) error

func (*DumpOptions) Get 

func (do *DumpOptions) Get(value string) interface{}

func (*DumpOptions) GetContainer 

func (do *DumpOptions) GetContainer() *gabs.Container

func (*DumpOptions) GetDisableAction 

func (do *DumpOptions) GetDisableAction() bool

func (*DumpOptions) IsNotifiable 

func (do *DumpOptions) IsNotifiable() bool

func (*DumpOptions) IsSnapshot 

func (do *DumpOptions) IsSnapshot() bool

func (*DumpOptions) String 

func (do *DumpOptions) String(value string) string

func (*DumpOptions) TimeoutInSeconds 

func (do *DumpOptions) TimeoutInSeconds() string

func (*DumpOptions) Validate 

func (do *DumpOptions) Validate() error

func (DumpOptions) ValidateNotifiableOptions 

func (do DumpOptions) ValidateNotifiableOptions() error

type ImportDumpOptions 

type ImportDumpOptions struct {
	MaxExecutionTime    int                    `json:"max_execution_time"`
	Repository          string                 `json:"repository"`
	Name                string                 `json:"name"`
	Path                string                 `json:"path"`
	Bucket              string                 `json:"bucket"`
	CredentialsFilePath string                 `json:"credentials_file_path"`
	Concurrency         int                    `json:"concurrency"`
	Size                int                    `json:"size"`
	CreateIndexWaitTime int64                  `json:"create_index_wait_time"`
	RemoveSettings      []string               `json:"remove_settings"`
	RemoveMappings      []string               `json:"remove_mappings"`
	RemoveAliases       []string               `json:"remove_aliases"`
	RemoveFields        []string               `json:"remove_fields"`
	ExtraSettings       map[string]interface{} `json:"extra_settings"`
	ExtraMappings       map[string]interface{} `json:"extra_mappings"`
	ExtraAliases        map[string]interface{} `json:"extra_aliases"`
	ExtraFields         map[string]interface{} `json:"extra_fields"`
	// contains filtered or unexported fields
}

func (*ImportDumpOptions) BindFlags 

func (ido *ImportDumpOptions) BindFlags(flags *pflag.FlagSet) error

func (*ImportDumpOptions) Exists 

func (do *ImportDumpOptions) Exists(value string) bool

func (*ImportDumpOptions) FillFromContainer 

func (ido *ImportDumpOptions) FillFromContainer(container *gabs.Container) error

func (*ImportDumpOptions) Get 

func (do *ImportDumpOptions) Get(value string) interface{}

func (*ImportDumpOptions) GetContainer 

func (do *ImportDumpOptions) GetContainer() *gabs.Container

func (*ImportDumpOptions) GetDisableAction 

func (do *ImportDumpOptions) GetDisableAction() bool

func (*ImportDumpOptions) IsNotifiable 

func (do *ImportDumpOptions) IsNotifiable() bool

func (*ImportDumpOptions) IsSnapshot 

func (do *ImportDumpOptions) IsSnapshot() bool

func (*ImportDumpOptions) String 

func (do *ImportDumpOptions) String(value string) string

func (*ImportDumpOptions) TimeoutInSeconds 

func (do *ImportDumpOptions) TimeoutInSeconds() string

func (*ImportDumpOptions) Validate 

func (ido *ImportDumpOptions) Validate() error

func (ImportDumpOptions) ValidateNotifiableOptions 

func (do ImportDumpOptions) ValidateNotifiableOptions() error

type IndexSettingsOptions 

type IndexSettingsOptions struct {
	IndexSettings map[string]interface{} `json:"index_settings"`
	// contains filtered or unexported fields
}

func (*IndexSettingsOptions) BindFlags 

func (iso *IndexSettingsOptions) BindFlags(flags *pflag.FlagSet) error

func (*IndexSettingsOptions) Exists 

func (do *IndexSettingsOptions) Exists(value string) bool

func (*IndexSettingsOptions) FillFromContainer 

func (iso *IndexSettingsOptions) FillFromContainer(container *gabs.Container) error

func (*IndexSettingsOptions) Get 

func (do *IndexSettingsOptions) Get(value string) interface{}

func (*IndexSettingsOptions) GetContainer 

func (do *IndexSettingsOptions) GetContainer() *gabs.Container

func (*IndexSettingsOptions) GetDisableAction 

func (do *IndexSettingsOptions) GetDisableAction() bool

func (*IndexSettingsOptions) IsNotifiable 

func (do *IndexSettingsOptions) IsNotifiable() bool

func (*IndexSettingsOptions) IsSnapshot 

func (do *IndexSettingsOptions) IsSnapshot() bool

func (*IndexSettingsOptions) String 

func (do *IndexSettingsOptions) String(value string) string

func (*IndexSettingsOptions) TimeoutInSeconds 

func (do *IndexSettingsOptions) TimeoutInSeconds() string

func (*IndexSettingsOptions) Validate 

func (iso *IndexSettingsOptions) Validate() error

func (IndexSettingsOptions) ValidateNotifiableOptions 

func (do IndexSettingsOptions) ValidateNotifiableOptions() error

type ListIndicesOptions 

type ListIndicesOptions struct {
	// contains filtered or unexported fields
}

func (*ListIndicesOptions) BindFlags 

func (lio *ListIndicesOptions) BindFlags(flags *pflag.FlagSet) error

func (*ListIndicesOptions) Exists 

func (do *ListIndicesOptions) Exists(value string) bool

func (*ListIndicesOptions) FillFromContainer 

func (lio *ListIndicesOptions) FillFromContainer(container *gabs.Container) error

func (*ListIndicesOptions) Get 

func (do *ListIndicesOptions) Get(value string) interface{}

func (*ListIndicesOptions) GetContainer 

func (do *ListIndicesOptions) GetContainer() *gabs.Container

func (*ListIndicesOptions) GetDisableAction 

func (do *ListIndicesOptions) GetDisableAction() bool

func (*ListIndicesOptions) IsNotifiable 

func (do *ListIndicesOptions) IsNotifiable() bool

func (*ListIndicesOptions) IsSnapshot 

func (do *ListIndicesOptions) IsSnapshot() bool

func (*ListIndicesOptions) String 

func (do *ListIndicesOptions) String(value string) string

func (*ListIndicesOptions) TimeoutInSeconds 

func (do *ListIndicesOptions) TimeoutInSeconds() string

func (*ListIndicesOptions) Validate 

func (lo *ListIndicesOptions) Validate() error

func (ListIndicesOptions) ValidateNotifiableOptions 

func (do ListIndicesOptions) ValidateNotifiableOptions() error

type ListSnapshotsOptions 

type ListSnapshotsOptions struct {
	// contains filtered or unexported fields
}

func (*ListSnapshotsOptions) BindFlags 

func (lso *ListSnapshotsOptions) BindFlags(flags *pflag.FlagSet) error

func (*ListSnapshotsOptions) Exists 

func (lso *ListSnapshotsOptions) Exists(value string) bool

func (*ListSnapshotsOptions) FillFromContainer 

func (lso *ListSnapshotsOptions) FillFromContainer(container *gabs.Container) error

func (*ListSnapshotsOptions) IsSnapshot 

func (bso *ListSnapshotsOptions) IsSnapshot() bool

func (*ListSnapshotsOptions) String 

func (lso *ListSnapshotsOptions) String(value string) string

func (*ListSnapshotsOptions) Validate 

func (lso *ListSnapshotsOptions) Validate() error

type MutateOptions 

type MutateOptions struct {
	Criteria         []*QueryCriteria       `json:"criteria"`
	BatchSize        int                    `json:"batch_size"`
	MaxExecutionTime int                    `json:"max_execution_time"`
	WaitInterval     int                    `json:"wait_interval"`
	Action           string                 `json:"action"`
	Mutation         map[string]interface{} `json:"mutation"`
	// contains filtered or unexported fields
}

func (*MutateOptions) BindFlags 

func (so *MutateOptions) BindFlags(flags *pflag.FlagSet) error

func (*MutateOptions) Exists 

func (do *MutateOptions) Exists(value string) bool

func (*MutateOptions) FillFromContainer 

func (mo *MutateOptions) FillFromContainer(container *gabs.Container) error

func (*MutateOptions) Get 

func (do *MutateOptions) Get(value string) interface{}

func (*MutateOptions) GetContainer 

func (do *MutateOptions) GetContainer() *gabs.Container

func (*MutateOptions) GetDisableAction 

func (do *MutateOptions) GetDisableAction() bool

func (*MutateOptions) IsNotifiable 

func (do *MutateOptions) IsNotifiable() bool

func (*MutateOptions) IsSnapshot 

func (do *MutateOptions) IsSnapshot() bool

func (*MutateOptions) String 

func (do *MutateOptions) String(value string) string

func (*MutateOptions) TimeoutInSeconds 

func (do *MutateOptions) TimeoutInSeconds() string

func (*MutateOptions) Validate 

func (mo *MutateOptions) Validate() error

func (MutateOptions) ValidateNotifiableOptions 

func (do MutateOptions) ValidateNotifiableOptions() error

type OpenIndicesOptions 

type OpenIndicesOptions struct {
	// contains filtered or unexported fields
}

func (*OpenIndicesOptions) BindFlags 

func (oio *OpenIndicesOptions) BindFlags(flags *pflag.FlagSet) error

func (*OpenIndicesOptions) Exists 

func (do *OpenIndicesOptions) Exists(value string) bool

func (*OpenIndicesOptions) FillFromContainer 

func (oio *OpenIndicesOptions) FillFromContainer(container *gabs.Container) error

func (*OpenIndicesOptions) Get 

func (do *OpenIndicesOptions) Get(value string) interface{}

func (*OpenIndicesOptions) GetContainer 

func (do *OpenIndicesOptions) GetContainer() *gabs.Container

func (*OpenIndicesOptions) GetDisableAction 

func (do *OpenIndicesOptions) GetDisableAction() bool

func (*OpenIndicesOptions) IsNotifiable 

func (do *OpenIndicesOptions) IsNotifiable() bool

func (*OpenIndicesOptions) IsSnapshot 

func (do *OpenIndicesOptions) IsSnapshot() bool

func (*OpenIndicesOptions) String 

func (do *OpenIndicesOptions) String(value string) string

func (*OpenIndicesOptions) TimeoutInSeconds 

func (do *OpenIndicesOptions) TimeoutInSeconds() string

func (*OpenIndicesOptions) Validate 

func (oio *OpenIndicesOptions) Validate() error

func (OpenIndicesOptions) ValidateNotifiableOptions 

func (do OpenIndicesOptions) ValidateNotifiableOptions() error

type Optionable 

type Optionable interface {
	FillFromContainer(container *gabs.Container) error

	Validate() error

	ValidateNotifiableOptions() error

	IsNotifiable() bool

	GetDisableAction() bool

	GetContainer() *gabs.Container

	Exists(value string) bool

	IsSnapshot() bool

	Get(value string) interface{}

	String(value string) string
}

type QueryCriteria 

type QueryCriteria struct {
	Clause   string        `json:"clause"`
	Key      string        `json:"key"`
	Operator string        `json:"operator"`
	Value    interface{}   `json:"value"`
	Values   []interface{} `json:"values"`
	Limit    int           `json:"limit"`
	Order    bool          `json:"order"`
}

type RestoreOptions 

type RestoreOptions struct {
	IncludeAliases     bool                   `json:"include_aliases"`
	Partial            bool                   `json:"partial"`
	WaitForCompletion  bool                   `json:"wait_for_completion"`
	MaxWait            int                    `json:"max_wait"`
	WaitInterval       int                    `json:"wait_interval"`
	RenamePattern      string                 `json:"rename_pattern"`
	RenameReplacement  string                 `json:"rename_replacement"`
	Indices            string                 `json:"indices"`
	ExtraSettings      map[string]interface{} `json:"extra_settings"`
	IncludeGlobalState bool                   `json:"include_global_state"`
	IgnoreUnavailable  bool                   `json:"ignore_unavailable"`
	Name               string                 `json:"name"`
	// contains filtered or unexported fields
}

func (*RestoreOptions) BindFlags 

func (ro *RestoreOptions) BindFlags(flags *pflag.FlagSet) error

func (*RestoreOptions) Exists 

func (ro *RestoreOptions) Exists(value string) bool

func (*RestoreOptions) FillFromContainer 

func (ro *RestoreOptions) FillFromContainer(container *gabs.Container) error

func (*RestoreOptions) IsSnapshot 

func (bso *RestoreOptions) IsSnapshot() bool

func (*RestoreOptions) String 

func (ro *RestoreOptions) String(value string) string

func (*RestoreOptions) Validate 

func (ro *RestoreOptions) Validate() error

type RolloverOptions 

type RolloverOptions struct {
	Name          string                 `json:"name"`
	MaxAge        string                 `json:"max_age"`
	MaxDocs       int                    `json:"max_docs"`
	MaxSize       string                 `json:"max_size"`
	ExtraSettings map[string]interface{} `json:"extra_settings"`
	NewIndex      string                 `json:"new_index"`
	// contains filtered or unexported fields
}

func (*RolloverOptions) BindFlags 

func (ro *RolloverOptions) BindFlags(flags *pflag.FlagSet) error

func (*RolloverOptions) Exists 

func (do *RolloverOptions) Exists(value string) bool

func (*RolloverOptions) FillFromContainer 

func (ro *RolloverOptions) FillFromContainer(container *gabs.Container) error

func (*RolloverOptions) Get 

func (do *RolloverOptions) Get(value string) interface{}

func (*RolloverOptions) GetContainer 

func (do *RolloverOptions) GetContainer() *gabs.Container

func (*RolloverOptions) GetDisableAction 

func (do *RolloverOptions) GetDisableAction() bool

func (*RolloverOptions) IsNotifiable 

func (do *RolloverOptions) IsNotifiable() bool

func (*RolloverOptions) IsSnapshot 

func (do *RolloverOptions) IsSnapshot() bool

func (*RolloverOptions) String 

func (do *RolloverOptions) String(value string) string

func (*RolloverOptions) TimeoutInSeconds 

func (do *RolloverOptions) TimeoutInSeconds() string

func (*RolloverOptions) Validate 

func (ro *RolloverOptions) Validate() error

func (RolloverOptions) ValidateNotifiableOptions 

func (do RolloverOptions) ValidateNotifiableOptions() error

type SnapshotOptions 

type SnapshotOptions struct {
	Repository         string `json:"repository"`
	Name               string `json:"name"`
	IgnoreUnavailable  bool   `json:"ignore_unavailable"`
	IncludeGlobalState bool   `json:"include_global_state"`
	Partial            bool   `json:"partial"`
	WaitForCompletion  bool   `json:"wait_for_completion"`
	MaxWait            int    `json:"max_wait"`
	WaitInterval       int    `json:"wait_interval"`
	// contains filtered or unexported fields
}

func (*SnapshotOptions) BindFlags 

func (so *SnapshotOptions) BindFlags(flags *pflag.FlagSet) error

func (*SnapshotOptions) Exists 

func (do *SnapshotOptions) Exists(value string) bool

func (*SnapshotOptions) FillFromContainer 

func (so *SnapshotOptions) FillFromContainer(container *gabs.Container) error

func (*SnapshotOptions) Get 

func (do *SnapshotOptions) Get(value string) interface{}

func (*SnapshotOptions) GetContainer 

func (do *SnapshotOptions) GetContainer() *gabs.Container

func (*SnapshotOptions) GetDisableAction 

func (do *SnapshotOptions) GetDisableAction() bool

func (*SnapshotOptions) IsNotifiable 

func (do *SnapshotOptions) IsNotifiable() bool

func (*SnapshotOptions) IsSnapshot 

func (do *SnapshotOptions) IsSnapshot() bool

func (*SnapshotOptions) String 

func (do *SnapshotOptions) String(value string) string

func (*SnapshotOptions) TimeoutInSeconds 

func (do *SnapshotOptions) TimeoutInSeconds() string

func (*SnapshotOptions) Validate 

func (so *SnapshotOptions) Validate() error

func (SnapshotOptions) ValidateNotifiableOptions 

func (do SnapshotOptions) ValidateNotifiableOptions() error

type Threshold 

type Threshold struct {
	Type   string   `json:"type"`
	Metric string   `json:"metric"`
	Min    *float64 `json:"min"`
	Max    *float64 `json:"max"`
	Alerts []*Alert `json:"alerts"`
}

type WatchOptions 

type WatchOptions struct {
	Interval        int64            `json:"interval"`
	IntervalUnit    string           `json:"interval_unit"`
	DateField       string           `json:"date_field"`
	StatsField      string           `json:"stats_field"`
	Criteria        []*QueryCriteria `json:"criteria"`
	Thresholds      []*Threshold     `json:"thresholds"`
	MessageTemplate string           `json:"message_template"`
	// contains filtered or unexported fields
}

func (*WatchOptions) BindFlags 

func (so *WatchOptions) BindFlags(flags *pflag.FlagSet) error

func (*WatchOptions) Exists 

func (do *WatchOptions) Exists(value string) bool

func (*WatchOptions) FillFromContainer 

func (wo *WatchOptions) FillFromContainer(container *gabs.Container) error

func (*WatchOptions) Get 

func (do *WatchOptions) Get(value string) interface{}

func (*WatchOptions) GetContainer 

func (do *WatchOptions) GetContainer() *gabs.Container

func (*WatchOptions) GetDisableAction 

func (do *WatchOptions) GetDisableAction() bool

func (*WatchOptions) IsNotifiable 

func (do *WatchOptions) IsNotifiable() bool

func (*WatchOptions) IsSnapshot 

func (do *WatchOptions) IsSnapshot() bool

func (*WatchOptions) String 

func (do *WatchOptions) String(value string) string

func (*WatchOptions) TimeoutInSeconds 

func (do *WatchOptions) TimeoutInSeconds() string

func (*WatchOptions) Validate 

func (wo *WatchOptions) Validate() error

func (WatchOptions) ValidateNotifiableOptions 

func (do WatchOptions) ValidateNotifiableOptions() error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.
⌂ 换网址