Documentation ¶
Index ¶
- Variables
- type CaptchaConfig
- type CaptchaServer
- func (*CaptchaServer) Descriptor() ([]byte, []int)deprecated
- func (x *CaptchaServer) GetConfig() *CaptchaConfig
- func (x *CaptchaServer) GetKafka() *KafkaConfig
- func (x *CaptchaServer) GetRedis() *RedisConfig
- func (x *CaptchaServer) GetRegistry() *Registry
- func (x *CaptchaServer) GetServer() *GrpcServerConfig
- func (*CaptchaServer) ProtoMessage()
- func (x *CaptchaServer) ProtoReflect() protoreflect.Message
- func (x *CaptchaServer) Reset()
- func (x *CaptchaServer) String() string
- type CollectionConfig
- type CollectionServer
- func (*CollectionServer) Descriptor() ([]byte, []int)deprecated
- func (x *CollectionServer) GetConfig() *CollectionConfig
- func (x *CollectionServer) GetDatabase() *DatabaseServerConfig
- func (x *CollectionServer) GetKafka() *KafkaConfig
- func (x *CollectionServer) GetRedis() *RedisConfig
- func (x *CollectionServer) GetRegistry() *Registry
- func (x *CollectionServer) GetServer() *GrpcServerConfig
- func (*CollectionServer) ProtoMessage()
- func (x *CollectionServer) ProtoReflect() protoreflect.Message
- func (x *CollectionServer) Reset()
- func (x *CollectionServer) String() string
- type CollectorConfig
- type CollectorServer
- func (*CollectorServer) Descriptor() ([]byte, []int)deprecated
- func (x *CollectorServer) GetConfig() *CollectorConfig
- func (x *CollectorServer) GetKafka() *KafkaConfig
- func (x *CollectorServer) GetRedis() *RedisConfig
- func (x *CollectorServer) GetRegistry() *Registry
- func (x *CollectorServer) GetServer() *GrpcServerConfig
- func (*CollectorServer) ProtoMessage()
- func (x *CollectorServer) ProtoReflect() protoreflect.Message
- func (x *CollectorServer) Reset()
- func (x *CollectorServer) String() string
- type DatabaseServerConfig
- func (*DatabaseServerConfig) Descriptor() ([]byte, []int)deprecated
- func (x *DatabaseServerConfig) GetAutoMigrate() bool
- func (x *DatabaseServerConfig) GetHost() string
- func (x *DatabaseServerConfig) GetName() string
- func (x *DatabaseServerConfig) GetPassword() string
- func (x *DatabaseServerConfig) GetPort() uint32
- func (x *DatabaseServerConfig) GetSslMode() string
- func (x *DatabaseServerConfig) GetUser() string
- func (*DatabaseServerConfig) ProtoMessage()
- func (x *DatabaseServerConfig) ProtoReflect() protoreflect.Message
- func (x *DatabaseServerConfig) Reset()
- func (x *DatabaseServerConfig) String() string
- type DeviceConfig
- type DeviceServer
- func (*DeviceServer) Descriptor() ([]byte, []int)deprecated
- func (x *DeviceServer) GetConfig() *DeviceConfig
- func (x *DeviceServer) GetDatabase() *DatabaseServerConfig
- func (x *DeviceServer) GetRedis() *RedisConfig
- func (x *DeviceServer) GetRegistry() *Registry
- func (x *DeviceServer) GetServer() *GrpcServerConfig
- func (*DeviceServer) ProtoMessage()
- func (x *DeviceServer) ProtoReflect() protoreflect.Message
- func (x *DeviceServer) Reset()
- func (x *DeviceServer) String() string
- type EmailConfig
- type EmailServer
- func (*EmailServer) Descriptor() ([]byte, []int)deprecated
- func (x *EmailServer) GetConfig() *EmailConfig
- func (x *EmailServer) GetKafka() *KafkaConfig
- func (x *EmailServer) GetRegistry() *Registry
- func (x *EmailServer) GetServer() *GrpcServerConfig
- func (*EmailServer) ProtoMessage()
- func (x *EmailServer) ProtoReflect() protoreflect.Message
- func (x *EmailServer) Reset()
- func (x *EmailServer) String() string
- type EmqxConfig
- func (*EmqxConfig) Descriptor() ([]byte, []int)deprecated
- func (x *EmqxConfig) GetApi() string
- func (x *EmqxConfig) GetAppid() string
- func (x *EmqxConfig) GetAppsecret() string
- func (*EmqxConfig) ProtoMessage()
- func (x *EmqxConfig) ProtoReflect() protoreflect.Message
- func (x *EmqxConfig) Reset()
- func (x *EmqxConfig) String() string
- type GrpcServerConfig
- func (*GrpcServerConfig) Descriptor() ([]byte, []int)deprecated
- func (x *GrpcServerConfig) GetAddr() string
- func (x *GrpcServerConfig) GetCustomEndpoint() string
- func (x *GrpcServerConfig) GetJwtSecret() string
- func (x *GrpcServerConfig) GetTimeout() *durationpb.Duration
- func (x *GrpcServerConfig) GetTls() *GrpcServerConfig_TLS
- func (x *GrpcServerConfig) GetTracingEndpoint() string
- func (*GrpcServerConfig) ProtoMessage()
- func (x *GrpcServerConfig) ProtoReflect() protoreflect.Message
- func (x *GrpcServerConfig) Reset()
- func (x *GrpcServerConfig) String() string
- type GrpcServerConfig_TLS
- func (*GrpcServerConfig_TLS) Descriptor() ([]byte, []int)deprecated
- func (x *GrpcServerConfig_TLS) GetCaFile() string
- func (x *GrpcServerConfig_TLS) GetCertFile() string
- func (x *GrpcServerConfig_TLS) GetKeyFile() string
- func (*GrpcServerConfig_TLS) ProtoMessage()
- func (x *GrpcServerConfig_TLS) ProtoReflect() protoreflect.Message
- func (x *GrpcServerConfig_TLS) Reset()
- func (x *GrpcServerConfig_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 LogConfig
- type LogServer
- func (*LogServer) Descriptor() ([]byte, []int)deprecated
- func (x *LogServer) GetConfig() *LogConfig
- func (x *LogServer) GetDatabase() *DatabaseServerConfig
- func (x *LogServer) GetKafka() *KafkaConfig
- func (x *LogServer) GetRegistry() *Registry
- func (x *LogServer) GetServer() *GrpcServerConfig
- func (*LogServer) ProtoMessage()
- func (x *LogServer) ProtoReflect() protoreflect.Message
- func (x *LogServer) Reset()
- func (x *LogServer) String() string
- type MTQQConfig
- func (*MTQQConfig) Descriptor() ([]byte, []int)deprecated
- func (x *MTQQConfig) GetAddr() string
- func (x *MTQQConfig) GetClientId() string
- func (x *MTQQConfig) GetPassword() string
- func (*MTQQConfig) ProtoMessage()
- func (x *MTQQConfig) ProtoReflect() protoreflect.Message
- func (x *MTQQConfig) Reset()
- func (x *MTQQConfig) String() string
- type MessageConfig
- type MessageServer
- func (*MessageServer) Descriptor() ([]byte, []int)deprecated
- func (x *MessageServer) GetConfig() *MessageConfig
- func (x *MessageServer) GetDatabase() *DatabaseServerConfig
- func (x *MessageServer) GetKafka() *KafkaConfig
- func (x *MessageServer) GetRedis() *RedisConfig
- func (x *MessageServer) GetRegistry() *Registry
- func (x *MessageServer) GetServer() *GrpcServerConfig
- func (*MessageServer) ProtoMessage()
- func (x *MessageServer) ProtoReflect() protoreflect.Message
- func (x *MessageServer) Reset()
- func (x *MessageServer) String() string
- type NotifyConfig
- type NotifyServer
- func (*NotifyServer) Descriptor() ([]byte, []int)deprecated
- func (x *NotifyServer) GetConfig() *NotifyConfig
- func (x *NotifyServer) GetKafka() *KafkaConfig
- func (x *NotifyServer) GetRegistry() *Registry
- func (x *NotifyServer) GetServer() *GrpcServerConfig
- func (*NotifyServer) ProtoMessage()
- func (x *NotifyServer) ProtoReflect() protoreflect.Message
- func (x *NotifyServer) Reset()
- func (x *NotifyServer) String() string
- type RedisConfig
- func (*RedisConfig) Descriptor() ([]byte, []int)deprecated
- func (x *RedisConfig) GetAddr() string
- func (x *RedisConfig) GetDb() int32
- func (x *RedisConfig) GetPassword() string
- func (x *RedisConfig) GetUsername() string
- func (*RedisConfig) ProtoMessage()
- func (x *RedisConfig) ProtoReflect() protoreflect.Message
- func (x *RedisConfig) Reset()
- func (x *RedisConfig) String() string
- type Registry
- 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 SmtpConfig
- func (*SmtpConfig) Descriptor() ([]byte, []int)deprecated
- func (x *SmtpConfig) GetFrom() string
- func (x *SmtpConfig) GetHost() string
- func (x *SmtpConfig) GetPassword() string
- func (x *SmtpConfig) GetPort() uint32
- func (x *SmtpConfig) GetProtocol() string
- func (x *SmtpConfig) GetUsername() string
- func (*SmtpConfig) ProtoMessage()
- func (x *SmtpConfig) ProtoReflect() protoreflect.Message
- func (x *SmtpConfig) Reset()
- func (x *SmtpConfig) 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 (x *TcpServer) GetTracingEndpoint() string
- 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 UserConfig
- type UserServer
- func (*UserServer) Descriptor() ([]byte, []int)deprecated
- func (x *UserServer) GetConfig() *UserConfig
- func (x *UserServer) GetDatabase() *DatabaseServerConfig
- func (x *UserServer) GetRedis() *RedisConfig
- func (x *UserServer) GetRegistry() *Registry
- func (x *UserServer) GetServer() *GrpcServerConfig
- func (*UserServer) ProtoMessage()
- func (x *UserServer) ProtoReflect() protoreflect.Message
- func (x *UserServer) Reset()
- func (x *UserServer) String() string
- type WebConfig
- type WebConfig_JWT
- func (*WebConfig_JWT) Descriptor() ([]byte, []int)deprecated
- func (x *WebConfig_JWT) GetExpire() string
- func (x *WebConfig_JWT) GetSecret() string
- func (*WebConfig_JWT) ProtoMessage()
- func (x *WebConfig_JWT) ProtoReflect() protoreflect.Message
- func (x *WebConfig_JWT) Reset()
- func (x *WebConfig_JWT) String() string
- type WebServer
- func (*WebServer) Descriptor() ([]byte, []int)deprecated
- func (x *WebServer) GetConfig() *WebConfig
- func (x *WebServer) GetRedis() *RedisConfig
- func (x *WebServer) GetRegistry() *Registry
- func (x *WebServer) GetServer() *WebServerConfig
- func (*WebServer) ProtoMessage()
- func (x *WebServer) ProtoReflect() protoreflect.Message
- func (x *WebServer) Reset()
- func (x *WebServer) String() string
- type WebServerConfig
- func (*WebServerConfig) Descriptor() ([]byte, []int)deprecated
- func (x *WebServerConfig) GetAddr() string
- func (x *WebServerConfig) GetCustomEndpoint() string
- func (x *WebServerConfig) GetTls() *WebServerConfig_TLS
- func (x *WebServerConfig) GetTracingEndpoint() string
- func (*WebServerConfig) ProtoMessage()
- func (x *WebServerConfig) ProtoReflect() protoreflect.Message
- func (x *WebServerConfig) Reset()
- func (x *WebServerConfig) String() string
- type WebServerConfig_TLS
- func (*WebServerConfig_TLS) Descriptor() ([]byte, []int)deprecated
- func (x *WebServerConfig_TLS) GetCaFile() string
- func (x *WebServerConfig_TLS) GetCertFile() string
- func (x *WebServerConfig_TLS) GetKeyFile() string
- func (*WebServerConfig_TLS) ProtoMessage()
- func (x *WebServerConfig_TLS) ProtoReflect() protoreflect.Message
- func (x *WebServerConfig_TLS) Reset()
- func (x *WebServerConfig_TLS) String() string
Constants ¶
This section is empty.
Variables ¶
var File_conf_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
type CaptchaConfig ¶ added in v0.3.0
type CaptchaConfig struct {
// contains filtered or unexported fields
}
func (*CaptchaConfig) Descriptor
deprecated
added in
v0.3.0
func (*CaptchaConfig) Descriptor() ([]byte, []int)
Deprecated: Use CaptchaConfig.ProtoReflect.Descriptor instead.
func (*CaptchaConfig) ProtoMessage ¶ added in v0.3.0
func (*CaptchaConfig) ProtoMessage()
func (*CaptchaConfig) ProtoReflect ¶ added in v0.3.0
func (x *CaptchaConfig) ProtoReflect() protoreflect.Message
func (*CaptchaConfig) Reset ¶ added in v0.3.0
func (x *CaptchaConfig) Reset()
func (*CaptchaConfig) String ¶ added in v0.3.0
func (x *CaptchaConfig) String() string
type CaptchaServer ¶ added in v0.3.0
type CaptchaServer struct { Server *GrpcServerConfig `protobuf:"bytes,1,opt,name=server,proto3" json:"server,omitempty"` Registry *Registry `protobuf:"bytes,2,opt,name=registry,proto3" json:"registry,omitempty"` Config *CaptchaConfig `protobuf:"bytes,3,opt,name=config,proto3" json:"config,omitempty"` Kafka *KafkaConfig `protobuf:"bytes,4,opt,name=kafka,proto3" json:"kafka,omitempty"` Redis *RedisConfig `protobuf:"bytes,5,opt,name=redis,proto3" json:"redis,omitempty"` // contains filtered or unexported fields }
func (*CaptchaServer) Descriptor
deprecated
added in
v0.3.0
func (*CaptchaServer) Descriptor() ([]byte, []int)
Deprecated: Use CaptchaServer.ProtoReflect.Descriptor instead.
func (*CaptchaServer) GetConfig ¶ added in v0.3.0
func (x *CaptchaServer) GetConfig() *CaptchaConfig
func (*CaptchaServer) GetKafka ¶ added in v0.3.0
func (x *CaptchaServer) GetKafka() *KafkaConfig
func (*CaptchaServer) GetRedis ¶ added in v0.3.0
func (x *CaptchaServer) GetRedis() *RedisConfig
func (*CaptchaServer) GetRegistry ¶ added in v0.3.0
func (x *CaptchaServer) GetRegistry() *Registry
func (*CaptchaServer) GetServer ¶ added in v0.3.0
func (x *CaptchaServer) GetServer() *GrpcServerConfig
func (*CaptchaServer) ProtoMessage ¶ added in v0.3.0
func (*CaptchaServer) ProtoMessage()
func (*CaptchaServer) ProtoReflect ¶ added in v0.3.0
func (x *CaptchaServer) ProtoReflect() protoreflect.Message
func (*CaptchaServer) Reset ¶ added in v0.3.0
func (x *CaptchaServer) Reset()
func (*CaptchaServer) String ¶ added in v0.3.0
func (x *CaptchaServer) String() string
type CollectionConfig ¶ added in v0.2.0
type CollectionConfig struct {
// contains filtered or unexported fields
}
func (*CollectionConfig) Descriptor
deprecated
added in
v0.2.0
func (*CollectionConfig) Descriptor() ([]byte, []int)
Deprecated: Use CollectionConfig.ProtoReflect.Descriptor instead.
func (*CollectionConfig) ProtoMessage ¶ added in v0.2.0
func (*CollectionConfig) ProtoMessage()
func (*CollectionConfig) ProtoReflect ¶ added in v0.2.0
func (x *CollectionConfig) ProtoReflect() protoreflect.Message
func (*CollectionConfig) Reset ¶ added in v0.2.0
func (x *CollectionConfig) Reset()
func (*CollectionConfig) String ¶ added in v0.2.0
func (x *CollectionConfig) String() string
type CollectionServer ¶ added in v0.2.0
type CollectionServer struct { Server *GrpcServerConfig `protobuf:"bytes,1,opt,name=server,proto3" json:"server,omitempty"` Registry *Registry `protobuf:"bytes,2,opt,name=registry,proto3" json:"registry,omitempty"` Database *DatabaseServerConfig `protobuf:"bytes,3,opt,name=database,proto3" json:"database,omitempty"` Config *CollectionConfig `protobuf:"bytes,4,opt,name=config,proto3" json:"config,omitempty"` Kafka *KafkaConfig `protobuf:"bytes,5,opt,name=kafka,proto3" json:"kafka,omitempty"` Redis *RedisConfig `protobuf:"bytes,6,opt,name=redis,proto3" json:"redis,omitempty"` // contains filtered or unexported fields }
func (*CollectionServer) Descriptor
deprecated
added in
v0.2.0
func (*CollectionServer) Descriptor() ([]byte, []int)
Deprecated: Use CollectionServer.ProtoReflect.Descriptor instead.
func (*CollectionServer) GetConfig ¶ added in v0.2.0
func (x *CollectionServer) GetConfig() *CollectionConfig
func (*CollectionServer) GetDatabase ¶ added in v0.2.0
func (x *CollectionServer) GetDatabase() *DatabaseServerConfig
func (*CollectionServer) GetKafka ¶ added in v0.2.0
func (x *CollectionServer) GetKafka() *KafkaConfig
func (*CollectionServer) GetRedis ¶ added in v0.3.3
func (x *CollectionServer) GetRedis() *RedisConfig
func (*CollectionServer) GetRegistry ¶ added in v0.2.0
func (x *CollectionServer) GetRegistry() *Registry
func (*CollectionServer) GetServer ¶ added in v0.2.0
func (x *CollectionServer) GetServer() *GrpcServerConfig
func (*CollectionServer) ProtoMessage ¶ added in v0.2.0
func (*CollectionServer) ProtoMessage()
func (*CollectionServer) ProtoReflect ¶ added in v0.2.0
func (x *CollectionServer) ProtoReflect() protoreflect.Message
func (*CollectionServer) Reset ¶ added in v0.2.0
func (x *CollectionServer) Reset()
func (*CollectionServer) String ¶ added in v0.2.0
func (x *CollectionServer) String() string
type CollectorConfig ¶
type CollectorConfig struct { Mqtt *MTQQConfig `protobuf:"bytes,1,opt,name=mqtt,proto3" json:"mqtt,omitempty"` // contains filtered or unexported fields }
func (*CollectorConfig) Descriptor
deprecated
func (*CollectorConfig) Descriptor() ([]byte, []int)
Deprecated: Use CollectorConfig.ProtoReflect.Descriptor instead.
func (*CollectorConfig) GetMqtt ¶ added in v0.2.3
func (x *CollectorConfig) GetMqtt() *MTQQConfig
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 { Server *GrpcServerConfig `protobuf:"bytes,1,opt,name=server,proto3" json:"server,omitempty"` Registry *Registry `protobuf:"bytes,2,opt,name=registry,proto3" json:"registry,omitempty"` Config *CollectorConfig `protobuf:"bytes,3,opt,name=config,proto3" json:"config,omitempty"` Kafka *KafkaConfig `protobuf:"bytes,4,opt,name=kafka,proto3" json:"kafka,omitempty"` Redis *RedisConfig `protobuf:"bytes,5,opt,name=redis,proto3" json:"redis,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) GetKafka ¶ added in v0.1.1
func (x *CollectorServer) GetKafka() *KafkaConfig
func (*CollectorServer) GetRedis ¶ added in v0.3.2
func (x *CollectorServer) GetRedis() *RedisConfig
func (*CollectorServer) GetRegistry ¶
func (x *CollectorServer) GetRegistry() *Registry
func (*CollectorServer) GetServer ¶ added in v0.3.2
func (x *CollectorServer) GetServer() *GrpcServerConfig
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 DatabaseServerConfig ¶ added in v0.2.0
type DatabaseServerConfig struct { Host string `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty" env:"DATABASE_HOST"` // @gotags: env:"DATABASE_HOST" Port uint32 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty" env:"DATABASE_PORT"` // @gotags: env:"DATABASE_PORT" User string `protobuf:"bytes,3,opt,name=user,proto3" json:"user,omitempty" env:"DATABASE_USER"` // @gotags: env:"DATABASE_USER" Password string `protobuf:"bytes,4,opt,name=password,proto3" json:"password,omitempty" env:"DATABASE_PASSWORD"` // @gotags: env:"DATABASE_PASSWORD" Name string `protobuf:"bytes,5,opt,name=name,proto3" json:"name,omitempty" env:"DATABASE_NAME"` // @gotags: env:"DATABASE_NAME" SslMode string `protobuf:"bytes,6,opt,name=ssl_mode,json=sslMode,proto3" json:"ssl_mode,omitempty" env:"DATABASE_SSLMODE"` // @gotags: env:"DATABASE_SSLMODE" AutoMigrate bool `protobuf:"varint,7,opt,name=auto_migrate,json=autoMigrate,proto3" json:"auto_migrate,omitempty" env:"DATABASE_AUTOMIGRATE"` // @gotags: env:"DATABASE_AUTOMIGRATE" // contains filtered or unexported fields }
func (*DatabaseServerConfig) Descriptor
deprecated
added in
v0.2.0
func (*DatabaseServerConfig) Descriptor() ([]byte, []int)
Deprecated: Use DatabaseServerConfig.ProtoReflect.Descriptor instead.
func (*DatabaseServerConfig) GetAutoMigrate ¶ added in v0.2.0
func (x *DatabaseServerConfig) GetAutoMigrate() bool
func (*DatabaseServerConfig) GetHost ¶ added in v0.2.0
func (x *DatabaseServerConfig) GetHost() string
func (*DatabaseServerConfig) GetName ¶ added in v0.2.0
func (x *DatabaseServerConfig) GetName() string
func (*DatabaseServerConfig) GetPassword ¶ added in v0.2.0
func (x *DatabaseServerConfig) GetPassword() string
func (*DatabaseServerConfig) GetPort ¶ added in v0.2.0
func (x *DatabaseServerConfig) GetPort() uint32
func (*DatabaseServerConfig) GetSslMode ¶ added in v0.2.0
func (x *DatabaseServerConfig) GetSslMode() string
func (*DatabaseServerConfig) GetUser ¶ added in v0.2.0
func (x *DatabaseServerConfig) GetUser() string
func (*DatabaseServerConfig) ProtoMessage ¶ added in v0.2.0
func (*DatabaseServerConfig) ProtoMessage()
func (*DatabaseServerConfig) ProtoReflect ¶ added in v0.2.0
func (x *DatabaseServerConfig) ProtoReflect() protoreflect.Message
func (*DatabaseServerConfig) Reset ¶ added in v0.2.0
func (x *DatabaseServerConfig) Reset()
func (*DatabaseServerConfig) String ¶ added in v0.2.0
func (x *DatabaseServerConfig) String() string
type DeviceConfig ¶ added in v0.2.0
type DeviceConfig struct { Emqx *EmqxConfig `protobuf:"bytes,1,opt,name=emqx,proto3" json:"emqx,omitempty"` // contains filtered or unexported fields }
func (*DeviceConfig) Descriptor
deprecated
added in
v0.2.0
func (*DeviceConfig) Descriptor() ([]byte, []int)
Deprecated: Use DeviceConfig.ProtoReflect.Descriptor instead.
func (*DeviceConfig) GetEmqx ¶ added in v0.2.3
func (x *DeviceConfig) GetEmqx() *EmqxConfig
func (*DeviceConfig) ProtoMessage ¶ added in v0.2.0
func (*DeviceConfig) ProtoMessage()
func (*DeviceConfig) ProtoReflect ¶ added in v0.2.0
func (x *DeviceConfig) ProtoReflect() protoreflect.Message
func (*DeviceConfig) Reset ¶ added in v0.2.0
func (x *DeviceConfig) Reset()
func (*DeviceConfig) String ¶ added in v0.2.0
func (x *DeviceConfig) String() string
type DeviceServer ¶ added in v0.2.0
type DeviceServer struct { Server *GrpcServerConfig `protobuf:"bytes,1,opt,name=server,proto3" json:"server,omitempty"` Registry *Registry `protobuf:"bytes,2,opt,name=registry,proto3" json:"registry,omitempty"` Database *DatabaseServerConfig `protobuf:"bytes,3,opt,name=database,proto3" json:"database,omitempty"` Config *DeviceConfig `protobuf:"bytes,4,opt,name=config,proto3" json:"config,omitempty"` Redis *RedisConfig `protobuf:"bytes,5,opt,name=redis,proto3" json:"redis,omitempty"` // contains filtered or unexported fields }
func (*DeviceServer) Descriptor
deprecated
added in
v0.2.0
func (*DeviceServer) Descriptor() ([]byte, []int)
Deprecated: Use DeviceServer.ProtoReflect.Descriptor instead.
func (*DeviceServer) GetConfig ¶ added in v0.2.0
func (x *DeviceServer) GetConfig() *DeviceConfig
func (*DeviceServer) GetDatabase ¶ added in v0.2.0
func (x *DeviceServer) GetDatabase() *DatabaseServerConfig
func (*DeviceServer) GetRedis ¶ added in v0.2.1
func (x *DeviceServer) GetRedis() *RedisConfig
func (*DeviceServer) GetRegistry ¶ added in v0.2.0
func (x *DeviceServer) GetRegistry() *Registry
func (*DeviceServer) GetServer ¶ added in v0.2.0
func (x *DeviceServer) GetServer() *GrpcServerConfig
func (*DeviceServer) ProtoMessage ¶ added in v0.2.0
func (*DeviceServer) ProtoMessage()
func (*DeviceServer) ProtoReflect ¶ added in v0.2.0
func (x *DeviceServer) ProtoReflect() protoreflect.Message
func (*DeviceServer) Reset ¶ added in v0.2.0
func (x *DeviceServer) Reset()
func (*DeviceServer) String ¶ added in v0.2.0
func (x *DeviceServer) String() string
type EmailConfig ¶ added in v0.3.0
type EmailConfig struct { Smtp *SmtpConfig `protobuf:"bytes,1,opt,name=smtp,proto3" json:"smtp,omitempty"` // contains filtered or unexported fields }
func (*EmailConfig) Descriptor
deprecated
added in
v0.3.0
func (*EmailConfig) Descriptor() ([]byte, []int)
Deprecated: Use EmailConfig.ProtoReflect.Descriptor instead.
func (*EmailConfig) GetSmtp ¶ added in v0.3.0
func (x *EmailConfig) GetSmtp() *SmtpConfig
func (*EmailConfig) ProtoMessage ¶ added in v0.3.0
func (*EmailConfig) ProtoMessage()
func (*EmailConfig) ProtoReflect ¶ added in v0.3.0
func (x *EmailConfig) ProtoReflect() protoreflect.Message
func (*EmailConfig) Reset ¶ added in v0.3.0
func (x *EmailConfig) Reset()
func (*EmailConfig) String ¶ added in v0.3.0
func (x *EmailConfig) String() string
type EmailServer ¶ added in v0.3.0
type EmailServer struct { Server *GrpcServerConfig `protobuf:"bytes,1,opt,name=server,proto3" json:"server,omitempty"` Registry *Registry `protobuf:"bytes,2,opt,name=registry,proto3" json:"registry,omitempty"` Config *EmailConfig `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 (*EmailServer) Descriptor
deprecated
added in
v0.3.0
func (*EmailServer) Descriptor() ([]byte, []int)
Deprecated: Use EmailServer.ProtoReflect.Descriptor instead.
func (*EmailServer) GetConfig ¶ added in v0.3.0
func (x *EmailServer) GetConfig() *EmailConfig
func (*EmailServer) GetKafka ¶ added in v0.3.0
func (x *EmailServer) GetKafka() *KafkaConfig
func (*EmailServer) GetRegistry ¶ added in v0.3.0
func (x *EmailServer) GetRegistry() *Registry
func (*EmailServer) GetServer ¶ added in v0.3.0
func (x *EmailServer) GetServer() *GrpcServerConfig
func (*EmailServer) ProtoMessage ¶ added in v0.3.0
func (*EmailServer) ProtoMessage()
func (*EmailServer) ProtoReflect ¶ added in v0.3.0
func (x *EmailServer) ProtoReflect() protoreflect.Message
func (*EmailServer) Reset ¶ added in v0.3.0
func (x *EmailServer) Reset()
func (*EmailServer) String ¶ added in v0.3.0
func (x *EmailServer) String() string
type EmqxConfig ¶ added in v0.2.3
type EmqxConfig struct { Api string `protobuf:"bytes,1,opt,name=api,proto3" json:"api,omitempty" env:"EMQX_API"` // @gotags: env:"EMQX_API" Appid string `protobuf:"bytes,2,opt,name=appid,proto3" json:"appid,omitempty" env:"EMQX_APPID"` // @gotags: env:"EMQX_APPID" Appsecret string `protobuf:"bytes,3,opt,name=appsecret,proto3" json:"appsecret,omitempty" env:"EMQX_APPSECRET"` // @gotags: env:"EMQX_APPSECRET" // contains filtered or unexported fields }
func (*EmqxConfig) Descriptor
deprecated
added in
v0.2.3
func (*EmqxConfig) Descriptor() ([]byte, []int)
Deprecated: Use EmqxConfig.ProtoReflect.Descriptor instead.
func (*EmqxConfig) GetApi ¶ added in v0.2.3
func (x *EmqxConfig) GetApi() string
func (*EmqxConfig) GetAppid ¶ added in v0.2.3
func (x *EmqxConfig) GetAppid() string
func (*EmqxConfig) GetAppsecret ¶ added in v0.2.3
func (x *EmqxConfig) GetAppsecret() string
func (*EmqxConfig) ProtoMessage ¶ added in v0.2.3
func (*EmqxConfig) ProtoMessage()
func (*EmqxConfig) ProtoReflect ¶ added in v0.2.3
func (x *EmqxConfig) ProtoReflect() protoreflect.Message
func (*EmqxConfig) Reset ¶ added in v0.2.3
func (x *EmqxConfig) Reset()
func (*EmqxConfig) String ¶ added in v0.2.3
func (x *EmqxConfig) String() string
type GrpcServerConfig ¶ added in v0.2.0
type GrpcServerConfig struct { Addr string `protobuf:"bytes,1,opt,name=addr,proto3" json:"addr,omitempty" env:"GRPC_ADDR"` // @gotags: env:"GRPC_ADDR" Tls *GrpcServerConfig_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" TracingEndpoint string `` // @gotags: env:"TRACING_ENDPOINT" /* 129-byte string literal not displayed */ // contains filtered or unexported fields }
func DefaultGrpcServer ¶
func DefaultGrpcServer() *GrpcServerConfig
func (*GrpcServerConfig) Descriptor
deprecated
added in
v0.2.0
func (*GrpcServerConfig) Descriptor() ([]byte, []int)
Deprecated: Use GrpcServerConfig.ProtoReflect.Descriptor instead.
func (*GrpcServerConfig) GetAddr ¶ added in v0.2.0
func (x *GrpcServerConfig) GetAddr() string
func (*GrpcServerConfig) GetCustomEndpoint ¶ added in v0.2.0
func (x *GrpcServerConfig) GetCustomEndpoint() string
func (*GrpcServerConfig) GetJwtSecret ¶ added in v0.2.0
func (x *GrpcServerConfig) GetJwtSecret() string
func (*GrpcServerConfig) GetTimeout ¶ added in v0.2.0
func (x *GrpcServerConfig) GetTimeout() *durationpb.Duration
func (*GrpcServerConfig) GetTls ¶ added in v0.2.0
func (x *GrpcServerConfig) GetTls() *GrpcServerConfig_TLS
func (*GrpcServerConfig) GetTracingEndpoint ¶ added in v0.4.1
func (x *GrpcServerConfig) GetTracingEndpoint() string
func (*GrpcServerConfig) ProtoMessage ¶ added in v0.2.0
func (*GrpcServerConfig) ProtoMessage()
func (*GrpcServerConfig) ProtoReflect ¶ added in v0.2.0
func (x *GrpcServerConfig) ProtoReflect() protoreflect.Message
func (*GrpcServerConfig) Reset ¶ added in v0.2.0
func (x *GrpcServerConfig) Reset()
func (*GrpcServerConfig) String ¶ added in v0.2.0
func (x *GrpcServerConfig) String() string
type GrpcServerConfig_TLS ¶ added in v0.2.0
type GrpcServerConfig_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 (*GrpcServerConfig_TLS) Descriptor
deprecated
added in
v0.2.0
func (*GrpcServerConfig_TLS) Descriptor() ([]byte, []int)
Deprecated: Use GrpcServerConfig_TLS.ProtoReflect.Descriptor instead.
func (*GrpcServerConfig_TLS) GetCaFile ¶ added in v0.2.0
func (x *GrpcServerConfig_TLS) GetCaFile() string
func (*GrpcServerConfig_TLS) GetCertFile ¶ added in v0.2.0
func (x *GrpcServerConfig_TLS) GetCertFile() string
func (*GrpcServerConfig_TLS) GetKeyFile ¶ added in v0.2.0
func (x *GrpcServerConfig_TLS) GetKeyFile() string
func (*GrpcServerConfig_TLS) ProtoMessage ¶ added in v0.2.0
func (*GrpcServerConfig_TLS) ProtoMessage()
func (*GrpcServerConfig_TLS) ProtoReflect ¶ added in v0.2.0
func (x *GrpcServerConfig_TLS) ProtoReflect() protoreflect.Message
func (*GrpcServerConfig_TLS) Reset ¶ added in v0.2.0
func (x *GrpcServerConfig_TLS) Reset()
func (*GrpcServerConfig_TLS) String ¶ added in v0.2.0
func (x *GrpcServerConfig_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 LogConfig ¶ added in v0.2.0
type LogConfig struct {
// contains filtered or unexported fields
}
func (*LogConfig) Descriptor
deprecated
added in
v0.2.0
func (*LogConfig) ProtoMessage ¶ added in v0.2.0
func (*LogConfig) ProtoMessage()
func (*LogConfig) ProtoReflect ¶ added in v0.2.0
func (x *LogConfig) ProtoReflect() protoreflect.Message
type LogServer ¶ added in v0.2.0
type LogServer struct { Server *GrpcServerConfig `protobuf:"bytes,1,opt,name=server,proto3" json:"server,omitempty"` Registry *Registry `protobuf:"bytes,2,opt,name=registry,proto3" json:"registry,omitempty"` Database *DatabaseServerConfig `protobuf:"bytes,3,opt,name=database,proto3" json:"database,omitempty"` Config *LogConfig `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 (*LogServer) Descriptor
deprecated
added in
v0.2.0
func (*LogServer) GetDatabase ¶ added in v0.2.0
func (x *LogServer) GetDatabase() *DatabaseServerConfig
func (*LogServer) GetKafka ¶ added in v0.2.0
func (x *LogServer) GetKafka() *KafkaConfig
func (*LogServer) GetRegistry ¶ added in v0.2.0
func (*LogServer) GetServer ¶ added in v0.2.0
func (x *LogServer) GetServer() *GrpcServerConfig
func (*LogServer) ProtoMessage ¶ added in v0.2.0
func (*LogServer) ProtoMessage()
func (*LogServer) ProtoReflect ¶ added in v0.2.0
func (x *LogServer) ProtoReflect() protoreflect.Message
type MTQQConfig ¶ added in v0.2.3
type MTQQConfig struct { Addr string `protobuf:"bytes,1,opt,name=addr,proto3" json:"addr,omitempty" env:"MQTT_ADDR"` // @gotags: env:"MQTT_ADDR" ClientId string `protobuf:"bytes,2,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty" env:"MQTT_CLIENT_ID"` // @gotags: env:"MQTT_CLIENT_ID" Password string `protobuf:"bytes,3,opt,name=password,proto3" json:"password,omitempty" env:"MQTT_PASSWORD"` // @gotags: env:"MQTT_PASSWORD" // contains filtered or unexported fields }
func (*MTQQConfig) Descriptor
deprecated
added in
v0.2.3
func (*MTQQConfig) Descriptor() ([]byte, []int)
Deprecated: Use MTQQConfig.ProtoReflect.Descriptor instead.
func (*MTQQConfig) GetAddr ¶ added in v0.2.3
func (x *MTQQConfig) GetAddr() string
func (*MTQQConfig) GetClientId ¶ added in v0.2.3
func (x *MTQQConfig) GetClientId() string
func (*MTQQConfig) GetPassword ¶ added in v0.2.3
func (x *MTQQConfig) GetPassword() string
func (*MTQQConfig) ProtoMessage ¶ added in v0.2.3
func (*MTQQConfig) ProtoMessage()
func (*MTQQConfig) ProtoReflect ¶ added in v0.2.3
func (x *MTQQConfig) ProtoReflect() protoreflect.Message
func (*MTQQConfig) Reset ¶ added in v0.2.3
func (x *MTQQConfig) Reset()
func (*MTQQConfig) String ¶ added in v0.2.3
func (x *MTQQConfig) String() string
type MessageConfig ¶ added in v0.3.3
type MessageConfig struct {
// contains filtered or unexported fields
}
func (*MessageConfig) Descriptor
deprecated
added in
v0.3.3
func (*MessageConfig) Descriptor() ([]byte, []int)
Deprecated: Use MessageConfig.ProtoReflect.Descriptor instead.
func (*MessageConfig) ProtoMessage ¶ added in v0.3.3
func (*MessageConfig) ProtoMessage()
func (*MessageConfig) ProtoReflect ¶ added in v0.3.3
func (x *MessageConfig) ProtoReflect() protoreflect.Message
func (*MessageConfig) Reset ¶ added in v0.3.3
func (x *MessageConfig) Reset()
func (*MessageConfig) String ¶ added in v0.3.3
func (x *MessageConfig) String() string
type MessageServer ¶ added in v0.3.3
type MessageServer struct { Server *GrpcServerConfig `protobuf:"bytes,1,opt,name=server,proto3" json:"server,omitempty"` Registry *Registry `protobuf:"bytes,2,opt,name=registry,proto3" json:"registry,omitempty"` Database *DatabaseServerConfig `protobuf:"bytes,3,opt,name=database,proto3" json:"database,omitempty"` Config *MessageConfig `protobuf:"bytes,4,opt,name=config,proto3" json:"config,omitempty"` Kafka *KafkaConfig `protobuf:"bytes,5,opt,name=kafka,proto3" json:"kafka,omitempty"` Redis *RedisConfig `protobuf:"bytes,6,opt,name=redis,proto3" json:"redis,omitempty"` // contains filtered or unexported fields }
func (*MessageServer) Descriptor
deprecated
added in
v0.3.3
func (*MessageServer) Descriptor() ([]byte, []int)
Deprecated: Use MessageServer.ProtoReflect.Descriptor instead.
func (*MessageServer) GetConfig ¶ added in v0.3.3
func (x *MessageServer) GetConfig() *MessageConfig
func (*MessageServer) GetDatabase ¶ added in v0.3.3
func (x *MessageServer) GetDatabase() *DatabaseServerConfig
func (*MessageServer) GetKafka ¶ added in v0.3.3
func (x *MessageServer) GetKafka() *KafkaConfig
func (*MessageServer) GetRedis ¶ added in v0.3.3
func (x *MessageServer) GetRedis() *RedisConfig
func (*MessageServer) GetRegistry ¶ added in v0.3.3
func (x *MessageServer) GetRegistry() *Registry
func (*MessageServer) GetServer ¶ added in v0.3.3
func (x *MessageServer) GetServer() *GrpcServerConfig
func (*MessageServer) ProtoMessage ¶ added in v0.3.3
func (*MessageServer) ProtoMessage()
func (*MessageServer) ProtoReflect ¶ added in v0.3.3
func (x *MessageServer) ProtoReflect() protoreflect.Message
func (*MessageServer) Reset ¶ added in v0.3.3
func (x *MessageServer) Reset()
func (*MessageServer) String ¶ added in v0.3.3
func (x *MessageServer) String() string
type NotifyConfig ¶ added in v0.3.2
type NotifyConfig struct {
// contains filtered or unexported fields
}
func (*NotifyConfig) Descriptor
deprecated
added in
v0.3.2
func (*NotifyConfig) Descriptor() ([]byte, []int)
Deprecated: Use NotifyConfig.ProtoReflect.Descriptor instead.
func (*NotifyConfig) ProtoMessage ¶ added in v0.3.2
func (*NotifyConfig) ProtoMessage()
func (*NotifyConfig) ProtoReflect ¶ added in v0.3.2
func (x *NotifyConfig) ProtoReflect() protoreflect.Message
func (*NotifyConfig) Reset ¶ added in v0.3.2
func (x *NotifyConfig) Reset()
func (*NotifyConfig) String ¶ added in v0.3.2
func (x *NotifyConfig) String() string
type NotifyServer ¶ added in v0.3.2
type NotifyServer struct { Server *GrpcServerConfig `protobuf:"bytes,1,opt,name=server,proto3" json:"server,omitempty"` Registry *Registry `protobuf:"bytes,2,opt,name=registry,proto3" json:"registry,omitempty"` Config *NotifyConfig `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 (*NotifyServer) Descriptor
deprecated
added in
v0.3.2
func (*NotifyServer) Descriptor() ([]byte, []int)
Deprecated: Use NotifyServer.ProtoReflect.Descriptor instead.
func (*NotifyServer) GetConfig ¶ added in v0.3.2
func (x *NotifyServer) GetConfig() *NotifyConfig
func (*NotifyServer) GetKafka ¶ added in v0.3.2
func (x *NotifyServer) GetKafka() *KafkaConfig
func (*NotifyServer) GetRegistry ¶ added in v0.3.2
func (x *NotifyServer) GetRegistry() *Registry
func (*NotifyServer) GetServer ¶ added in v0.3.2
func (x *NotifyServer) GetServer() *GrpcServerConfig
func (*NotifyServer) ProtoMessage ¶ added in v0.3.2
func (*NotifyServer) ProtoMessage()
func (*NotifyServer) ProtoReflect ¶ added in v0.3.2
func (x *NotifyServer) ProtoReflect() protoreflect.Message
func (*NotifyServer) Reset ¶ added in v0.3.2
func (x *NotifyServer) Reset()
func (*NotifyServer) String ¶ added in v0.3.2
func (x *NotifyServer) String() string
type RedisConfig ¶ added in v0.2.0
type RedisConfig struct { Addr string `protobuf:"bytes,1,opt,name=addr,proto3" json:"addr,omitempty" env:"REDIS_ADDR"` // @gotags: env:"REDIS_ADDR" Username string `protobuf:"bytes,2,opt,name=username,proto3" json:"username,omitempty" env:"REDIS_USERNAME"` // @gotags: env:"REDIS_USERNAME" Password string `protobuf:"bytes,3,opt,name=password,proto3" json:"password,omitempty" env:"REDIS_PASSWORD"` // @gotags: env:"REDIS_PASSWORD" Db int32 `protobuf:"varint,4,opt,name=db,proto3" json:"db,omitempty" env:"REDIS_DB"` // @gotags: env:"REDIS_DB" // contains filtered or unexported fields }
func (*RedisConfig) Descriptor
deprecated
added in
v0.2.0
func (*RedisConfig) Descriptor() ([]byte, []int)
Deprecated: Use RedisConfig.ProtoReflect.Descriptor instead.
func (*RedisConfig) GetAddr ¶ added in v0.2.0
func (x *RedisConfig) GetAddr() string
func (*RedisConfig) GetDb ¶ added in v0.2.0
func (x *RedisConfig) GetDb() int32
func (*RedisConfig) GetPassword ¶ added in v0.2.0
func (x *RedisConfig) GetPassword() string
func (*RedisConfig) GetUsername ¶ added in v0.2.0
func (x *RedisConfig) GetUsername() string
func (*RedisConfig) ProtoMessage ¶ added in v0.2.0
func (*RedisConfig) ProtoMessage()
func (*RedisConfig) ProtoReflect ¶ added in v0.2.0
func (x *RedisConfig) ProtoReflect() protoreflect.Message
func (*RedisConfig) Reset ¶ added in v0.2.0
func (x *RedisConfig) Reset()
func (*RedisConfig) String ¶ added in v0.2.0
func (x *RedisConfig) String() string
type Registry ¶
type Registry struct { 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) GetEtcd ¶
func (x *Registry) GetEtcd() *Registry_Etcd
func (*Registry) ProtoMessage ¶
func (*Registry) ProtoMessage()
func (*Registry) ProtoReflect ¶
func (x *Registry) ProtoReflect() protoreflect.Message
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 SmtpConfig ¶ added in v0.3.0
type SmtpConfig struct { Host string `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty" env:"SMTP_HOST"` // @gotags: env:"SMTP_HOST" Port uint32 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty" env:"SMTP_PORT"` // @gotags: env:"SMTP_PORT" Protocol string `protobuf:"bytes,3,opt,name=protocol,proto3" json:"protocol,omitempty" env:"SMTP_PROTOCOL"` // @gotags: env:"SMTP_PROTOCOL" Username string `protobuf:"bytes,4,opt,name=username,proto3" json:"username,omitempty" env:"SMTP_USERNAME"` // @gotags: env:"SMTP_USERNAME" Password string `protobuf:"bytes,5,opt,name=password,proto3" json:"password,omitempty" env:"SMTP_PASSWORD"` // @gotags: env:"SMTP_PASSWORD" From string `protobuf:"bytes,6,opt,name=from,proto3" json:"from,omitempty" env:"SMTP_FROM"` // @gotags: env:"SMTP_FROM" // contains filtered or unexported fields }
func (*SmtpConfig) Descriptor
deprecated
added in
v0.3.0
func (*SmtpConfig) Descriptor() ([]byte, []int)
Deprecated: Use SmtpConfig.ProtoReflect.Descriptor instead.
func (*SmtpConfig) GetFrom ¶ added in v0.3.0
func (x *SmtpConfig) GetFrom() string
func (*SmtpConfig) GetHost ¶ added in v0.3.0
func (x *SmtpConfig) GetHost() string
func (*SmtpConfig) GetPassword ¶ added in v0.3.0
func (x *SmtpConfig) GetPassword() string
func (*SmtpConfig) GetPort ¶ added in v0.3.0
func (x *SmtpConfig) GetPort() uint32
func (*SmtpConfig) GetProtocol ¶ added in v0.3.0
func (x *SmtpConfig) GetProtocol() string
func (*SmtpConfig) GetUsername ¶ added in v0.3.0
func (x *SmtpConfig) GetUsername() string
func (*SmtpConfig) ProtoMessage ¶ added in v0.3.0
func (*SmtpConfig) ProtoMessage()
func (*SmtpConfig) ProtoReflect ¶ added in v0.3.0
func (x *SmtpConfig) ProtoReflect() protoreflect.Message
func (*SmtpConfig) Reset ¶ added in v0.3.0
func (x *SmtpConfig) Reset()
func (*SmtpConfig) String ¶ added in v0.3.0
func (x *SmtpConfig) 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" TracingEndpoint string `` // @gotags: env:"TRACING_ENDPOINT" /* 129-byte string literal not displayed */ // 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) GetTracingEndpoint ¶ added in v0.4.1
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 UserConfig ¶ added in v0.2.0
type UserConfig struct {
// contains filtered or unexported fields
}
func (*UserConfig) Descriptor
deprecated
added in
v0.2.0
func (*UserConfig) Descriptor() ([]byte, []int)
Deprecated: Use UserConfig.ProtoReflect.Descriptor instead.
func (*UserConfig) ProtoMessage ¶ added in v0.2.0
func (*UserConfig) ProtoMessage()
func (*UserConfig) ProtoReflect ¶ added in v0.2.0
func (x *UserConfig) ProtoReflect() protoreflect.Message
func (*UserConfig) Reset ¶ added in v0.2.0
func (x *UserConfig) Reset()
func (*UserConfig) String ¶ added in v0.2.0
func (x *UserConfig) String() string
type UserServer ¶ added in v0.2.0
type UserServer struct { Server *GrpcServerConfig `protobuf:"bytes,1,opt,name=server,proto3" json:"server,omitempty"` Registry *Registry `protobuf:"bytes,2,opt,name=registry,proto3" json:"registry,omitempty"` Database *DatabaseServerConfig `protobuf:"bytes,3,opt,name=database,proto3" json:"database,omitempty"` Config *UserConfig `protobuf:"bytes,4,opt,name=config,proto3" json:"config,omitempty"` Redis *RedisConfig `protobuf:"bytes,5,opt,name=redis,proto3" json:"redis,omitempty"` // contains filtered or unexported fields }
func (*UserServer) Descriptor
deprecated
added in
v0.2.0
func (*UserServer) Descriptor() ([]byte, []int)
Deprecated: Use UserServer.ProtoReflect.Descriptor instead.
func (*UserServer) GetConfig ¶ added in v0.2.0
func (x *UserServer) GetConfig() *UserConfig
func (*UserServer) GetDatabase ¶ added in v0.2.0
func (x *UserServer) GetDatabase() *DatabaseServerConfig
func (*UserServer) GetRedis ¶ added in v0.2.0
func (x *UserServer) GetRedis() *RedisConfig
func (*UserServer) GetRegistry ¶ added in v0.2.0
func (x *UserServer) GetRegistry() *Registry
func (*UserServer) GetServer ¶ added in v0.2.0
func (x *UserServer) GetServer() *GrpcServerConfig
func (*UserServer) ProtoMessage ¶ added in v0.2.0
func (*UserServer) ProtoMessage()
func (*UserServer) ProtoReflect ¶ added in v0.2.0
func (x *UserServer) ProtoReflect() protoreflect.Message
func (*UserServer) Reset ¶ added in v0.2.0
func (x *UserServer) Reset()
func (*UserServer) String ¶ added in v0.2.0
func (x *UserServer) String() string
type WebConfig ¶ added in v0.2.0
type WebConfig struct { Jwt *WebConfig_JWT `protobuf:"bytes,1,opt,name=jwt,proto3" json:"jwt,omitempty"` // contains filtered or unexported fields }
func (*WebConfig) Descriptor
deprecated
added in
v0.2.0
func (*WebConfig) GetJwt ¶ added in v0.2.0
func (x *WebConfig) GetJwt() *WebConfig_JWT
func (*WebConfig) ProtoMessage ¶ added in v0.2.0
func (*WebConfig) ProtoMessage()
func (*WebConfig) ProtoReflect ¶ added in v0.2.0
func (x *WebConfig) ProtoReflect() protoreflect.Message
type WebConfig_JWT ¶ added in v0.2.0
type WebConfig_JWT struct { Secret string `protobuf:"bytes,1,opt,name=secret,proto3" json:"secret,omitempty" env:"WEB_JWT_SECRET"` // @gotags: env:"WEB_JWT_SECRET" Expire string `protobuf:"bytes,2,opt,name=expire,proto3" json:"expire,omitempty" env:"WEB_JWT_EXPIRE"` // @gotags: env:"WEB_JWT_EXPIRE" // contains filtered or unexported fields }
func (*WebConfig_JWT) Descriptor
deprecated
added in
v0.2.0
func (*WebConfig_JWT) Descriptor() ([]byte, []int)
Deprecated: Use WebConfig_JWT.ProtoReflect.Descriptor instead.
func (*WebConfig_JWT) GetExpire ¶ added in v0.2.0
func (x *WebConfig_JWT) GetExpire() string
func (*WebConfig_JWT) GetSecret ¶ added in v0.2.0
func (x *WebConfig_JWT) GetSecret() string
func (*WebConfig_JWT) ProtoMessage ¶ added in v0.2.0
func (*WebConfig_JWT) ProtoMessage()
func (*WebConfig_JWT) ProtoReflect ¶ added in v0.2.0
func (x *WebConfig_JWT) ProtoReflect() protoreflect.Message
func (*WebConfig_JWT) Reset ¶ added in v0.2.0
func (x *WebConfig_JWT) Reset()
func (*WebConfig_JWT) String ¶ added in v0.2.0
func (x *WebConfig_JWT) String() string
type WebServer ¶
type WebServer struct { Server *WebServerConfig `protobuf:"bytes,1,opt,name=server,proto3" json:"server,omitempty"` Registry *Registry `protobuf:"bytes,2,opt,name=registry,proto3" json:"registry,omitempty"` Config *WebConfig `protobuf:"bytes,3,opt,name=config,proto3" json:"config,omitempty"` Redis *RedisConfig `protobuf:"bytes,4,opt,name=redis,proto3" json:"redis,omitempty"` // contains filtered or unexported fields }
func (*WebServer) Descriptor
deprecated
func (*WebServer) GetRedis ¶ added in v0.2.0
func (x *WebServer) GetRedis() *RedisConfig
func (*WebServer) GetRegistry ¶ added in v0.2.0
func (*WebServer) GetServer ¶ added in v0.2.0
func (x *WebServer) GetServer() *WebServerConfig
func (*WebServer) ProtoMessage ¶
func (*WebServer) ProtoMessage()
func (*WebServer) ProtoReflect ¶
func (x *WebServer) ProtoReflect() protoreflect.Message
type WebServerConfig ¶ added in v0.2.0
type WebServerConfig struct { Addr string `protobuf:"bytes,1,opt,name=addr,proto3" json:"addr,omitempty" env:"WEB_ADDR"` // @gotags: env:"WEB_ADDR" Tls *WebServerConfig_TLS `protobuf:"bytes,2,opt,name=tls,proto3" json:"tls,omitempty"` CustomEndpoint string `` // @gotags: env:"WEB_CUSTOM_ENDPOINT" /* 129-byte string literal not displayed */ TracingEndpoint string `` // @gotags: env:"TRACING_ENDPOINT" /* 129-byte string literal not displayed */ // contains filtered or unexported fields }
func DefaultWebServer ¶ added in v0.2.0
func DefaultWebServer() *WebServerConfig
func (*WebServerConfig) Descriptor
deprecated
added in
v0.2.0
func (*WebServerConfig) Descriptor() ([]byte, []int)
Deprecated: Use WebServerConfig.ProtoReflect.Descriptor instead.
func (*WebServerConfig) GetAddr ¶ added in v0.2.0
func (x *WebServerConfig) GetAddr() string
func (*WebServerConfig) GetCustomEndpoint ¶ added in v0.2.0
func (x *WebServerConfig) GetCustomEndpoint() string
func (*WebServerConfig) GetTls ¶ added in v0.2.0
func (x *WebServerConfig) GetTls() *WebServerConfig_TLS
func (*WebServerConfig) GetTracingEndpoint ¶ added in v0.4.1
func (x *WebServerConfig) GetTracingEndpoint() string
func (*WebServerConfig) ProtoMessage ¶ added in v0.2.0
func (*WebServerConfig) ProtoMessage()
func (*WebServerConfig) ProtoReflect ¶ added in v0.2.0
func (x *WebServerConfig) ProtoReflect() protoreflect.Message
func (*WebServerConfig) Reset ¶ added in v0.2.0
func (x *WebServerConfig) Reset()
func (*WebServerConfig) String ¶ added in v0.2.0
func (x *WebServerConfig) String() string
type WebServerConfig_TLS ¶ added in v0.2.0
type WebServerConfig_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 (*WebServerConfig_TLS) Descriptor
deprecated
added in
v0.2.0
func (*WebServerConfig_TLS) Descriptor() ([]byte, []int)
Deprecated: Use WebServerConfig_TLS.ProtoReflect.Descriptor instead.
func (*WebServerConfig_TLS) GetCaFile ¶ added in v0.2.0
func (x *WebServerConfig_TLS) GetCaFile() string
func (*WebServerConfig_TLS) GetCertFile ¶ added in v0.2.0
func (x *WebServerConfig_TLS) GetCertFile() string
func (*WebServerConfig_TLS) GetKeyFile ¶ added in v0.2.0
func (x *WebServerConfig_TLS) GetKeyFile() string
func (*WebServerConfig_TLS) ProtoMessage ¶ added in v0.2.0
func (*WebServerConfig_TLS) ProtoMessage()
func (*WebServerConfig_TLS) ProtoReflect ¶ added in v0.2.0
func (x *WebServerConfig_TLS) ProtoReflect() protoreflect.Message
func (*WebServerConfig_TLS) Reset ¶ added in v0.2.0
func (x *WebServerConfig_TLS) Reset()
func (*WebServerConfig_TLS) String ¶ added in v0.2.0
func (x *WebServerConfig_TLS) String() string