Documentation ¶
Index ¶
- Variables
- type CollectorConfig
- func (*CollectorConfig) Descriptor() ([]byte, []int)deprecated
- func (x *CollectorConfig) GetDatabaseJwtSecret() string
- func (x *CollectorConfig) GetDatabaseTls() bool
- func (*CollectorConfig) ProtoMessage()
- func (x *CollectorConfig) ProtoReflect() protoreflect.Message
- func (x *CollectorConfig) Reset()
- func (x *CollectorConfig) String() string
- type CollectorServer
- func (*CollectorServer) Descriptor() ([]byte, []int)deprecated
- func (x *CollectorServer) GetConfig() *CollectorConfig
- func (x *CollectorServer) GetGrpcServer() *GrpcServer
- func (x *CollectorServer) GetKafka() *KafkaConfig
- func (x *CollectorServer) GetRegistry() *Registry
- func (x *CollectorServer) GetTcpServer() *TcpServer
- func (*CollectorServer) ProtoMessage()
- func (x *CollectorServer) ProtoReflect() protoreflect.Message
- func (x *CollectorServer) Reset()
- func (x *CollectorServer) String() string
- type DatabaseConfig
- func (*DatabaseConfig) Descriptor() ([]byte, []int)deprecated
- func (x *DatabaseConfig) GetAutoMigrate() bool
- func (x *DatabaseConfig) GetHost() string
- func (x *DatabaseConfig) GetName() string
- func (x *DatabaseConfig) GetPassword() string
- func (x *DatabaseConfig) GetPort() uint32
- func (x *DatabaseConfig) GetSslMode() string
- func (x *DatabaseConfig) GetType() DatabaseType
- func (x *DatabaseConfig) GetUser() string
- func (*DatabaseConfig) ProtoMessage()
- func (x *DatabaseConfig) ProtoReflect() protoreflect.Message
- func (x *DatabaseConfig) Reset()
- func (x *DatabaseConfig) String() string
- type DatabaseServer
- func (*DatabaseServer) Descriptor() ([]byte, []int)deprecated
- func (x *DatabaseServer) GetConfig() *DatabaseConfig
- func (x *DatabaseServer) GetKafka() *KafkaConfig
- func (x *DatabaseServer) GetRegistry() *Registry
- func (x *DatabaseServer) GetServer() *GrpcServer
- func (*DatabaseServer) ProtoMessage()
- func (x *DatabaseServer) ProtoReflect() protoreflect.Message
- func (x *DatabaseServer) Reset()
- func (x *DatabaseServer) String() string
- type DatabaseType
- func (DatabaseType) Descriptor() protoreflect.EnumDescriptor
- func (x DatabaseType) Enum() *DatabaseType
- func (DatabaseType) EnumDescriptor() ([]byte, []int)deprecated
- func (x DatabaseType) Number() protoreflect.EnumNumber
- func (x DatabaseType) String() string
- func (DatabaseType) Type() protoreflect.EnumType
- type GatewayConfig
- type GatewayServer
- func (*GatewayServer) Descriptor() ([]byte, []int)deprecated
- func (x *GatewayServer) GetConfig() *GatewayConfig
- func (x *GatewayServer) GetRegistry() *Registry
- func (x *GatewayServer) GetServer() *TcpServer
- func (*GatewayServer) ProtoMessage()
- func (x *GatewayServer) ProtoReflect() protoreflect.Message
- func (x *GatewayServer) Reset()
- func (x *GatewayServer) String() string
- type GrpcServer
- func (*GrpcServer) Descriptor() ([]byte, []int)deprecated
- func (x *GrpcServer) GetAddr() string
- func (x *GrpcServer) GetCustomEndpoint() string
- func (x *GrpcServer) GetJwtSecret() string
- func (x *GrpcServer) GetTimeout() *durationpb.Duration
- func (x *GrpcServer) GetTls() *GrpcServer_TLS
- func (*GrpcServer) ProtoMessage()
- func (x *GrpcServer) ProtoReflect() protoreflect.Message
- func (x *GrpcServer) Reset()
- func (x *GrpcServer) String() string
- type GrpcServer_TLS
- func (*GrpcServer_TLS) Descriptor() ([]byte, []int)deprecated
- func (x *GrpcServer_TLS) GetCaFile() string
- func (x *GrpcServer_TLS) GetCertFile() string
- func (x *GrpcServer_TLS) GetKeyFile() string
- func (*GrpcServer_TLS) ProtoMessage()
- func (x *GrpcServer_TLS) ProtoReflect() protoreflect.Message
- func (x *GrpcServer_TLS) Reset()
- func (x *GrpcServer_TLS) String() string
- type KafkaConfig
- func (*KafkaConfig) Descriptor() ([]byte, []int)deprecated
- func (x *KafkaConfig) GetBrokers() string
- func (x *KafkaConfig) GetPassword() string
- func (x *KafkaConfig) GetUser() string
- func (*KafkaConfig) ProtoMessage()
- func (x *KafkaConfig) ProtoReflect() protoreflect.Message
- func (x *KafkaConfig) Reset()
- func (x *KafkaConfig) String() string
- type Registry
- type Registry_Consul
- func (*Registry_Consul) Descriptor() ([]byte, []int)deprecated
- func (x *Registry_Consul) GetAddr() string
- func (x *Registry_Consul) GetPrefix() string
- func (x *Registry_Consul) GetScheme() string
- func (x *Registry_Consul) GetTimeout() *durationpb.Duration
- func (*Registry_Consul) ProtoMessage()
- func (x *Registry_Consul) ProtoReflect() protoreflect.Message
- func (x *Registry_Consul) Reset()
- func (x *Registry_Consul) String() string
- type Registry_Etcd
- func (*Registry_Etcd) Descriptor() ([]byte, []int)deprecated
- func (x *Registry_Etcd) GetEndpoint() string
- func (x *Registry_Etcd) GetPassword() string
- func (x *Registry_Etcd) GetTimeout() *durationpb.Duration
- func (x *Registry_Etcd) GetUsername() string
- func (*Registry_Etcd) ProtoMessage()
- func (x *Registry_Etcd) ProtoReflect() protoreflect.Message
- func (x *Registry_Etcd) Reset()
- func (x *Registry_Etcd) String() string
- type TcpServer
- func (*TcpServer) Descriptor() ([]byte, []int)deprecated
- func (x *TcpServer) GetAddr() string
- func (x *TcpServer) GetCustomEndpoint() string
- func (x *TcpServer) GetTimeout() *durationpb.Duration
- func (x *TcpServer) GetTls() *TcpServer_TLS
- func (*TcpServer) ProtoMessage()
- func (x *TcpServer) ProtoReflect() protoreflect.Message
- func (x *TcpServer) Reset()
- func (x *TcpServer) String() string
- type TcpServer_TLS
- func (*TcpServer_TLS) Descriptor() ([]byte, []int)deprecated
- func (x *TcpServer_TLS) GetCaFile() string
- func (x *TcpServer_TLS) GetCertFile() string
- func (x *TcpServer_TLS) GetKeyFile() string
- func (*TcpServer_TLS) ProtoMessage()
- func (x *TcpServer_TLS) ProtoReflect() protoreflect.Message
- func (x *TcpServer_TLS) Reset()
- func (x *TcpServer_TLS) String() string
- type WebServer
- func (*WebServer) Descriptor() ([]byte, []int)deprecated
- func (x *WebServer) GetAddr() string
- func (x *WebServer) GetCustomEndpoint() string
- func (x *WebServer) GetTls() *WebServer_TLS
- func (*WebServer) ProtoMessage()
- func (x *WebServer) ProtoReflect() protoreflect.Message
- func (x *WebServer) Reset()
- func (x *WebServer) String() string
- type WebServer_TLS
- func (*WebServer_TLS) Descriptor() ([]byte, []int)deprecated
- func (x *WebServer_TLS) GetCaFile() string
- func (x *WebServer_TLS) GetCertFile() string
- func (x *WebServer_TLS) GetKeyFile() string
- func (*WebServer_TLS) ProtoMessage()
- func (x *WebServer_TLS) ProtoReflect() protoreflect.Message
- func (x *WebServer_TLS) Reset()
- func (x *WebServer_TLS) String() string
Constants ¶
This section is empty.
Variables ¶
var ( DatabaseType_name = map[int32]string{ 0: "SQLITE", 1: "MYSQL", 2: "POSTGRESQL", } DatabaseType_value = map[string]int32{ "SQLITE": 0, "MYSQL": 1, "POSTGRESQL": 2, } )
Enum value maps for DatabaseType.
var File_conf_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
type CollectorConfig ¶
type CollectorConfig struct { DatabaseTls bool `protobuf:"varint,1,opt,name=database_tls,json=databaseTls,proto3" json:"database_tls,omitempty" env:"COLLECTOR_DATABASE_TLS"` // @gotags: env:"COLLECTOR_DATABASE_TLS" DatabaseJwtSecret string `` // @gotags: env:"COLLECTOR_DATABASE_JWT_SECRET" /* 150-byte string literal not displayed */ // contains filtered or unexported fields }
func (*CollectorConfig) Descriptor
deprecated
func (*CollectorConfig) Descriptor() ([]byte, []int)
Deprecated: Use CollectorConfig.ProtoReflect.Descriptor instead.
func (*CollectorConfig) GetDatabaseJwtSecret ¶
func (x *CollectorConfig) GetDatabaseJwtSecret() string
func (*CollectorConfig) GetDatabaseTls ¶
func (x *CollectorConfig) GetDatabaseTls() bool
func (*CollectorConfig) ProtoMessage ¶
func (*CollectorConfig) ProtoMessage()
func (*CollectorConfig) ProtoReflect ¶
func (x *CollectorConfig) ProtoReflect() protoreflect.Message
func (*CollectorConfig) Reset ¶
func (x *CollectorConfig) Reset()
func (*CollectorConfig) String ¶
func (x *CollectorConfig) String() string
type CollectorServer ¶
type CollectorServer struct { TcpServer *TcpServer `protobuf:"bytes,1,opt,name=tcp_server,json=tcpServer,proto3" json:"tcp_server,omitempty"` GrpcServer *GrpcServer `protobuf:"bytes,2,opt,name=grpc_server,json=grpcServer,proto3" json:"grpc_server,omitempty"` Registry *Registry `protobuf:"bytes,3,opt,name=registry,proto3" json:"registry,omitempty"` Config *CollectorConfig `protobuf:"bytes,4,opt,name=config,proto3" json:"config,omitempty"` Kafka *KafkaConfig `protobuf:"bytes,5,opt,name=kafka,proto3" json:"kafka,omitempty"` // contains filtered or unexported fields }
func (*CollectorServer) Descriptor
deprecated
func (*CollectorServer) Descriptor() ([]byte, []int)
Deprecated: Use CollectorServer.ProtoReflect.Descriptor instead.
func (*CollectorServer) GetConfig ¶
func (x *CollectorServer) GetConfig() *CollectorConfig
func (*CollectorServer) GetGrpcServer ¶
func (x *CollectorServer) GetGrpcServer() *GrpcServer
func (*CollectorServer) GetKafka ¶ added in v0.1.1
func (x *CollectorServer) GetKafka() *KafkaConfig
func (*CollectorServer) GetRegistry ¶
func (x *CollectorServer) GetRegistry() *Registry
func (*CollectorServer) GetTcpServer ¶
func (x *CollectorServer) GetTcpServer() *TcpServer
func (*CollectorServer) ProtoMessage ¶
func (*CollectorServer) ProtoMessage()
func (*CollectorServer) ProtoReflect ¶
func (x *CollectorServer) ProtoReflect() protoreflect.Message
func (*CollectorServer) Reset ¶
func (x *CollectorServer) Reset()
func (*CollectorServer) String ¶
func (x *CollectorServer) String() string
type DatabaseConfig ¶
type DatabaseConfig struct { Type DatabaseType `protobuf:"varint,1,opt,name=type,proto3,enum=kratos.api.DatabaseType" json:"type,omitempty" env:"DATABASE_TYPE"` // @gotags: env:"DATABASE_TYPE" Host string `protobuf:"bytes,2,opt,name=host,proto3" json:"host,omitempty" env:"DATABASE_HOST"` // @gotags: env:"DATABASE_HOST" Port uint32 `protobuf:"varint,3,opt,name=port,proto3" json:"port,omitempty" env:"DATABASE_PORT"` // @gotags: env:"DATABASE_PORT" User string `protobuf:"bytes,4,opt,name=user,proto3" json:"user,omitempty" env:"DATABASE_USER"` // @gotags: env:"DATABASE_USER" Password string `protobuf:"bytes,5,opt,name=password,proto3" json:"password,omitempty" env:"DATABASE_PASSWORD"` // @gotags: env:"DATABASE_PASSWORD" Name string `protobuf:"bytes,6,opt,name=name,proto3" json:"name,omitempty" env:"DATABASE_NAME"` // @gotags: env:"DATABASE_NAME" SslMode string `protobuf:"bytes,7,opt,name=ssl_mode,json=sslMode,proto3" json:"ssl_mode,omitempty" env:"DATABASE_SSLMODE"` // @gotags: env:"DATABASE_SSLMODE" AutoMigrate bool `protobuf:"varint,8,opt,name=auto_migrate,json=autoMigrate,proto3" json:"auto_migrate,omitempty" env:"DATABASE_AUTOMIGRATE"` // @gotags: env:"DATABASE_AUTOMIGRATE" // contains filtered or unexported fields }
func (*DatabaseConfig) Descriptor
deprecated
func (*DatabaseConfig) Descriptor() ([]byte, []int)
Deprecated: Use DatabaseConfig.ProtoReflect.Descriptor instead.
func (*DatabaseConfig) GetAutoMigrate ¶
func (x *DatabaseConfig) GetAutoMigrate() bool
func (*DatabaseConfig) GetHost ¶
func (x *DatabaseConfig) GetHost() string
func (*DatabaseConfig) GetName ¶
func (x *DatabaseConfig) GetName() string
func (*DatabaseConfig) GetPassword ¶
func (x *DatabaseConfig) GetPassword() string
func (*DatabaseConfig) GetPort ¶
func (x *DatabaseConfig) GetPort() uint32
func (*DatabaseConfig) GetSslMode ¶
func (x *DatabaseConfig) GetSslMode() string
func (*DatabaseConfig) GetType ¶
func (x *DatabaseConfig) GetType() DatabaseType
func (*DatabaseConfig) GetUser ¶
func (x *DatabaseConfig) GetUser() string
func (*DatabaseConfig) ProtoMessage ¶
func (*DatabaseConfig) ProtoMessage()
func (*DatabaseConfig) ProtoReflect ¶
func (x *DatabaseConfig) ProtoReflect() protoreflect.Message
func (*DatabaseConfig) Reset ¶
func (x *DatabaseConfig) Reset()
func (*DatabaseConfig) String ¶
func (x *DatabaseConfig) String() string
type DatabaseServer ¶
type DatabaseServer struct { Server *GrpcServer `protobuf:"bytes,1,opt,name=server,proto3" json:"server,omitempty"` Registry *Registry `protobuf:"bytes,2,opt,name=registry,proto3" json:"registry,omitempty"` Config *DatabaseConfig `protobuf:"bytes,3,opt,name=config,proto3" json:"config,omitempty"` Kafka *KafkaConfig `protobuf:"bytes,4,opt,name=kafka,proto3" json:"kafka,omitempty"` // contains filtered or unexported fields }
func (*DatabaseServer) Descriptor
deprecated
func (*DatabaseServer) Descriptor() ([]byte, []int)
Deprecated: Use DatabaseServer.ProtoReflect.Descriptor instead.
func (*DatabaseServer) GetConfig ¶
func (x *DatabaseServer) GetConfig() *DatabaseConfig
func (*DatabaseServer) GetKafka ¶ added in v0.1.1
func (x *DatabaseServer) GetKafka() *KafkaConfig
func (*DatabaseServer) GetRegistry ¶
func (x *DatabaseServer) GetRegistry() *Registry
func (*DatabaseServer) GetServer ¶
func (x *DatabaseServer) GetServer() *GrpcServer
func (*DatabaseServer) ProtoMessage ¶
func (*DatabaseServer) ProtoMessage()
func (*DatabaseServer) ProtoReflect ¶
func (x *DatabaseServer) ProtoReflect() protoreflect.Message
func (*DatabaseServer) Reset ¶
func (x *DatabaseServer) Reset()
func (*DatabaseServer) String ¶
func (x *DatabaseServer) String() string
type DatabaseType ¶
type DatabaseType int32
const ( DatabaseType_SQLITE DatabaseType = 0 DatabaseType_MYSQL DatabaseType = 1 DatabaseType_POSTGRESQL DatabaseType = 2 )
func (DatabaseType) Descriptor ¶
func (DatabaseType) Descriptor() protoreflect.EnumDescriptor
func (DatabaseType) Enum ¶
func (x DatabaseType) Enum() *DatabaseType
func (DatabaseType) EnumDescriptor
deprecated
func (DatabaseType) EnumDescriptor() ([]byte, []int)
Deprecated: Use DatabaseType.Descriptor instead.
func (DatabaseType) Number ¶
func (x DatabaseType) Number() protoreflect.EnumNumber
func (DatabaseType) String ¶
func (x DatabaseType) String() string
func (DatabaseType) Type ¶
func (DatabaseType) Type() protoreflect.EnumType
type GatewayConfig ¶
type GatewayConfig struct {
// contains filtered or unexported fields
}
func (*GatewayConfig) Descriptor
deprecated
func (*GatewayConfig) Descriptor() ([]byte, []int)
Deprecated: Use GatewayConfig.ProtoReflect.Descriptor instead.
func (*GatewayConfig) ProtoMessage ¶
func (*GatewayConfig) ProtoMessage()
func (*GatewayConfig) ProtoReflect ¶
func (x *GatewayConfig) ProtoReflect() protoreflect.Message
func (*GatewayConfig) Reset ¶
func (x *GatewayConfig) Reset()
func (*GatewayConfig) String ¶
func (x *GatewayConfig) String() string
type GatewayServer ¶
type GatewayServer struct { Server *TcpServer `protobuf:"bytes,1,opt,name=server,proto3" json:"server,omitempty"` Registry *Registry `protobuf:"bytes,2,opt,name=registry,proto3" json:"registry,omitempty"` Config *GatewayConfig `protobuf:"bytes,3,opt,name=config,proto3" json:"config,omitempty"` // contains filtered or unexported fields }
func (*GatewayServer) Descriptor
deprecated
func (*GatewayServer) Descriptor() ([]byte, []int)
Deprecated: Use GatewayServer.ProtoReflect.Descriptor instead.
func (*GatewayServer) GetConfig ¶
func (x *GatewayServer) GetConfig() *GatewayConfig
func (*GatewayServer) GetRegistry ¶
func (x *GatewayServer) GetRegistry() *Registry
func (*GatewayServer) GetServer ¶
func (x *GatewayServer) GetServer() *TcpServer
func (*GatewayServer) ProtoMessage ¶
func (*GatewayServer) ProtoMessage()
func (*GatewayServer) ProtoReflect ¶
func (x *GatewayServer) ProtoReflect() protoreflect.Message
func (*GatewayServer) Reset ¶
func (x *GatewayServer) Reset()
func (*GatewayServer) String ¶
func (x *GatewayServer) String() string
type GrpcServer ¶
type GrpcServer struct { Addr string `protobuf:"bytes,1,opt,name=addr,proto3" json:"addr,omitempty" env:"GRPC_ADDR"` // @gotags: env:"GRPC_ADDR" Tls *GrpcServer_TLS `protobuf:"bytes,2,opt,name=tls,proto3" json:"tls,omitempty"` CustomEndpoint string `` // @gotags: env:"GRPC_CUSTOM_ENDPOINT" /* 130-byte string literal not displayed */ Timeout *durationpb.Duration `protobuf:"bytes,4,opt,name=timeout,proto3" json:"timeout,omitempty" env:"GRPC_SERVER_TIMEOUT"` // @gotags: env:"GRPC_SERVER_TIMEOUT" JwtSecret string `protobuf:"bytes,5,opt,name=jwt_secret,json=jwtSecret,proto3" json:"jwt_secret,omitempty" env:"GRPC_SERVER_JWT_SECRET"` // @gotags: env:"GRPC_SERVER_JWT_SECRET" // contains filtered or unexported fields }
func DefaultGrpcServer ¶
func DefaultGrpcServer() *GrpcServer
func (*GrpcServer) Descriptor
deprecated
func (*GrpcServer) Descriptor() ([]byte, []int)
Deprecated: Use GrpcServer.ProtoReflect.Descriptor instead.
func (*GrpcServer) GetAddr ¶
func (x *GrpcServer) GetAddr() string
func (*GrpcServer) GetCustomEndpoint ¶
func (x *GrpcServer) GetCustomEndpoint() string
func (*GrpcServer) GetJwtSecret ¶
func (x *GrpcServer) GetJwtSecret() string
func (*GrpcServer) GetTimeout ¶
func (x *GrpcServer) GetTimeout() *durationpb.Duration
func (*GrpcServer) GetTls ¶
func (x *GrpcServer) GetTls() *GrpcServer_TLS
func (*GrpcServer) ProtoMessage ¶
func (*GrpcServer) ProtoMessage()
func (*GrpcServer) ProtoReflect ¶
func (x *GrpcServer) ProtoReflect() protoreflect.Message
func (*GrpcServer) Reset ¶
func (x *GrpcServer) Reset()
func (*GrpcServer) String ¶
func (x *GrpcServer) String() string
type GrpcServer_TLS ¶
type GrpcServer_TLS struct { CertFile string `protobuf:"bytes,1,opt,name=cert_file,json=certFile,proto3" json:"cert_file,omitempty" env:"GRPC_CERT_FILE"` // @gotags: env:"GRPC_CERT_FILE" KeyFile string `protobuf:"bytes,2,opt,name=key_file,json=keyFile,proto3" json:"key_file,omitempty" env:"GRPC_KEY_FILE"` // @gotags: env:"GRPC_KEY_FILE" CaFile string `protobuf:"bytes,3,opt,name=ca_file,json=caFile,proto3" json:"ca_file,omitempty" env:"GRPC_CA_FILE"` // @gotags: env:"GRPC_CA_FILE" // contains filtered or unexported fields }
func (*GrpcServer_TLS) Descriptor
deprecated
func (*GrpcServer_TLS) Descriptor() ([]byte, []int)
Deprecated: Use GrpcServer_TLS.ProtoReflect.Descriptor instead.
func (*GrpcServer_TLS) GetCaFile ¶
func (x *GrpcServer_TLS) GetCaFile() string
func (*GrpcServer_TLS) GetCertFile ¶
func (x *GrpcServer_TLS) GetCertFile() string
func (*GrpcServer_TLS) GetKeyFile ¶
func (x *GrpcServer_TLS) GetKeyFile() string
func (*GrpcServer_TLS) ProtoMessage ¶
func (*GrpcServer_TLS) ProtoMessage()
func (*GrpcServer_TLS) ProtoReflect ¶
func (x *GrpcServer_TLS) ProtoReflect() protoreflect.Message
func (*GrpcServer_TLS) Reset ¶
func (x *GrpcServer_TLS) Reset()
func (*GrpcServer_TLS) String ¶
func (x *GrpcServer_TLS) String() string
type KafkaConfig ¶ added in v0.1.1
type KafkaConfig struct { Brokers string `protobuf:"bytes,1,opt,name=brokers,proto3" json:"brokers,omitempty" env:"KAFKA_BROKERS"` // @gotags: env:"KAFKA_BROKERS" User string `protobuf:"bytes,2,opt,name=user,proto3" json:"user,omitempty" env:"KAFKA_USER"` // @gotags: env:"KAFKA_USER" Password string `protobuf:"bytes,3,opt,name=password,proto3" json:"password,omitempty" env:"KAFKA_PASSWORD"` // @gotags: env:"KAFKA_PASSWORD" // contains filtered or unexported fields }
func DefaultKafka ¶ added in v0.1.1
func DefaultKafka() *KafkaConfig
func (*KafkaConfig) Descriptor
deprecated
added in
v0.1.1
func (*KafkaConfig) Descriptor() ([]byte, []int)
Deprecated: Use KafkaConfig.ProtoReflect.Descriptor instead.
func (*KafkaConfig) GetBrokers ¶ added in v0.1.1
func (x *KafkaConfig) GetBrokers() string
func (*KafkaConfig) GetPassword ¶ added in v0.1.1
func (x *KafkaConfig) GetPassword() string
func (*KafkaConfig) GetUser ¶ added in v0.1.1
func (x *KafkaConfig) GetUser() string
func (*KafkaConfig) ProtoMessage ¶ added in v0.1.1
func (*KafkaConfig) ProtoMessage()
func (*KafkaConfig) ProtoReflect ¶ added in v0.1.1
func (x *KafkaConfig) ProtoReflect() protoreflect.Message
func (*KafkaConfig) Reset ¶ added in v0.1.1
func (x *KafkaConfig) Reset()
func (*KafkaConfig) String ¶ added in v0.1.1
func (x *KafkaConfig) String() string
type Registry ¶
type Registry struct { Consul *Registry_Consul `protobuf:"bytes,1,opt,name=consul,proto3" json:"consul,omitempty"` Etcd *Registry_Etcd `protobuf:"bytes,2,opt,name=etcd,proto3" json:"etcd,omitempty"` // contains filtered or unexported fields }
func DefaultRegistry ¶
func DefaultRegistry() *Registry
func (*Registry) Descriptor
deprecated
func (*Registry) GetConsul ¶
func (x *Registry) GetConsul() *Registry_Consul
func (*Registry) GetEtcd ¶
func (x *Registry) GetEtcd() *Registry_Etcd
func (*Registry) ProtoMessage ¶
func (*Registry) ProtoMessage()
func (*Registry) ProtoReflect ¶
func (x *Registry) ProtoReflect() protoreflect.Message
type Registry_Consul ¶
type Registry_Consul struct { Scheme string `protobuf:"bytes,1,opt,name=scheme,proto3" json:"scheme,omitempty" env:"CONSUL_SCHEME"` // @gotags: env:"CONSUL_SCHEME" Addr string `protobuf:"bytes,2,opt,name=addr,proto3" json:"addr,omitempty" env:"CONSUL_ADDR"` // @gotags: env:"CONSUL_ADDR" Prefix string `protobuf:"bytes,3,opt,name=prefix,proto3" json:"prefix,omitempty" env:"CONSUL_PREFIX"` // @gotags: env:"CONSUL_PREFIX" Timeout *durationpb.Duration `protobuf:"bytes,4,opt,name=timeout,proto3" json:"timeout,omitempty" env:"CONSUL_TIMEOUT"` // @gotags: env:"CONSUL_TIMEOUT" // contains filtered or unexported fields }
func (*Registry_Consul) Descriptor
deprecated
func (*Registry_Consul) Descriptor() ([]byte, []int)
Deprecated: Use Registry_Consul.ProtoReflect.Descriptor instead.
func (*Registry_Consul) GetAddr ¶
func (x *Registry_Consul) GetAddr() string
func (*Registry_Consul) GetPrefix ¶
func (x *Registry_Consul) GetPrefix() string
func (*Registry_Consul) GetScheme ¶
func (x *Registry_Consul) GetScheme() string
func (*Registry_Consul) GetTimeout ¶
func (x *Registry_Consul) GetTimeout() *durationpb.Duration
func (*Registry_Consul) ProtoMessage ¶
func (*Registry_Consul) ProtoMessage()
func (*Registry_Consul) ProtoReflect ¶
func (x *Registry_Consul) ProtoReflect() protoreflect.Message
func (*Registry_Consul) Reset ¶
func (x *Registry_Consul) Reset()
func (*Registry_Consul) String ¶
func (x *Registry_Consul) String() string
type Registry_Etcd ¶
type Registry_Etcd struct { Endpoint string `protobuf:"bytes,1,opt,name=endpoint,proto3" json:"endpoint,omitempty" env:"ETCD_ENDPOINT"` // @gotags: env:"ETCD_ENDPOINT" Username string `protobuf:"bytes,2,opt,name=username,proto3" json:"username,omitempty" env:"ETCD_USERNAME"` // @gotags: env:"ETCD_USERNAME" Password string `protobuf:"bytes,3,opt,name=password,proto3" json:"password,omitempty" env:"ETCD_PASSWORD"` // @gotags: env:"ETCD_PASSWORD" Timeout *durationpb.Duration `protobuf:"bytes,4,opt,name=timeout,proto3" json:"timeout,omitempty" env:"ETCD_TIMEOUT"` // @gotags: env:"ETCD_TIMEOUT" // contains filtered or unexported fields }
func (*Registry_Etcd) Descriptor
deprecated
func (*Registry_Etcd) Descriptor() ([]byte, []int)
Deprecated: Use Registry_Etcd.ProtoReflect.Descriptor instead.
func (*Registry_Etcd) GetEndpoint ¶
func (x *Registry_Etcd) GetEndpoint() string
func (*Registry_Etcd) GetPassword ¶
func (x *Registry_Etcd) GetPassword() string
func (*Registry_Etcd) GetTimeout ¶
func (x *Registry_Etcd) GetTimeout() *durationpb.Duration
func (*Registry_Etcd) GetUsername ¶
func (x *Registry_Etcd) GetUsername() string
func (*Registry_Etcd) ProtoMessage ¶
func (*Registry_Etcd) ProtoMessage()
func (*Registry_Etcd) ProtoReflect ¶
func (x *Registry_Etcd) ProtoReflect() protoreflect.Message
func (*Registry_Etcd) Reset ¶
func (x *Registry_Etcd) Reset()
func (*Registry_Etcd) String ¶
func (x *Registry_Etcd) String() string
type TcpServer ¶
type TcpServer struct { Addr string `protobuf:"bytes,1,opt,name=addr,proto3" json:"addr,omitempty" env:"TCP_ADDR"` // @gotags: env:"TCP_ADDR" Tls *TcpServer_TLS `protobuf:"bytes,2,opt,name=tls,proto3" json:"tls,omitempty"` CustomEndpoint string `` // @gotags: env:"TCP_CUSTOM_ENDPOINT" /* 129-byte string literal not displayed */ Timeout *durationpb.Duration `protobuf:"bytes,4,opt,name=timeout,proto3" json:"timeout,omitempty" env:"TCP_SERVER_TIMEOUT"` // @gotags: env:"TCP_SERVER_TIMEOUT" // contains filtered or unexported fields }
func DefaultTcpServer ¶
func DefaultTcpServer() *TcpServer
func (*TcpServer) Descriptor
deprecated
func (*TcpServer) GetCustomEndpoint ¶
func (*TcpServer) GetTimeout ¶
func (x *TcpServer) GetTimeout() *durationpb.Duration
func (*TcpServer) GetTls ¶
func (x *TcpServer) GetTls() *TcpServer_TLS
func (*TcpServer) ProtoMessage ¶
func (*TcpServer) ProtoMessage()
func (*TcpServer) ProtoReflect ¶
func (x *TcpServer) ProtoReflect() protoreflect.Message
type TcpServer_TLS ¶
type TcpServer_TLS struct { CertFile string `protobuf:"bytes,1,opt,name=cert_file,json=certFile,proto3" json:"cert_file,omitempty" env:"TCP_CERT_FILE"` // @gotags: env:"TCP_CERT_FILE" KeyFile string `protobuf:"bytes,2,opt,name=key_file,json=keyFile,proto3" json:"key_file,omitempty" env:"TCP_KEY_FILE"` // @gotags: env:"TCP_KEY_FILE" CaFile string `protobuf:"bytes,3,opt,name=ca_file,json=caFile,proto3" json:"ca_file,omitempty" env:"TCP_CA_FILE"` // @gotags: env:"TCP_CA_FILE" // contains filtered or unexported fields }
func (*TcpServer_TLS) Descriptor
deprecated
func (*TcpServer_TLS) Descriptor() ([]byte, []int)
Deprecated: Use TcpServer_TLS.ProtoReflect.Descriptor instead.
func (*TcpServer_TLS) GetCaFile ¶
func (x *TcpServer_TLS) GetCaFile() string
func (*TcpServer_TLS) GetCertFile ¶
func (x *TcpServer_TLS) GetCertFile() string
func (*TcpServer_TLS) GetKeyFile ¶
func (x *TcpServer_TLS) GetKeyFile() string
func (*TcpServer_TLS) ProtoMessage ¶
func (*TcpServer_TLS) ProtoMessage()
func (*TcpServer_TLS) ProtoReflect ¶
func (x *TcpServer_TLS) ProtoReflect() protoreflect.Message
func (*TcpServer_TLS) Reset ¶
func (x *TcpServer_TLS) Reset()
func (*TcpServer_TLS) String ¶
func (x *TcpServer_TLS) String() string
type WebServer ¶
type WebServer struct { Addr string `protobuf:"bytes,1,opt,name=addr,proto3" json:"addr,omitempty" env:"WEB_ADDR"` // @gotags: env:"WEB_ADDR" Tls *WebServer_TLS `protobuf:"bytes,2,opt,name=tls,proto3" json:"tls,omitempty"` CustomEndpoint string `` // @gotags: env:"WEB_CUSTOM_ENDPOINT" /* 129-byte string literal not displayed */ // contains filtered or unexported fields }
func (*WebServer) Descriptor
deprecated
func (*WebServer) GetCustomEndpoint ¶
func (*WebServer) GetTls ¶
func (x *WebServer) GetTls() *WebServer_TLS
func (*WebServer) ProtoMessage ¶
func (*WebServer) ProtoMessage()
func (*WebServer) ProtoReflect ¶
func (x *WebServer) ProtoReflect() protoreflect.Message
type WebServer_TLS ¶
type WebServer_TLS struct { CertFile string `protobuf:"bytes,1,opt,name=cert_file,json=certFile,proto3" json:"cert_file,omitempty" env:"WEB_CERT_FILE"` // @gotags: env:"WEB_CERT_FILE" KeyFile string `protobuf:"bytes,2,opt,name=key_file,json=keyFile,proto3" json:"key_file,omitempty" env:"WEB_KEY_FILE"` // @gotags: env:"WEB_KEY_FILE" CaFile string `protobuf:"bytes,3,opt,name=ca_file,json=caFile,proto3" json:"ca_file,omitempty" env:"WEB_CA_FILE"` // @gotags: env:"WEB_CA_FILE" // contains filtered or unexported fields }
func (*WebServer_TLS) Descriptor
deprecated
func (*WebServer_TLS) Descriptor() ([]byte, []int)
Deprecated: Use WebServer_TLS.ProtoReflect.Descriptor instead.
func (*WebServer_TLS) GetCaFile ¶
func (x *WebServer_TLS) GetCaFile() string
func (*WebServer_TLS) GetCertFile ¶
func (x *WebServer_TLS) GetCertFile() string
func (*WebServer_TLS) GetKeyFile ¶
func (x *WebServer_TLS) GetKeyFile() string
func (*WebServer_TLS) ProtoMessage ¶
func (*WebServer_TLS) ProtoMessage()
func (*WebServer_TLS) ProtoReflect ¶
func (x *WebServer_TLS) ProtoReflect() protoreflect.Message
func (*WebServer_TLS) Reset ¶
func (x *WebServer_TLS) Reset()
func (*WebServer_TLS) String ¶
func (x *WebServer_TLS) String() string