consulx

package
v0.0.3 Latest Latest
Warning

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

 Go to latest Published: Mar 19, 2025 License: MIT Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_pkg_consulx_config_proto protoreflect.FileDescriptor
View Source 
var Provider = wire.NewSet(
	NewClients,
)

Functions

func NewClient 

func NewClient(options *Options) (*api.Client, error)

func NewClients 

func NewClients(config *Config) *lazyloadx.Group[*api.Client]

Types

type Config 

type Config struct {
	Configs map[string]*Options `` /* 155-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Config) Descriptor deprecated added in v0.0.2 

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

Deprecated: Use Config.ProtoReflect.Descriptor instead.

func (*Config) GetConfigs added in v0.0.2 

func (x *Config) GetConfigs() map[string]*Options

func (*Config) ProtoMessage added in v0.0.2 

func (*Config) ProtoMessage()

func (*Config) ProtoReflect added in v0.0.2 

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

func (*Config) Reset added in v0.0.2 

func (x *Config) Reset()

func (*Config) String added in v0.0.2 

func (x *Config) String() string

type Options added in v0.0.2 

type Options struct {
	Address    *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	Scheme     *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=scheme,proto3" json:"scheme,omitempty"`
	PathPrefix *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=path_prefix,json=pathPrefix,proto3" json:"path_prefix,omitempty"`
	Datacenter *wrapperspb.StringValue `protobuf:"bytes,4,opt,name=datacenter,proto3" json:"datacenter,omitempty"`
	HttpAuth   *Options_HttpBasicAuth  `protobuf:"bytes,5,opt,name=http_auth,json=httpAuth,proto3" json:"http_auth,omitempty"`
	WaitTime   *durationpb.Duration    `protobuf:"bytes,6,opt,name=wait_time,json=waitTime,proto3" json:"wait_time,omitempty"`
	Token      *wrapperspb.StringValue `protobuf:"bytes,7,opt,name=token,proto3" json:"token,omitempty"`
	TokenFile  *wrapperspb.StringValue `protobuf:"bytes,8,opt,name=token_file,json=tokenFile,proto3" json:"token_file,omitempty"`
	Namespace  *wrapperspb.StringValue `protobuf:"bytes,9,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Partition  *wrapperspb.StringValue `protobuf:"bytes,10,opt,name=partition,proto3" json:"partition,omitempty"`
	TlsConfig  *Options_TLSConfig      `protobuf:"bytes,11,opt,name=tls_config,json=tlsConfig,proto3" json:"tls_config,omitempty"`
	// contains filtered or unexported fields
}

Config is used to pass multiple configuration options to Sarama's constructors.

func (*Options) Descriptor deprecated added in v0.0.2 

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

Deprecated: Use Options.ProtoReflect.Descriptor instead.

func (*Options) GetAddress added in v0.0.2 

func (x *Options) GetAddress() *wrapperspb.StringValue

func (*Options) GetDatacenter added in v0.0.2 

func (x *Options) GetDatacenter() *wrapperspb.StringValue

func (*Options) GetHttpAuth added in v0.0.2 

func (x *Options) GetHttpAuth() *Options_HttpBasicAuth

func (*Options) GetNamespace added in v0.0.2 

func (x *Options) GetNamespace() *wrapperspb.StringValue

func (*Options) GetPartition added in v0.0.2 

func (x *Options) GetPartition() *wrapperspb.StringValue

func (*Options) GetPathPrefix added in v0.0.2 

func (x *Options) GetPathPrefix() *wrapperspb.StringValue

func (*Options) GetScheme added in v0.0.2 

func (x *Options) GetScheme() *wrapperspb.StringValue

func (*Options) GetTlsConfig added in v0.0.2 

func (x *Options) GetTlsConfig() *Options_TLSConfig

func (*Options) GetToken added in v0.0.2 

func (x *Options) GetToken() *wrapperspb.StringValue

func (*Options) GetTokenFile added in v0.0.2 

func (x *Options) GetTokenFile() *wrapperspb.StringValue

func (*Options) GetWaitTime added in v0.0.2 

func (x *Options) GetWaitTime() *durationpb.Duration

func (*Options) ProtoMessage added in v0.0.2 

func (*Options) ProtoMessage()

func (*Options) ProtoReflect added in v0.0.2 

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

func (*Options) Reset added in v0.0.2 

func (x *Options) Reset()

func (*Options) String added in v0.0.2 

func (x *Options) String() string

type Options_HttpBasicAuth added in v0.0.2 

type Options_HttpBasicAuth struct {
	Username *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"`
	Password *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"`
	// contains filtered or unexported fields
}

func (*Options_HttpBasicAuth) Descriptor deprecated added in v0.0.2 

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

Deprecated: Use Options_HttpBasicAuth.ProtoReflect.Descriptor instead.

func (*Options_HttpBasicAuth) GetPassword added in v0.0.2 

func (x *Options_HttpBasicAuth) GetPassword() *wrapperspb.StringValue

func (*Options_HttpBasicAuth) GetUsername added in v0.0.2 

func (x *Options_HttpBasicAuth) GetUsername() *wrapperspb.StringValue

func (*Options_HttpBasicAuth) ProtoMessage added in v0.0.2 

func (*Options_HttpBasicAuth) ProtoMessage()

func (*Options_HttpBasicAuth) ProtoReflect added in v0.0.2 

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

func (*Options_HttpBasicAuth) Reset added in v0.0.2 

func (x *Options_HttpBasicAuth) Reset()

func (*Options_HttpBasicAuth) String added in v0.0.2 

func (x *Options_HttpBasicAuth) String() string

type Options_TLSConfig added in v0.0.2 

type Options_TLSConfig struct {
	Address            *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	CaFile             *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=ca_file,json=caFile,proto3" json:"ca_file,omitempty"`
	CaPath             *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=ca_path,json=caPath,proto3" json:"ca_path,omitempty"`
	CaPem              []byte                  `protobuf:"bytes,4,opt,name=ca_pem,json=caPem,proto3" json:"ca_pem,omitempty"`
	CertFile           *wrapperspb.StringValue `protobuf:"bytes,5,opt,name=cert_file,json=certFile,proto3" json:"cert_file,omitempty"`
	CertPem            []byte                  `protobuf:"bytes,6,opt,name=cert_pem,json=certPem,proto3" json:"cert_pem,omitempty"`
	KeyFile            *wrapperspb.StringValue `protobuf:"bytes,7,opt,name=key_file,json=keyFile,proto3" json:"key_file,omitempty"`
	KeyPem             []byte                  `protobuf:"bytes,8,opt,name=key_pem,json=keyPem,proto3" json:"key_pem,omitempty"`
	InsecureSkipVerify *wrapperspb.BoolValue   `protobuf:"bytes,9,opt,name=insecure_skip_verify,json=insecureSkipVerify,proto3" json:"insecure_skip_verify,omitempty"`
	// contains filtered or unexported fields
}

func (*Options_TLSConfig) Descriptor deprecated added in v0.0.2 

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

Deprecated: Use Options_TLSConfig.ProtoReflect.Descriptor instead.

func (*Options_TLSConfig) GetAddress added in v0.0.2 

func (x *Options_TLSConfig) GetAddress() *wrapperspb.StringValue

func (*Options_TLSConfig) GetCaFile added in v0.0.2 

func (x *Options_TLSConfig) GetCaFile() *wrapperspb.StringValue

func (*Options_TLSConfig) GetCaPath added in v0.0.2 

func (x *Options_TLSConfig) GetCaPath() *wrapperspb.StringValue

func (*Options_TLSConfig) GetCaPem added in v0.0.2 

func (x *Options_TLSConfig) GetCaPem() []byte

func (*Options_TLSConfig) GetCertFile added in v0.0.2 

func (x *Options_TLSConfig) GetCertFile() *wrapperspb.StringValue

func (*Options_TLSConfig) GetCertPem added in v0.0.2 

func (x *Options_TLSConfig) GetCertPem() []byte

func (*Options_TLSConfig) GetInsecureSkipVerify added in v0.0.2 

func (x *Options_TLSConfig) GetInsecureSkipVerify() *wrapperspb.BoolValue

func (*Options_TLSConfig) GetKeyFile added in v0.0.2 

func (x *Options_TLSConfig) GetKeyFile() *wrapperspb.StringValue

func (*Options_TLSConfig) GetKeyPem added in v0.0.2 

func (x *Options_TLSConfig) GetKeyPem() []byte

func (*Options_TLSConfig) ProtoMessage added in v0.0.2 

func (*Options_TLSConfig) ProtoMessage()

func (*Options_TLSConfig) ProtoReflect added in v0.0.2 

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

func (*Options_TLSConfig) Reset added in v0.0.2 

func (x *Options_TLSConfig) Reset()

func (*Options_TLSConfig) String added in v0.0.2 

func (x *Options_TLSConfig) 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.