es_sidecar

package
v0.0.0-...-565567d Latest Latest
Warning

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

 Go to latest Published: Nov 27, 2024 License: Apache-2.0 Imports: 9 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_config_es_sidecar_config_request_proto protoreflect.FileDescriptor

Functions

This section is empty.

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 imports settings from the global configuration

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 (x *ConfigRequest_V1) GetSvc() *ConfigRequest_V1_Service

func (*ConfigRequest_V1) GetSys 

func (x *ConfigRequest_V1) GetSys() *ConfigRequest_V1_System

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_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 {
	Mlsa    *shared.Mlsa                     `protobuf:"bytes,1,opt,name=mlsa,proto3" json:"mlsa,omitempty" toml:"mlsa,omitempty" mapstructure:"mlsa,omitempty"`
	Service *ConfigRequest_V1_System_Service `protobuf:"bytes,2,opt,name=service,proto3" json:"service,omitempty" toml:"service,omitempty" mapstructure:"service,omitempty"`
	Tls     *shared.TLSCredentials           `protobuf:"bytes,3,opt,name=tls,proto3" json:"tls,omitempty" toml:"tls,omitempty" mapstructure:"tls,omitempty"`
	Backups *ConfigRequest_V1_System_Backups `protobuf:"bytes,4,opt,name=backups,proto3" json:"backups,omitempty" toml:"backups,omitempty" mapstructure:"backups,omitempty"` // Internal only
	Log     *ConfigRequest_V1_System_Log     `protobuf:"bytes,5,opt,name=log,proto3" json:"log,omitempty" toml:"log,omitempty" mapstructure:"log,omitempty"`
	// 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) GetBackups 

func (x *ConfigRequest_V1_System) GetBackups() *ConfigRequest_V1_System_Backups

func (*ConfigRequest_V1_System) GetLog 

func (x *ConfigRequest_V1_System) GetLog() *ConfigRequest_V1_System_Log

func (*ConfigRequest_V1_System) GetMlsa 

func (x *ConfigRequest_V1_System) GetMlsa() *shared.Mlsa

func (*ConfigRequest_V1_System) GetService 

func (x *ConfigRequest_V1_System) GetService() *ConfigRequest_V1_System_Service

func (*ConfigRequest_V1_System) GetTls 

func (x *ConfigRequest_V1_System) GetTls() *shared.TLSCredentials

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_System_Backups 

type ConfigRequest_V1_System_Backups struct {
	Backend    *wrapperspb.StringValue                      `protobuf:"bytes,1,opt,name=backend,proto3" json:"backend,omitempty" toml:"backend,omitempty" mapstructure:"backend,omitempty"`
	VerifyRepo *wrapperspb.BoolValue                        `` /* 157-byte string literal not displayed */
	Fs         *ConfigRequest_V1_System_Backups_FsSettings  `protobuf:"bytes,2,opt,name=fs,proto3" json:"fs,omitempty" toml:"fs,omitempty" mapstructure:"fs,omitempty"`
	S3         *ConfigRequest_V1_System_Backups_S3Settings  `protobuf:"bytes,5,opt,name=s3,proto3" json:"s3,omitempty" toml:"s3,omitempty" mapstructure:"s3,omitempty"`
	Gcs        *ConfigRequest_V1_System_Backups_GCSSettings `protobuf:"bytes,7,opt,name=gcs,proto3" json:"gcs,omitempty" toml:"gcs,omitempty" mapstructure:"gcs,omitempty"`
	// contains filtered or unexported fields
}

func (*ConfigRequest_V1_System_Backups) Descriptor deprecated 

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

Deprecated: Use ConfigRequest_V1_System_Backups.ProtoReflect.Descriptor instead.

func (*ConfigRequest_V1_System_Backups) GetBackend 

func (x *ConfigRequest_V1_System_Backups) GetBackend() *wrapperspb.StringValue

func (*ConfigRequest_V1_System_Backups) GetFs 

func (x *ConfigRequest_V1_System_Backups) GetFs() *ConfigRequest_V1_System_Backups_FsSettings

func (*ConfigRequest_V1_System_Backups) GetGcs 

func (x *ConfigRequest_V1_System_Backups) GetGcs() *ConfigRequest_V1_System_Backups_GCSSettings

func (*ConfigRequest_V1_System_Backups) GetS3 

func (x *ConfigRequest_V1_System_Backups) GetS3() *ConfigRequest_V1_System_Backups_S3Settings

func (*ConfigRequest_V1_System_Backups) GetVerifyRepo 

func (x *ConfigRequest_V1_System_Backups) GetVerifyRepo() *wrapperspb.BoolValue

func (*ConfigRequest_V1_System_Backups) ProtoMessage 

func (*ConfigRequest_V1_System_Backups) ProtoMessage()

func (*ConfigRequest_V1_System_Backups) ProtoReflect 

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

func (*ConfigRequest_V1_System_Backups) Reset 

func (x *ConfigRequest_V1_System_Backups) Reset()

func (*ConfigRequest_V1_System_Backups) String 

func (x *ConfigRequest_V1_System_Backups) String() string

type ConfigRequest_V1_System_Backups_FsSettings 

type ConfigRequest_V1_System_Backups_FsSettings struct {
	RootLocation           *wrapperspb.StringValue `` /* 167-byte string literal not displayed */
	MaxSnapshotBytesPerSec *wrapperspb.StringValue `` /* 229-byte string literal not displayed */
	MaxRestoreBytesPerSec  *wrapperspb.StringValue `` /* 224-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ConfigRequest_V1_System_Backups_FsSettings) Descriptor deprecated 

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

Deprecated: Use ConfigRequest_V1_System_Backups_FsSettings.ProtoReflect.Descriptor instead.

func (*ConfigRequest_V1_System_Backups_FsSettings) GetMaxRestoreBytesPerSec 

func (x *ConfigRequest_V1_System_Backups_FsSettings) GetMaxRestoreBytesPerSec() *wrapperspb.StringValue

func (*ConfigRequest_V1_System_Backups_FsSettings) GetMaxSnapshotBytesPerSec 

func (x *ConfigRequest_V1_System_Backups_FsSettings) GetMaxSnapshotBytesPerSec() *wrapperspb.StringValue

func (*ConfigRequest_V1_System_Backups_FsSettings) GetRootLocation 

func (x *ConfigRequest_V1_System_Backups_FsSettings) GetRootLocation() *wrapperspb.StringValue

func (*ConfigRequest_V1_System_Backups_FsSettings) ProtoMessage 

func (*ConfigRequest_V1_System_Backups_FsSettings) ProtoMessage()

func (*ConfigRequest_V1_System_Backups_FsSettings) ProtoReflect 

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

func (*ConfigRequest_V1_System_Backups_FsSettings) Reset 

func (x *ConfigRequest_V1_System_Backups_FsSettings) Reset()

func (*ConfigRequest_V1_System_Backups_FsSettings) String 

func (x *ConfigRequest_V1_System_Backups_FsSettings) String() string

type ConfigRequest_V1_System_Backups_GCSSettings 

type ConfigRequest_V1_System_Backups_GCSSettings struct {
	Bucket   *wrapperspb.StringValue        `protobuf:"bytes,1,opt,name=bucket,proto3" json:"bucket,omitempty" toml:"bucket,omitempty" mapstructure:"bucket,omitempty"`
	Client   *wrapperspb.StringValue        `protobuf:"bytes,2,opt,name=client,proto3" json:"client,omitempty" toml:"client,omitempty" mapstructure:"client,omitempty"`
	BasePath *wrapperspb.StringValue        `` /* 147-byte string literal not displayed */
	Os       *shared.Backups_GCS_Opensearch `protobuf:"bytes,4,opt,name=os,proto3" json:"os,omitempty" toml:"os,omitempty" mapstructure:"os,omitempty"`
	// contains filtered or unexported fields
}

func (*ConfigRequest_V1_System_Backups_GCSSettings) Descriptor deprecated 

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

Deprecated: Use ConfigRequest_V1_System_Backups_GCSSettings.ProtoReflect.Descriptor instead.

func (*ConfigRequest_V1_System_Backups_GCSSettings) GetBasePath 

func (x *ConfigRequest_V1_System_Backups_GCSSettings) GetBasePath() *wrapperspb.StringValue

func (*ConfigRequest_V1_System_Backups_GCSSettings) GetBucket 

func (x *ConfigRequest_V1_System_Backups_GCSSettings) GetBucket() *wrapperspb.StringValue

func (*ConfigRequest_V1_System_Backups_GCSSettings) GetClient 

func (x *ConfigRequest_V1_System_Backups_GCSSettings) GetClient() *wrapperspb.StringValue

func (*ConfigRequest_V1_System_Backups_GCSSettings) GetOs 

func (x *ConfigRequest_V1_System_Backups_GCSSettings) GetOs() *shared.Backups_GCS_Opensearch

func (*ConfigRequest_V1_System_Backups_GCSSettings) ProtoMessage 

func (*ConfigRequest_V1_System_Backups_GCSSettings) ProtoMessage()

func (*ConfigRequest_V1_System_Backups_GCSSettings) ProtoReflect 

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

func (*ConfigRequest_V1_System_Backups_GCSSettings) Reset 

func (x *ConfigRequest_V1_System_Backups_GCSSettings) Reset()

func (*ConfigRequest_V1_System_Backups_GCSSettings) String 

func (x *ConfigRequest_V1_System_Backups_GCSSettings) String() string

type ConfigRequest_V1_System_Backups_S3Settings 

type ConfigRequest_V1_System_Backups_S3Settings struct {
	Bucket        *wrapperspb.StringValue                                      `protobuf:"bytes,1,opt,name=bucket,proto3" json:"bucket,omitempty" toml:"bucket,omitempty" mapstructure:"bucket,omitempty"`
	Client        *wrapperspb.StringValue                                      `protobuf:"bytes,2,opt,name=client,proto3" json:"client,omitempty" toml:"client,omitempty" mapstructure:"client,omitempty"`
	BasePath      *wrapperspb.StringValue                                      `` /* 147-byte string literal not displayed */
	Os            *shared.Backups_S3_Opensearch                                `protobuf:"bytes,4,opt,name=os,proto3" json:"os,omitempty" toml:"os,omitempty" mapstructure:"os,omitempty"`
	EnableAwsAuth *wrapperspb.BoolValue                                        `` /* 176-byte string literal not displayed */
	AwsAuth       *shared.External_Opensearch_Authentication_AwsOpensearchAuth `` /* 142-byte string literal not displayed */
	OsUrl         *wrapperspb.StringValue                                      `` /* 132-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ConfigRequest_V1_System_Backups_S3Settings) Descriptor deprecated 

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

Deprecated: Use ConfigRequest_V1_System_Backups_S3Settings.ProtoReflect.Descriptor instead.

func (*ConfigRequest_V1_System_Backups_S3Settings) GetAwsAuth 

func (x *ConfigRequest_V1_System_Backups_S3Settings) GetAwsAuth() *shared.External_Opensearch_Authentication_AwsOpensearchAuth

func (*ConfigRequest_V1_System_Backups_S3Settings) GetBasePath 

func (x *ConfigRequest_V1_System_Backups_S3Settings) GetBasePath() *wrapperspb.StringValue

func (*ConfigRequest_V1_System_Backups_S3Settings) GetBucket 

func (x *ConfigRequest_V1_System_Backups_S3Settings) GetBucket() *wrapperspb.StringValue

func (*ConfigRequest_V1_System_Backups_S3Settings) GetClient 

func (x *ConfigRequest_V1_System_Backups_S3Settings) GetClient() *wrapperspb.StringValue

func (*ConfigRequest_V1_System_Backups_S3Settings) GetEnableAwsAuth 

func (x *ConfigRequest_V1_System_Backups_S3Settings) GetEnableAwsAuth() *wrapperspb.BoolValue

func (*ConfigRequest_V1_System_Backups_S3Settings) GetOs 

func (x *ConfigRequest_V1_System_Backups_S3Settings) GetOs() *shared.Backups_S3_Opensearch

func (*ConfigRequest_V1_System_Backups_S3Settings) GetOsUrl 

func (x *ConfigRequest_V1_System_Backups_S3Settings) GetOsUrl() *wrapperspb.StringValue

func (*ConfigRequest_V1_System_Backups_S3Settings) ProtoMessage 

func (*ConfigRequest_V1_System_Backups_S3Settings) ProtoMessage()

func (*ConfigRequest_V1_System_Backups_S3Settings) ProtoReflect 

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

func (*ConfigRequest_V1_System_Backups_S3Settings) Reset 

func (x *ConfigRequest_V1_System_Backups_S3Settings) Reset()

func (*ConfigRequest_V1_System_Backups_S3Settings) String 

func (x *ConfigRequest_V1_System_Backups_S3Settings) String() string

type ConfigRequest_V1_System_Log 

type ConfigRequest_V1_System_Log struct {
	Format *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=format,proto3" json:"format,omitempty" toml:"format,omitempty" mapstructure:"format,omitempty"`
	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_System_Log) Descriptor deprecated 

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

Deprecated: Use ConfigRequest_V1_System_Log.ProtoReflect.Descriptor instead.

func (*ConfigRequest_V1_System_Log) GetFormat 

func (x *ConfigRequest_V1_System_Log) GetFormat() *wrapperspb.StringValue

func (*ConfigRequest_V1_System_Log) GetLevel 

func (x *ConfigRequest_V1_System_Log) GetLevel() *wrapperspb.StringValue

func (*ConfigRequest_V1_System_Log) ProtoMessage 

func (*ConfigRequest_V1_System_Log) ProtoMessage()

func (*ConfigRequest_V1_System_Log) ProtoReflect 

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

func (*ConfigRequest_V1_System_Log) Reset 

func (x *ConfigRequest_V1_System_Log) Reset()

func (*ConfigRequest_V1_System_Log) String 

func (x *ConfigRequest_V1_System_Log) String() string

type ConfigRequest_V1_System_Service 

type ConfigRequest_V1_System_Service struct {

	// Deprecated: Do not use.
	Host *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty" toml:"host,omitempty" mapstructure:"host,omitempty"` // The listen host is no longer setable(localhost only)
	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_System_Service) Descriptor deprecated 

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

Deprecated: Use ConfigRequest_V1_System_Service.ProtoReflect.Descriptor instead.

func (*ConfigRequest_V1_System_Service) GetHost deprecated 

func (x *ConfigRequest_V1_System_Service) GetHost() *wrapperspb.StringValue

Deprecated: Do not use.

func (*ConfigRequest_V1_System_Service) GetPort 

func (x *ConfigRequest_V1_System_Service) GetPort() *wrapperspb.Int32Value

func (*ConfigRequest_V1_System_Service) ProtoMessage 

func (*ConfigRequest_V1_System_Service) ProtoMessage()

func (*ConfigRequest_V1_System_Service) ProtoReflect 

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

func (*ConfigRequest_V1_System_Service) Reset 

func (x *ConfigRequest_V1_System_Service) Reset()

func (*ConfigRequest_V1_System_Service) String 

func (x *ConfigRequest_V1_System_Service) String() string

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.