es

package
v0.0.0-...-f54f16c Latest Latest
Warning

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

Go to latest
Published: Apr 24, 2024 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Index

Constants

View Source
const (
	// ESHeapMinGB is the minimum amount of memory in GB we will
	// recommend for ES Heap
	ESHeapMinGB = 1
	// ESHeapMaxGB is the maximum amount of memory in GB we will
	// recommend for ES Heap
	ESHeapMaxGB = 16
	// ESHeapPortion is the proportion of system memory we
	// recommend for ES Heap
	ESHeapPortion = 0.25
	// KBPerGB is the number of KB in a GB, used for conversions
	KBPerGB = 1048576
)

Variables

View Source
var File_config_elasticsearch_config_request_proto protoreflect.FileDescriptor

Functions

func RecommendedHeapSizeGB

func RecommendedHeapSizeGB(sysMemKB int) int

RecommendedHeapSizeGB returns the recommended size of the Elasticsearch heap settings. The returned value is in Gigabytes.

Types

type ConfigRequest

type ConfigRequest struct {
	V1 *ConfigRequest_V1 `protobuf:"bytes,3,opt,name=v1,proto3" json:"v1,omitempty" toml:"v1,omitempty" mapstructure:"v1,omitempty"`
	// contains filtered or unexported fields
}

func DefaultConfigRequest

func DefaultConfigRequest() *ConfigRequest

DefaultConfigRequest returns a new instance of ConfigRequest with default values. nolint: gomnd

func NewConfigRequest

func NewConfigRequest() *ConfigRequest

NewConfigRequest returns a new instance of ConfigRequest with zero values.

func (*ConfigRequest) BindPort

func (m *ConfigRequest) BindPort(name string, value uint16) error

BindPort sets the port tagged with the given name

func (*ConfigRequest) Descriptor deprecated

func (*ConfigRequest) Descriptor() ([]byte, []int)

Deprecated: Use ConfigRequest.ProtoReflect.Descriptor instead.

func (*ConfigRequest) GetPort

func (m *ConfigRequest) GetPort(name string) (uint16, error)

GetPort gets the port tagged with the given name. If the value is not set, it returns 0.

func (*ConfigRequest) GetSecret

func (m *ConfigRequest) GetSecret(name string) *wrappers.StringValue

GetSecret gets a secret by name. Returns nil if it is not set

func (*ConfigRequest) GetV1

func (x *ConfigRequest) GetV1() *ConfigRequest_V1

func (*ConfigRequest) ListPorts

func (m *ConfigRequest) ListPorts() []a2conf.PortInfo

ListPorts lists all the ports exposed by the config

func (*ConfigRequest) ListSecrets

func (m *ConfigRequest) ListSecrets() []a2conf.SecretInfo

ListSecrets lists all the secrets exposed by the config

func (*ConfigRequest) PrepareSystemConfig

func (c *ConfigRequest) PrepareSystemConfig(creds *ac.TLSCredentials) (ac.PreparedSystemConfig, error)

PrepareSystemConfig returns a system configuration that can be used to start the service.

func (*ConfigRequest) ProtoMessage

func (*ConfigRequest) ProtoMessage()

func (*ConfigRequest) ProtoReflect

func (x *ConfigRequest) ProtoReflect() protoreflect.Message

func (*ConfigRequest) Reset

func (x *ConfigRequest) Reset()

func (*ConfigRequest) ServiceName

func (m *ConfigRequest) ServiceName() string

ServiceName returns the name of the service this config belongs to

func (*ConfigRequest) SetGlobalConfig

func (c *ConfigRequest) SetGlobalConfig(g *ac.GlobalConfig)

SetGlobalConfig injects global configuration overrides

func (*ConfigRequest) SetSecret

func (m *ConfigRequest) SetSecret(name string, value *wrappers.StringValue) error

SetSecret sets a secret by name. Returns ErrSecretNotFound if the secret does not exist

func (*ConfigRequest) String

func (x *ConfigRequest) String() string

func (*ConfigRequest) Validate

func (c *ConfigRequest) Validate() error

Validate validates that the config is sufficient to start the Service. If validation succeeds it will return nil, if it fails it will return a new instance of config.InvalidConfigError that has the missing keys and invalid fields populated.

type ConfigRequest_V1

type ConfigRequest_V1 struct {
	Sys *ConfigRequest_V1_System  `protobuf:"bytes,1,opt,name=sys,proto3" json:"sys,omitempty" toml:"sys,omitempty" mapstructure:"sys,omitempty"`
	Svc *ConfigRequest_V1_Service `protobuf:"bytes,2,opt,name=svc,proto3" json:"svc,omitempty" toml:"svc,omitempty" mapstructure:"svc,omitempty"`
	// contains filtered or unexported fields
}

func (*ConfigRequest_V1) Descriptor deprecated

func (*ConfigRequest_V1) Descriptor() ([]byte, []int)

Deprecated: Use ConfigRequest_V1.ProtoReflect.Descriptor instead.

func (*ConfigRequest_V1) GetSvc

func (*ConfigRequest_V1) GetSys

func (*ConfigRequest_V1) ProtoMessage

func (*ConfigRequest_V1) ProtoMessage()

func (*ConfigRequest_V1) ProtoReflect

func (x *ConfigRequest_V1) ProtoReflect() protoreflect.Message

func (*ConfigRequest_V1) Reset

func (x *ConfigRequest_V1) Reset()

func (*ConfigRequest_V1) String

func (x *ConfigRequest_V1) String() string

type ConfigRequest_V1_Action

type ConfigRequest_V1_Action struct {
	DestructiveRequiresName *wrapperspb.BoolValue `` /* 226-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ConfigRequest_V1_Action) Descriptor deprecated

func (*ConfigRequest_V1_Action) Descriptor() ([]byte, []int)

Deprecated: Use ConfigRequest_V1_Action.ProtoReflect.Descriptor instead.

func (*ConfigRequest_V1_Action) GetDestructiveRequiresName

func (x *ConfigRequest_V1_Action) GetDestructiveRequiresName() *wrapperspb.BoolValue

func (*ConfigRequest_V1_Action) ProtoMessage

func (*ConfigRequest_V1_Action) ProtoMessage()

func (*ConfigRequest_V1_Action) ProtoReflect

func (x *ConfigRequest_V1_Action) ProtoReflect() protoreflect.Message

func (*ConfigRequest_V1_Action) Reset

func (x *ConfigRequest_V1_Action) Reset()

func (*ConfigRequest_V1_Action) String

func (x *ConfigRequest_V1_Action) String() string

type ConfigRequest_V1_Allocation

type ConfigRequest_V1_Allocation struct {
	NodeConcurrentRecoveries       *wrapperspb.Int32Value  `` /* 231-byte string literal not displayed */
	NodeInitialPrimariesRecoveries *wrapperspb.Int32Value  `` /* 265-byte string literal not displayed */
	SameShardHost                  *wrapperspb.BoolValue   `` /* 176-byte string literal not displayed */
	AwarenessAttributes            *wrapperspb.StringValue `` /* 202-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ConfigRequest_V1_Allocation) Descriptor deprecated

func (*ConfigRequest_V1_Allocation) Descriptor() ([]byte, []int)

Deprecated: Use ConfigRequest_V1_Allocation.ProtoReflect.Descriptor instead.

func (*ConfigRequest_V1_Allocation) GetAwarenessAttributes

func (x *ConfigRequest_V1_Allocation) GetAwarenessAttributes() *wrapperspb.StringValue

func (*ConfigRequest_V1_Allocation) GetNodeConcurrentRecoveries

func (x *ConfigRequest_V1_Allocation) GetNodeConcurrentRecoveries() *wrapperspb.Int32Value

func (*ConfigRequest_V1_Allocation) GetNodeInitialPrimariesRecoveries

func (x *ConfigRequest_V1_Allocation) GetNodeInitialPrimariesRecoveries() *wrapperspb.Int32Value

func (*ConfigRequest_V1_Allocation) GetSameShardHost

func (x *ConfigRequest_V1_Allocation) GetSameShardHost() *wrapperspb.BoolValue

func (*ConfigRequest_V1_Allocation) ProtoMessage

func (*ConfigRequest_V1_Allocation) ProtoMessage()

func (*ConfigRequest_V1_Allocation) ProtoReflect

func (*ConfigRequest_V1_Allocation) Reset

func (x *ConfigRequest_V1_Allocation) Reset()

func (*ConfigRequest_V1_Allocation) String

func (x *ConfigRequest_V1_Allocation) String() string

type ConfigRequest_V1_Bootstrap

type ConfigRequest_V1_Bootstrap struct {
	MemoryLock *wrapperspb.BoolValue `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ConfigRequest_V1_Bootstrap) Descriptor deprecated

func (*ConfigRequest_V1_Bootstrap) Descriptor() ([]byte, []int)

Deprecated: Use ConfigRequest_V1_Bootstrap.ProtoReflect.Descriptor instead.

func (*ConfigRequest_V1_Bootstrap) GetMemoryLock

func (x *ConfigRequest_V1_Bootstrap) GetMemoryLock() *wrapperspb.BoolValue

func (*ConfigRequest_V1_Bootstrap) ProtoMessage

func (*ConfigRequest_V1_Bootstrap) ProtoMessage()

func (*ConfigRequest_V1_Bootstrap) ProtoReflect

func (*ConfigRequest_V1_Bootstrap) Reset

func (x *ConfigRequest_V1_Bootstrap) Reset()

func (*ConfigRequest_V1_Bootstrap) String

func (x *ConfigRequest_V1_Bootstrap) String() string

type ConfigRequest_V1_Breaker

type ConfigRequest_V1_Breaker struct {
	TotalLimit        *wrapperspb.StringValue `` /* 157-byte string literal not displayed */
	FielddataLimit    *wrapperspb.StringValue `` /* 177-byte string literal not displayed */
	FielddataOverhead *wrapperspb.StringValue `` /* 192-byte string literal not displayed */
	RequestLimit      *wrapperspb.StringValue `` /* 167-byte string literal not displayed */
	RequestOverhead   *wrapperspb.StringValue `` /* 183-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ConfigRequest_V1_Breaker) Descriptor deprecated

func (*ConfigRequest_V1_Breaker) Descriptor() ([]byte, []int)

Deprecated: Use ConfigRequest_V1_Breaker.ProtoReflect.Descriptor instead.

func (*ConfigRequest_V1_Breaker) GetFielddataLimit

func (x *ConfigRequest_V1_Breaker) GetFielddataLimit() *wrapperspb.StringValue

func (*ConfigRequest_V1_Breaker) GetFielddataOverhead

func (x *ConfigRequest_V1_Breaker) GetFielddataOverhead() *wrapperspb.StringValue

func (*ConfigRequest_V1_Breaker) GetRequestLimit

func (x *ConfigRequest_V1_Breaker) GetRequestLimit() *wrapperspb.StringValue

func (*ConfigRequest_V1_Breaker) GetRequestOverhead

func (x *ConfigRequest_V1_Breaker) GetRequestOverhead() *wrapperspb.StringValue

func (*ConfigRequest_V1_Breaker) GetTotalLimit

func (x *ConfigRequest_V1_Breaker) GetTotalLimit() *wrapperspb.StringValue

func (*ConfigRequest_V1_Breaker) ProtoMessage

func (*ConfigRequest_V1_Breaker) ProtoMessage()

func (*ConfigRequest_V1_Breaker) ProtoReflect

func (x *ConfigRequest_V1_Breaker) ProtoReflect() protoreflect.Message

func (*ConfigRequest_V1_Breaker) Reset

func (x *ConfigRequest_V1_Breaker) Reset()

func (*ConfigRequest_V1_Breaker) String

func (x *ConfigRequest_V1_Breaker) String() string

type ConfigRequest_V1_Cluster

type ConfigRequest_V1_Cluster struct {
	Name             *wrapperspb.StringValue   `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty" toml:"name,omitempty" mapstructure:"name,omitempty"`
	MaxShardsPerNode *wrapperspb.Int32Value    `` /* 195-byte string literal not displayed */
	Routing          *ConfigRequest_V1_Routing `protobuf:"bytes,2,opt,name=routing,proto3" json:"routing,omitempty" toml:"routing,omitempty" mapstructure:"routing,omitempty"`
	// contains filtered or unexported fields
}

func (*ConfigRequest_V1_Cluster) Descriptor deprecated

func (*ConfigRequest_V1_Cluster) Descriptor() ([]byte, []int)

Deprecated: Use ConfigRequest_V1_Cluster.ProtoReflect.Descriptor instead.

func (*ConfigRequest_V1_Cluster) GetMaxShardsPerNode

func (x *ConfigRequest_V1_Cluster) GetMaxShardsPerNode() *wrapperspb.Int32Value

func (*ConfigRequest_V1_Cluster) GetName

func (*ConfigRequest_V1_Cluster) GetRouting

func (*ConfigRequest_V1_Cluster) ProtoMessage

func (*ConfigRequest_V1_Cluster) ProtoMessage()

func (*ConfigRequest_V1_Cluster) ProtoReflect

func (x *ConfigRequest_V1_Cluster) ProtoReflect() protoreflect.Message

func (*ConfigRequest_V1_Cluster) Reset

func (x *ConfigRequest_V1_Cluster) Reset()

func (*ConfigRequest_V1_Cluster) String

func (x *ConfigRequest_V1_Cluster) String() string

type ConfigRequest_V1_Deprecated

type ConfigRequest_V1_Deprecated struct {
	ExternalEs *wrapperspb.BoolValue `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ConfigRequest_V1_Deprecated) Descriptor deprecated

func (*ConfigRequest_V1_Deprecated) Descriptor() ([]byte, []int)

Deprecated: Use ConfigRequest_V1_Deprecated.ProtoReflect.Descriptor instead.

func (*ConfigRequest_V1_Deprecated) GetExternalEs

func (x *ConfigRequest_V1_Deprecated) GetExternalEs() *wrapperspb.BoolValue

func (*ConfigRequest_V1_Deprecated) ProtoMessage

func (*ConfigRequest_V1_Deprecated) ProtoMessage()

func (*ConfigRequest_V1_Deprecated) ProtoReflect

func (*ConfigRequest_V1_Deprecated) Reset

func (x *ConfigRequest_V1_Deprecated) Reset()

func (*ConfigRequest_V1_Deprecated) String

func (x *ConfigRequest_V1_Deprecated) String() string

type ConfigRequest_V1_Discovery

type ConfigRequest_V1_Discovery struct {
	PingUnicastHosts   *wrapperspb.StringValue `` /* 191-byte string literal not displayed */
	MinimumMasterNodes *wrapperspb.Int32Value  `` /* 201-byte string literal not displayed */
	ZenFdPingTimeout   *wrapperspb.StringValue `` /* 195-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ConfigRequest_V1_Discovery) Descriptor deprecated

func (*ConfigRequest_V1_Discovery) Descriptor() ([]byte, []int)

Deprecated: Use ConfigRequest_V1_Discovery.ProtoReflect.Descriptor instead.

func (*ConfigRequest_V1_Discovery) GetMinimumMasterNodes

func (x *ConfigRequest_V1_Discovery) GetMinimumMasterNodes() *wrapperspb.Int32Value

func (*ConfigRequest_V1_Discovery) GetPingUnicastHosts

func (x *ConfigRequest_V1_Discovery) GetPingUnicastHosts() *wrapperspb.StringValue

func (*ConfigRequest_V1_Discovery) GetZenFdPingTimeout

func (x *ConfigRequest_V1_Discovery) GetZenFdPingTimeout() *wrapperspb.StringValue

func (*ConfigRequest_V1_Discovery) ProtoMessage

func (*ConfigRequest_V1_Discovery) ProtoMessage()

func (*ConfigRequest_V1_Discovery) ProtoReflect

func (*ConfigRequest_V1_Discovery) Reset

func (x *ConfigRequest_V1_Discovery) Reset()

func (*ConfigRequest_V1_Discovery) String

func (x *ConfigRequest_V1_Discovery) String() string

type ConfigRequest_V1_Fielddata

type ConfigRequest_V1_Fielddata struct {
	CacheSize *wrapperspb.StringValue `` /* 152-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ConfigRequest_V1_Fielddata) Descriptor deprecated

func (*ConfigRequest_V1_Fielddata) Descriptor() ([]byte, []int)

Deprecated: Use ConfigRequest_V1_Fielddata.ProtoReflect.Descriptor instead.

func (*ConfigRequest_V1_Fielddata) GetCacheSize

func (*ConfigRequest_V1_Fielddata) ProtoMessage

func (*ConfigRequest_V1_Fielddata) ProtoMessage()

func (*ConfigRequest_V1_Fielddata) ProtoReflect

func (*ConfigRequest_V1_Fielddata) Reset

func (x *ConfigRequest_V1_Fielddata) Reset()

func (*ConfigRequest_V1_Fielddata) String

func (x *ConfigRequest_V1_Fielddata) String() string

type ConfigRequest_V1_Gateway

type ConfigRequest_V1_Gateway struct {
	RecoverAfterNodes   *wrapperspb.Int32Value  `` /* 196-byte string literal not displayed */
	ExpectedNodes       *wrapperspb.Int32Value  `` /* 172-byte string literal not displayed */
	ExpectedMasterNodes *wrapperspb.Int32Value  `` /* 206-byte string literal not displayed */
	ExpectedDataNodes   *wrapperspb.Int32Value  `` /* 196-byte string literal not displayed */
	RecoverAfterTime    *wrapperspb.StringValue `` /* 191-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ConfigRequest_V1_Gateway) Descriptor deprecated

func (*ConfigRequest_V1_Gateway) Descriptor() ([]byte, []int)

Deprecated: Use ConfigRequest_V1_Gateway.ProtoReflect.Descriptor instead.

func (*ConfigRequest_V1_Gateway) GetExpectedDataNodes

func (x *ConfigRequest_V1_Gateway) GetExpectedDataNodes() *wrapperspb.Int32Value

func (*ConfigRequest_V1_Gateway) GetExpectedMasterNodes

func (x *ConfigRequest_V1_Gateway) GetExpectedMasterNodes() *wrapperspb.Int32Value

func (*ConfigRequest_V1_Gateway) GetExpectedNodes

func (x *ConfigRequest_V1_Gateway) GetExpectedNodes() *wrapperspb.Int32Value

func (*ConfigRequest_V1_Gateway) GetRecoverAfterNodes

func (x *ConfigRequest_V1_Gateway) GetRecoverAfterNodes() *wrapperspb.Int32Value

func (*ConfigRequest_V1_Gateway) GetRecoverAfterTime

func (x *ConfigRequest_V1_Gateway) GetRecoverAfterTime() *wrapperspb.StringValue

func (*ConfigRequest_V1_Gateway) ProtoMessage

func (*ConfigRequest_V1_Gateway) ProtoMessage()

func (*ConfigRequest_V1_Gateway) ProtoReflect

func (x *ConfigRequest_V1_Gateway) ProtoReflect() protoreflect.Message

func (*ConfigRequest_V1_Gateway) Reset

func (x *ConfigRequest_V1_Gateway) Reset()

func (*ConfigRequest_V1_Gateway) String

func (x *ConfigRequest_V1_Gateway) String() string

type ConfigRequest_V1_Index

type ConfigRequest_V1_Index struct {
	NumberOfReplicas *wrapperspb.Int32Value  `` /* 191-byte string literal not displayed */
	RefreshInterval  *wrapperspb.StringValue `` /* 182-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ConfigRequest_V1_Index) Descriptor deprecated

func (*ConfigRequest_V1_Index) Descriptor() ([]byte, []int)

Deprecated: Use ConfigRequest_V1_Index.ProtoReflect.Descriptor instead.

func (*ConfigRequest_V1_Index) GetNumberOfReplicas

func (x *ConfigRequest_V1_Index) GetNumberOfReplicas() *wrapperspb.Int32Value

func (*ConfigRequest_V1_Index) GetRefreshInterval

func (x *ConfigRequest_V1_Index) GetRefreshInterval() *wrapperspb.StringValue

func (*ConfigRequest_V1_Index) ProtoMessage

func (*ConfigRequest_V1_Index) ProtoMessage()

func (*ConfigRequest_V1_Index) ProtoReflect

func (x *ConfigRequest_V1_Index) ProtoReflect() protoreflect.Message

func (*ConfigRequest_V1_Index) Reset

func (x *ConfigRequest_V1_Index) Reset()

func (*ConfigRequest_V1_Index) String

func (x *ConfigRequest_V1_Index) String() string

type ConfigRequest_V1_Indices

type ConfigRequest_V1_Indices struct {
	Recovery  *ConfigRequest_V1_Recovery  `` /* 129-byte string literal not displayed */
	Fielddata *ConfigRequest_V1_Fielddata `` /* 133-byte string literal not displayed */
	Breaker   *ConfigRequest_V1_Breaker   `protobuf:"bytes,3,opt,name=breaker,proto3" json:"breaker,omitempty" toml:"breaker,omitempty" mapstructure:"breaker,omitempty"`
	// contains filtered or unexported fields
}

func (*ConfigRequest_V1_Indices) Descriptor deprecated

func (*ConfigRequest_V1_Indices) Descriptor() ([]byte, []int)

Deprecated: Use ConfigRequest_V1_Indices.ProtoReflect.Descriptor instead.

func (*ConfigRequest_V1_Indices) GetBreaker

func (*ConfigRequest_V1_Indices) GetFielddata

func (*ConfigRequest_V1_Indices) GetRecovery

func (*ConfigRequest_V1_Indices) ProtoMessage

func (*ConfigRequest_V1_Indices) ProtoMessage()

func (*ConfigRequest_V1_Indices) ProtoReflect

func (x *ConfigRequest_V1_Indices) ProtoReflect() protoreflect.Message

func (*ConfigRequest_V1_Indices) Reset

func (x *ConfigRequest_V1_Indices) Reset()

func (*ConfigRequest_V1_Indices) String

func (x *ConfigRequest_V1_Indices) String() string

type ConfigRequest_V1_Logger

type ConfigRequest_V1_Logger struct {
	Level *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=level,proto3" json:"level,omitempty" toml:"level,omitempty" mapstructure:"level,omitempty"`
	// contains filtered or unexported fields
}

func (*ConfigRequest_V1_Logger) Descriptor deprecated

func (*ConfigRequest_V1_Logger) Descriptor() ([]byte, []int)

Deprecated: Use ConfigRequest_V1_Logger.ProtoReflect.Descriptor instead.

func (*ConfigRequest_V1_Logger) GetLevel

func (*ConfigRequest_V1_Logger) ProtoMessage

func (*ConfigRequest_V1_Logger) ProtoMessage()

func (*ConfigRequest_V1_Logger) ProtoReflect

func (x *ConfigRequest_V1_Logger) ProtoReflect() protoreflect.Message

func (*ConfigRequest_V1_Logger) Reset

func (x *ConfigRequest_V1_Logger) Reset()

func (*ConfigRequest_V1_Logger) String

func (x *ConfigRequest_V1_Logger) String() string

type ConfigRequest_V1_Network

type ConfigRequest_V1_Network struct {
	Host *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty" toml:"host,omitempty" mapstructure:"host,omitempty"`
	Port *wrapperspb.Int32Value  `protobuf:"bytes,2,opt,name=port,proto3" json:"port,omitempty" toml:"port,omitempty" mapstructure:"port,omitempty"`
	// contains filtered or unexported fields
}

func (*ConfigRequest_V1_Network) Descriptor deprecated

func (*ConfigRequest_V1_Network) Descriptor() ([]byte, []int)

Deprecated: Use ConfigRequest_V1_Network.ProtoReflect.Descriptor instead.

func (*ConfigRequest_V1_Network) GetHost

func (*ConfigRequest_V1_Network) GetPort

func (*ConfigRequest_V1_Network) ProtoMessage

func (*ConfigRequest_V1_Network) ProtoMessage()

func (*ConfigRequest_V1_Network) ProtoReflect

func (x *ConfigRequest_V1_Network) ProtoReflect() protoreflect.Message

func (*ConfigRequest_V1_Network) Reset

func (x *ConfigRequest_V1_Network) Reset()

func (*ConfigRequest_V1_Network) String

func (x *ConfigRequest_V1_Network) String() string

type ConfigRequest_V1_Node

type ConfigRequest_V1_Node struct {
	Name                 *wrapperspb.StringValue `protobuf:"bytes,7,opt,name=name,proto3" json:"name,omitempty" toml:"name,omitempty" mapstructure:"name,omitempty"`
	RackId               *wrapperspb.StringValue `` /* 137-byte string literal not displayed */
	Zone                 *wrapperspb.StringValue `protobuf:"bytes,9,opt,name=zone,proto3" json:"zone,omitempty" toml:"zone,omitempty" mapstructure:"zone,omitempty"`
	MaxLocalStorageNodes *wrapperspb.Int32Value  `` /* 216-byte string literal not displayed */
	Master               *wrapperspb.BoolValue   `protobuf:"bytes,11,opt,name=master,proto3" json:"master,omitempty" toml:"master,omitempty" mapstructure:"master,omitempty"`
	Data                 *wrapperspb.BoolValue   `protobuf:"bytes,12,opt,name=data,proto3" json:"data,omitempty" toml:"data,omitempty" mapstructure:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*ConfigRequest_V1_Node) Descriptor deprecated

func (*ConfigRequest_V1_Node) Descriptor() ([]byte, []int)

Deprecated: Use ConfigRequest_V1_Node.ProtoReflect.Descriptor instead.

func (*ConfigRequest_V1_Node) GetData

func (*ConfigRequest_V1_Node) GetMaster

func (x *ConfigRequest_V1_Node) GetMaster() *wrapperspb.BoolValue

func (*ConfigRequest_V1_Node) GetMaxLocalStorageNodes

func (x *ConfigRequest_V1_Node) GetMaxLocalStorageNodes() *wrapperspb.Int32Value

func (*ConfigRequest_V1_Node) GetName

func (*ConfigRequest_V1_Node) GetRackId

func (*ConfigRequest_V1_Node) GetZone

func (*ConfigRequest_V1_Node) ProtoMessage

func (*ConfigRequest_V1_Node) ProtoMessage()

func (*ConfigRequest_V1_Node) ProtoReflect

func (x *ConfigRequest_V1_Node) ProtoReflect() protoreflect.Message

func (*ConfigRequest_V1_Node) Reset

func (x *ConfigRequest_V1_Node) Reset()

func (*ConfigRequest_V1_Node) String

func (x *ConfigRequest_V1_Node) String() string

type ConfigRequest_V1_Path

type ConfigRequest_V1_Path struct {
	Data *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty" toml:"data,omitempty" mapstructure:"data,omitempty"`
	Logs *wrapperspb.StringValue `protobuf:"bytes,4,opt,name=logs,proto3" json:"logs,omitempty" toml:"logs,omitempty" mapstructure:"logs,omitempty"`
	Repo *wrapperspb.StringValue `protobuf:"bytes,5,opt,name=repo,proto3" json:"repo,omitempty" toml:"repo,omitempty" mapstructure:"repo,omitempty"`
	// contains filtered or unexported fields
}

func (*ConfigRequest_V1_Path) Descriptor deprecated

func (*ConfigRequest_V1_Path) Descriptor() ([]byte, []int)

Deprecated: Use ConfigRequest_V1_Path.ProtoReflect.Descriptor instead.

func (*ConfigRequest_V1_Path) GetData

func (*ConfigRequest_V1_Path) GetLogs

func (*ConfigRequest_V1_Path) GetRepo

func (*ConfigRequest_V1_Path) ProtoMessage

func (*ConfigRequest_V1_Path) ProtoMessage()

func (*ConfigRequest_V1_Path) ProtoReflect

func (x *ConfigRequest_V1_Path) ProtoReflect() protoreflect.Message

func (*ConfigRequest_V1_Path) Reset

func (x *ConfigRequest_V1_Path) Reset()

func (*ConfigRequest_V1_Path) String

func (x *ConfigRequest_V1_Path) String() string

type ConfigRequest_V1_Plugins

type ConfigRequest_V1_Plugins struct {
	CloudAwsSigner *wrapperspb.StringValue `` /* 181-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ConfigRequest_V1_Plugins) Descriptor deprecated

func (*ConfigRequest_V1_Plugins) Descriptor() ([]byte, []int)

Deprecated: Use ConfigRequest_V1_Plugins.ProtoReflect.Descriptor instead.

func (*ConfigRequest_V1_Plugins) GetCloudAwsSigner

func (x *ConfigRequest_V1_Plugins) GetCloudAwsSigner() *wrapperspb.StringValue

func (*ConfigRequest_V1_Plugins) ProtoMessage

func (*ConfigRequest_V1_Plugins) ProtoMessage()

func (*ConfigRequest_V1_Plugins) ProtoReflect

func (x *ConfigRequest_V1_Plugins) ProtoReflect() protoreflect.Message

func (*ConfigRequest_V1_Plugins) Reset

func (x *ConfigRequest_V1_Plugins) Reset()

func (*ConfigRequest_V1_Plugins) String

func (x *ConfigRequest_V1_Plugins) String() string

type ConfigRequest_V1_ProxyConfig

type ConfigRequest_V1_ProxyConfig struct {
	Host     *wrapperspb.StringValue   `protobuf:"bytes,6,opt,name=host,proto3" json:"host,omitempty" toml:"host,omitempty" mapstructure:"host,omitempty"`
	Port     *wrapperspb.Int32Value    `protobuf:"bytes,7,opt,name=port,proto3" json:"port,omitempty" toml:"port,omitempty" mapstructure:"port,omitempty"`
	User     *wrapperspb.StringValue   `protobuf:"bytes,8,opt,name=user,proto3" json:"user,omitempty" toml:"user,omitempty" mapstructure:"user,omitempty"`
	Password *wrapperspb.StringValue   `` /* 129-byte string literal not displayed */
	NoProxy  []*wrapperspb.StringValue `` /* 143-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ConfigRequest_V1_ProxyConfig) Descriptor deprecated

func (*ConfigRequest_V1_ProxyConfig) Descriptor() ([]byte, []int)

Deprecated: Use ConfigRequest_V1_ProxyConfig.ProtoReflect.Descriptor instead.

func (*ConfigRequest_V1_ProxyConfig) GetHost

func (*ConfigRequest_V1_ProxyConfig) GetNoProxy

func (*ConfigRequest_V1_ProxyConfig) GetPassword

func (*ConfigRequest_V1_ProxyConfig) GetPort

func (*ConfigRequest_V1_ProxyConfig) GetUser

func (*ConfigRequest_V1_ProxyConfig) ProtoMessage

func (*ConfigRequest_V1_ProxyConfig) ProtoMessage()

func (*ConfigRequest_V1_ProxyConfig) ProtoReflect

func (*ConfigRequest_V1_ProxyConfig) Reset

func (x *ConfigRequest_V1_ProxyConfig) Reset()

func (*ConfigRequest_V1_ProxyConfig) String

type ConfigRequest_V1_Recovery

type ConfigRequest_V1_Recovery struct {
	MaxBytesPerSec *wrapperspb.StringValue `` /* 185-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ConfigRequest_V1_Recovery) Descriptor deprecated

func (*ConfigRequest_V1_Recovery) Descriptor() ([]byte, []int)

Deprecated: Use ConfigRequest_V1_Recovery.ProtoReflect.Descriptor instead.

func (*ConfigRequest_V1_Recovery) GetMaxBytesPerSec

func (x *ConfigRequest_V1_Recovery) GetMaxBytesPerSec() *wrapperspb.StringValue

func (*ConfigRequest_V1_Recovery) ProtoMessage

func (*ConfigRequest_V1_Recovery) ProtoMessage()

func (*ConfigRequest_V1_Recovery) ProtoReflect

func (*ConfigRequest_V1_Recovery) Reset

func (x *ConfigRequest_V1_Recovery) Reset()

func (*ConfigRequest_V1_Recovery) String

func (x *ConfigRequest_V1_Recovery) String() string

type ConfigRequest_V1_Routing

type ConfigRequest_V1_Routing struct {
	Allocation *ConfigRequest_V1_Allocation `` /* 137-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ConfigRequest_V1_Routing) Descriptor deprecated

func (*ConfigRequest_V1_Routing) Descriptor() ([]byte, []int)

Deprecated: Use ConfigRequest_V1_Routing.ProtoReflect.Descriptor instead.

func (*ConfigRequest_V1_Routing) GetAllocation

func (*ConfigRequest_V1_Routing) ProtoMessage

func (*ConfigRequest_V1_Routing) ProtoMessage()

func (*ConfigRequest_V1_Routing) ProtoReflect

func (x *ConfigRequest_V1_Routing) ProtoReflect() protoreflect.Message

func (*ConfigRequest_V1_Routing) Reset

func (x *ConfigRequest_V1_Routing) Reset()

func (*ConfigRequest_V1_Routing) String

func (x *ConfigRequest_V1_Routing) String() string

type ConfigRequest_V1_Runtime

type ConfigRequest_V1_Runtime struct {
	MaxOpenFiles       *wrapperspb.StringValue `` /* 171-byte string literal not displayed */
	MaxLockedMemory    *wrapperspb.StringValue `` /* 186-byte string literal not displayed */
	EsStartupSleepTime *wrapperspb.Int32Value  `` /* 205-byte string literal not displayed */
	EsJavaOpts         *wrapperspb.StringValue `` /* 161-byte string literal not displayed */
	Heapsize           *wrapperspb.StringValue `` /* 130-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ConfigRequest_V1_Runtime) Descriptor deprecated

func (*ConfigRequest_V1_Runtime) Descriptor() ([]byte, []int)

Deprecated: Use ConfigRequest_V1_Runtime.ProtoReflect.Descriptor instead.

func (*ConfigRequest_V1_Runtime) GetEsJavaOpts

func (x *ConfigRequest_V1_Runtime) GetEsJavaOpts() *wrapperspb.StringValue

func (*ConfigRequest_V1_Runtime) GetEsStartupSleepTime

func (x *ConfigRequest_V1_Runtime) GetEsStartupSleepTime() *wrapperspb.Int32Value

func (*ConfigRequest_V1_Runtime) GetHeapsize

func (*ConfigRequest_V1_Runtime) GetMaxLockedMemory

func (x *ConfigRequest_V1_Runtime) GetMaxLockedMemory() *wrapperspb.StringValue

func (*ConfigRequest_V1_Runtime) GetMaxOpenFiles

func (x *ConfigRequest_V1_Runtime) GetMaxOpenFiles() *wrapperspb.StringValue

func (*ConfigRequest_V1_Runtime) ProtoMessage

func (*ConfigRequest_V1_Runtime) ProtoMessage()

func (*ConfigRequest_V1_Runtime) ProtoReflect

func (x *ConfigRequest_V1_Runtime) ProtoReflect() protoreflect.Message

func (*ConfigRequest_V1_Runtime) Reset

func (x *ConfigRequest_V1_Runtime) Reset()

func (*ConfigRequest_V1_Runtime) String

func (x *ConfigRequest_V1_Runtime) String() string

type ConfigRequest_V1_S3

type ConfigRequest_V1_S3 struct {
	Client *ConfigRequest_V1_S3_Client `protobuf:"bytes,1,opt,name=client,proto3" json:"client,omitempty" toml:"client,omitempty" mapstructure:"client,omitempty"`
	// contains filtered or unexported fields
}

func (*ConfigRequest_V1_S3) Descriptor deprecated

func (*ConfigRequest_V1_S3) Descriptor() ([]byte, []int)

Deprecated: Use ConfigRequest_V1_S3.ProtoReflect.Descriptor instead.

func (*ConfigRequest_V1_S3) GetClient

func (*ConfigRequest_V1_S3) ProtoMessage

func (*ConfigRequest_V1_S3) ProtoMessage()

func (*ConfigRequest_V1_S3) ProtoReflect

func (x *ConfigRequest_V1_S3) ProtoReflect() protoreflect.Message

func (*ConfigRequest_V1_S3) Reset

func (x *ConfigRequest_V1_S3) Reset()

func (*ConfigRequest_V1_S3) String

func (x *ConfigRequest_V1_S3) String() string

type ConfigRequest_V1_S3_Client

type ConfigRequest_V1_S3_Client struct {
	Name               *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty" toml:"name,omitempty" mapstructure:"name,omitempty"`
	ReadTimeout        *wrapperspb.StringValue `` /* 162-byte string literal not displayed */
	MaxRetries         *wrapperspb.Int32Value  `` /* 157-byte string literal not displayed */
	UseThrottleRetries *wrapperspb.BoolValue   `` /* 201-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ConfigRequest_V1_S3_Client) Descriptor deprecated

func (*ConfigRequest_V1_S3_Client) Descriptor() ([]byte, []int)

Deprecated: Use ConfigRequest_V1_S3_Client.ProtoReflect.Descriptor instead.

func (*ConfigRequest_V1_S3_Client) GetMaxRetries

func (x *ConfigRequest_V1_S3_Client) GetMaxRetries() *wrapperspb.Int32Value

func (*ConfigRequest_V1_S3_Client) GetName

func (*ConfigRequest_V1_S3_Client) GetReadTimeout

func (x *ConfigRequest_V1_S3_Client) GetReadTimeout() *wrapperspb.StringValue

func (*ConfigRequest_V1_S3_Client) GetUseThrottleRetries

func (x *ConfigRequest_V1_S3_Client) GetUseThrottleRetries() *wrapperspb.BoolValue

func (*ConfigRequest_V1_S3_Client) ProtoMessage

func (*ConfigRequest_V1_S3_Client) ProtoMessage()

func (*ConfigRequest_V1_S3_Client) ProtoReflect

func (*ConfigRequest_V1_S3_Client) Reset

func (x *ConfigRequest_V1_S3_Client) Reset()

func (*ConfigRequest_V1_S3_Client) String

func (x *ConfigRequest_V1_S3_Client) String() string

type ConfigRequest_V1_Service

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

func (*ConfigRequest_V1_Service) Descriptor deprecated

func (*ConfigRequest_V1_Service) Descriptor() ([]byte, []int)

Deprecated: Use ConfigRequest_V1_Service.ProtoReflect.Descriptor instead.

func (*ConfigRequest_V1_Service) ProtoMessage

func (*ConfigRequest_V1_Service) ProtoMessage()

func (*ConfigRequest_V1_Service) ProtoReflect

func (x *ConfigRequest_V1_Service) ProtoReflect() protoreflect.Message

func (*ConfigRequest_V1_Service) Reset

func (x *ConfigRequest_V1_Service) Reset()

func (*ConfigRequest_V1_Service) String

func (x *ConfigRequest_V1_Service) String() string

type ConfigRequest_V1_System

type ConfigRequest_V1_System struct {
	Proxy      *ConfigRequest_V1_ProxyConfig `protobuf:"bytes,2,opt,name=proxy,proto3" json:"proxy,omitempty" toml:"proxy,omitempty" mapstructure:"proxy,omitempty"`
	Cluster    *ConfigRequest_V1_Cluster     `protobuf:"bytes,1,opt,name=cluster,proto3" json:"cluster,omitempty" toml:"cluster,omitempty" mapstructure:"cluster,omitempty"`
	Node       *ConfigRequest_V1_Node        `protobuf:"bytes,4,opt,name=node,proto3" json:"node,omitempty" toml:"node,omitempty" mapstructure:"node,omitempty"`
	Path       *ConfigRequest_V1_Path        `protobuf:"bytes,5,opt,name=path,proto3" json:"path,omitempty" toml:"path,omitempty" mapstructure:"path,omitempty"`
	Indices    *ConfigRequest_V1_Indices     `protobuf:"bytes,6,opt,name=indices,proto3" json:"indices,omitempty" toml:"indices,omitempty" mapstructure:"indices,omitempty"`
	Bootstrap  *ConfigRequest_V1_Bootstrap   `` /* 133-byte string literal not displayed */
	Network    *ConfigRequest_V1_Network     `protobuf:"bytes,8,opt,name=network,proto3" json:"network,omitempty" toml:"network,omitempty" mapstructure:"network,omitempty"`
	Transport  *ConfigRequest_V1_Transport   `` /* 133-byte string literal not displayed */
	Discovery  *ConfigRequest_V1_Discovery   `` /* 134-byte string literal not displayed */
	Gateway    *ConfigRequest_V1_Gateway     `` /* 126-byte string literal not displayed */
	Action     *ConfigRequest_V1_Action      `protobuf:"bytes,12,opt,name=action,proto3" json:"action,omitempty" toml:"action,omitempty" mapstructure:"action,omitempty"`
	Logger     *ConfigRequest_V1_Logger      `protobuf:"bytes,13,opt,name=logger,proto3" json:"logger,omitempty" toml:"logger,omitempty" mapstructure:"logger,omitempty"`
	Plugins    *ConfigRequest_V1_Plugins     `` /* 126-byte string literal not displayed */
	Runtime    *ConfigRequest_V1_Runtime     `` /* 126-byte string literal not displayed */
	S3         *ConfigRequest_V1_S3          `protobuf:"bytes,16,opt,name=s3,proto3" json:"s3,omitempty" toml:"s3,omitempty" mapstructure:"s3,omitempty"`
	Tls        *shared.TLSCredentials        `protobuf:"bytes,17,opt,name=tls,proto3" json:"tls,omitempty" toml:"tls,omitempty" mapstructure:"tls,omitempty"`
	Deprecated *ConfigRequest_V1_Deprecated  `` /* 138-byte string literal not displayed */
	Index      *ConfigRequest_V1_Index       `protobuf:"bytes,20,opt,name=index,proto3" json:"index,omitempty" toml:"index,omitempty" mapstructure:"index,omitempty"`
	Disable    *wrapperspb.BoolValue         `` // If set to true, automate-elasticsearch will noop. Derived from the global config
	/* 126-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ConfigRequest_V1_System) Descriptor deprecated

func (*ConfigRequest_V1_System) Descriptor() ([]byte, []int)

Deprecated: Use ConfigRequest_V1_System.ProtoReflect.Descriptor instead.

func (*ConfigRequest_V1_System) GetAction

func (*ConfigRequest_V1_System) GetBootstrap

func (*ConfigRequest_V1_System) GetCluster

func (*ConfigRequest_V1_System) GetDeprecated

func (*ConfigRequest_V1_System) GetDisable

func (x *ConfigRequest_V1_System) GetDisable() *wrapperspb.BoolValue

func (*ConfigRequest_V1_System) GetDiscovery

func (*ConfigRequest_V1_System) GetGateway

func (*ConfigRequest_V1_System) GetIndex

func (*ConfigRequest_V1_System) GetIndices

func (*ConfigRequest_V1_System) GetLogger

func (*ConfigRequest_V1_System) GetNetwork

func (*ConfigRequest_V1_System) GetNode

func (*ConfigRequest_V1_System) GetPath

func (*ConfigRequest_V1_System) GetPlugins

func (*ConfigRequest_V1_System) GetProxy

func (*ConfigRequest_V1_System) GetRuntime

func (*ConfigRequest_V1_System) GetS3

func (*ConfigRequest_V1_System) GetTls

func (*ConfigRequest_V1_System) GetTransport

func (*ConfigRequest_V1_System) ProtoMessage

func (*ConfigRequest_V1_System) ProtoMessage()

func (*ConfigRequest_V1_System) ProtoReflect

func (x *ConfigRequest_V1_System) ProtoReflect() protoreflect.Message

func (*ConfigRequest_V1_System) Reset

func (x *ConfigRequest_V1_System) Reset()

func (*ConfigRequest_V1_System) String

func (x *ConfigRequest_V1_System) String() string

type ConfigRequest_V1_Transport

type ConfigRequest_V1_Transport struct {

	// the transport port is actually a range of ports
	// e.g. 9300-9400
	Port *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=port,proto3" json:"port,omitempty" toml:"port,omitempty" mapstructure:"port,omitempty"`
	// contains filtered or unexported fields
}

func (*ConfigRequest_V1_Transport) Descriptor deprecated

func (*ConfigRequest_V1_Transport) Descriptor() ([]byte, []int)

Deprecated: Use ConfigRequest_V1_Transport.ProtoReflect.Descriptor instead.

func (*ConfigRequest_V1_Transport) GetPort

func (*ConfigRequest_V1_Transport) ProtoMessage

func (*ConfigRequest_V1_Transport) ProtoMessage()

func (*ConfigRequest_V1_Transport) ProtoReflect

func (*ConfigRequest_V1_Transport) Reset

func (x *ConfigRequest_V1_Transport) Reset()

func (*ConfigRequest_V1_Transport) String

func (x *ConfigRequest_V1_Transport) String() string

Jump to

Keyboard shortcuts

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