Versions in this module Expand all Collapse all v0 v0.0.2 Sep 1, 2024 Changes in this version type RabbitMQ + Enable bool + func (x *RabbitMQ) GetEnable() bool v0.0.1 Aug 31, 2024 Changes in this version + var File_config_def_default_v1_proto protoreflect.FileDescriptor + var Log_LogLevelEnum_name = map[int32]string + var Log_LogLevelEnum_value = map[string]int32 + type Configuration struct + Database Database + Log Log + MessageQueue RabbitMQ + Mongo Mongo + Profile Profile + Redis Redis + Registry Registry + Server *Server + Tracing Tracing + func NewConfiguration(config config.ConfigureWatcherRepo) (*Configuration, error) + type ConsumeConfig struct + AutoAck bool + Name string + NoWait bool + QosPrefetchCount int32 + QosPrefetchSize int32 + func (*ConsumeConfig) Descriptor() ([]byte, []int) + func (*ConsumeConfig) ProtoMessage() + func (x *ConsumeConfig) GetAutoAck() bool + func (x *ConsumeConfig) GetName() string + func (x *ConsumeConfig) GetNoWait() bool + func (x *ConsumeConfig) GetQosPrefetchCount() int32 + func (x *ConsumeConfig) GetQosPrefetchSize() int32 + func (x *ConsumeConfig) ProtoReflect() protoreflect.Message + func (x *ConsumeConfig) Reset() + func (x *ConsumeConfig) String() string + type Data struct + Database *Database + Mongodb *Mongo + RabbitMq *RabbitMQ + Redis *Redis + func (*Data) Descriptor() ([]byte, []int) + func (*Data) ProtoMessage() + func (x *Data) GetDatabase() *Database + func (x *Data) GetMongodb() *Mongo + func (x *Data) GetRabbitMq() *RabbitMQ + func (x *Data) GetRedis() *Redis + func (x *Data) ProtoReflect() protoreflect.Message + func (x *Data) Reset() + func (x *Data) String() string + type Database struct + Addr string + ConnMaxIdleTime *durationpb.Duration + ConnMaxLifetime *durationpb.Duration + Database string + Driver string + Enable bool + MaxConnection uint64 + MaxPoolIdleSize uint64 + func (*Database) Descriptor() ([]byte, []int) + func (*Database) ProtoMessage() + func (x *Database) GetAddr() string + func (x *Database) GetConnMaxIdleTime() *durationpb.Duration + func (x *Database) GetConnMaxLifetime() *durationpb.Duration + func (x *Database) GetDatabase() string + func (x *Database) GetDriver() string + func (x *Database) GetEnable() bool + func (x *Database) GetMaxConnection() uint64 + func (x *Database) GetMaxPoolIdleSize() uint64 + func (x *Database) ProtoReflect() protoreflect.Message + func (x *Database) Reset() + func (x *Database) String() string + type ExchangeConfig struct + AutoDelete bool + Durable bool + Kind string + Name string + func (*ExchangeConfig) Descriptor() ([]byte, []int) + func (*ExchangeConfig) ProtoMessage() + func (x *ExchangeConfig) GetAutoDelete() bool + func (x *ExchangeConfig) GetDurable() bool + func (x *ExchangeConfig) GetKind() string + func (x *ExchangeConfig) GetName() string + func (x *ExchangeConfig) ProtoReflect() protoreflect.Message + func (x *ExchangeConfig) Reset() + func (x *ExchangeConfig) String() string + type Log struct + Console *Log_Console + File *Log_File + Graylog *Log_Graylog + func (*Log) Descriptor() ([]byte, []int) + func (*Log) ProtoMessage() + func (x *Log) GetConsole() *Log_Console + func (x *Log) GetFile() *Log_File + func (x *Log) GetGraylog() *Log_Graylog + func (x *Log) ProtoReflect() protoreflect.Message + func (x *Log) Reset() + func (x *Log) String() string + type Log_Console struct + Enable bool + Level string + UseJsonEncoder bool + func (*Log_Console) Descriptor() ([]byte, []int) + func (*Log_Console) ProtoMessage() + func (x *Log_Console) GetEnable() bool + func (x *Log_Console) GetLevel() string + func (x *Log_Console) GetUseJsonEncoder() bool + func (x *Log_Console) ProtoReflect() protoreflect.Message + func (x *Log_Console) Reset() + func (x *Log_Console) String() string + type Log_File struct + Dir string + Enable bool + Filename string + Level string + RotateSize int64 + RotateTime *durationpb.Duration + StorageAge *durationpb.Duration + StorageCounter uint32 + func (*Log_File) Descriptor() ([]byte, []int) + func (*Log_File) ProtoMessage() + func (x *Log_File) GetDir() string + func (x *Log_File) GetEnable() bool + func (x *Log_File) GetFilename() string + func (x *Log_File) GetLevel() string + func (x *Log_File) GetRotateSize() int64 + func (x *Log_File) GetRotateTime() *durationpb.Duration + func (x *Log_File) GetStorageAge() *durationpb.Duration + func (x *Log_File) GetStorageCounter() uint32 + func (x *Log_File) ProtoReflect() protoreflect.Message + func (x *Log_File) Reset() + func (x *Log_File) String() string + type Log_Graylog struct + Addr string + AsyncPoolSize int32 + Enable bool + Facility string + Level string + Proto string + func (*Log_Graylog) Descriptor() ([]byte, []int) + func (*Log_Graylog) ProtoMessage() + func (x *Log_Graylog) GetAddr() string + func (x *Log_Graylog) GetAsyncPoolSize() int32 + func (x *Log_Graylog) GetEnable() bool + func (x *Log_Graylog) GetFacility() string + func (x *Log_Graylog) GetLevel() string + func (x *Log_Graylog) GetProto() string + func (x *Log_Graylog) ProtoReflect() protoreflect.Message + func (x *Log_Graylog) Reset() + func (x *Log_Graylog) String() string + type Log_LogLevelEnum int32 + const Log_DEBUG + const Log_ERROR + const Log_FATAL + const Log_INFO + const Log_LOG_LEVEL_UNSPECIFIED + const Log_WARN + func (Log_LogLevelEnum) Descriptor() protoreflect.EnumDescriptor + func (Log_LogLevelEnum) EnumDescriptor() ([]byte, []int) + func (Log_LogLevelEnum) Type() protoreflect.EnumType + func (x Log_LogLevelEnum) Enum() *Log_LogLevelEnum + func (x Log_LogLevelEnum) Number() protoreflect.EnumNumber + func (x Log_LogLevelEnum) String() string + type Mongo struct + Address string + ConnectTimeout *durationpb.Duration + Database string + Debug bool + Enable bool + HeartbeatInterval *durationpb.Duration + Hosts []string + MaxConnIdleTime *durationpb.Duration + MaxConnection uint64 + MaxPoolSize uint64 + MinPoolSize uint64 + Timeout *durationpb.Duration + func (*Mongo) Descriptor() ([]byte, []int) + func (*Mongo) ProtoMessage() + func (x *Mongo) GetAddress() string + func (x *Mongo) GetConnectTimeout() *durationpb.Duration + func (x *Mongo) GetDatabase() string + func (x *Mongo) GetDebug() bool + func (x *Mongo) GetEnable() bool + func (x *Mongo) GetHeartbeatInterval() *durationpb.Duration + func (x *Mongo) GetHosts() []string + func (x *Mongo) GetMaxConnIdleTime() *durationpb.Duration + func (x *Mongo) GetMaxConnection() uint64 + func (x *Mongo) GetMaxPoolSize() uint64 + func (x *Mongo) GetMinPoolSize() uint64 + func (x *Mongo) GetTimeout() *durationpb.Duration + func (x *Mongo) ProtoReflect() protoreflect.Message + func (x *Mongo) Reset() + func (x *Mongo) String() string + type Profile struct + CpuFile string + EnableCpu bool + EnableMem bool + MemFile string + func (*Profile) Descriptor() ([]byte, []int) + func (*Profile) ProtoMessage() + func (x *Profile) GetCpuFile() string + func (x *Profile) GetEnableCpu() bool + func (x *Profile) GetEnableMem() bool + func (x *Profile) GetMemFile() string + func (x *Profile) ProtoReflect() protoreflect.Message + func (x *Profile) Reset() + func (x *Profile) String() string + type QueueConfig struct + AutoDelete bool + Durable bool + ExchangeName string + Name string + RoutingKey string + func (*QueueConfig) Descriptor() ([]byte, []int) + func (*QueueConfig) ProtoMessage() + func (x *QueueConfig) GetAutoDelete() bool + func (x *QueueConfig) GetDurable() bool + func (x *QueueConfig) GetExchangeName() string + func (x *QueueConfig) GetName() string + func (x *QueueConfig) GetRoutingKey() string + func (x *QueueConfig) ProtoReflect() protoreflect.Message + func (x *QueueConfig) Reset() + func (x *QueueConfig) String() string + type RabbitMQ struct + Addresses string + ClientName string + Heartbeat *durationpb.Duration + Retry int32 + Vhost string + func (*RabbitMQ) Descriptor() ([]byte, []int) + func (*RabbitMQ) ProtoMessage() + func (x *RabbitMQ) GetAddresses() string + func (x *RabbitMQ) GetClientName() string + func (x *RabbitMQ) GetHeartbeat() *durationpb.Duration + func (x *RabbitMQ) GetRetry() int32 + func (x *RabbitMQ) GetVhost() string + func (x *RabbitMQ) ProtoReflect() protoreflect.Message + func (x *RabbitMQ) Reset() + func (x *RabbitMQ) String() string + type Redis struct + Addresses []string + Db int32 + DialTimeout *durationpb.Duration + Enable bool + MaxPoolIdleSize uint64 + MaxPoolSize uint64 + MaxRetries uint64 + MinPoolIdleSize uint64 + Password string + ReadTimeout *durationpb.Duration + Username string + WriteTimeout *durationpb.Duration + func (*Redis) Descriptor() ([]byte, []int) + func (*Redis) ProtoMessage() + func (x *Redis) GetAddresses() []string + func (x *Redis) GetDb() int32 + func (x *Redis) GetDialTimeout() *durationpb.Duration + func (x *Redis) GetEnable() bool + func (x *Redis) GetMaxPoolIdleSize() uint64 + func (x *Redis) GetMaxPoolSize() uint64 + func (x *Redis) GetMaxRetries() uint64 + func (x *Redis) GetMinPoolIdleSize() uint64 + func (x *Redis) GetPassword() string + func (x *Redis) GetReadTimeout() *durationpb.Duration + func (x *Redis) GetUsername() string + func (x *Redis) GetWriteTimeout() *durationpb.Duration + func (x *Redis) ProtoReflect() protoreflect.Message + func (x *Redis) Reset() + func (x *Redis) String() string + type Registry struct + Address string + Enable bool + Name string + Timeout *durationpb.Duration + Type string + Version string + func (*Registry) Descriptor() ([]byte, []int) + func (*Registry) ProtoMessage() + func (x *Registry) GetAddress() string + func (x *Registry) GetEnable() bool + func (x *Registry) GetName() string + func (x *Registry) GetTimeout() *durationpb.Duration + func (x *Registry) GetType() string + func (x *Registry) GetVersion() string + func (x *Registry) ProtoReflect() protoreflect.Message + func (x *Registry) Reset() + func (x *Registry) String() string + type Server struct + Grpc *Registry + Http *Registry + func (*Server) Descriptor() ([]byte, []int) + func (*Server) ProtoMessage() + func (x *Server) GetGrpc() *Registry + func (x *Server) GetHttp() *Registry + func (x *Server) ProtoReflect() protoreflect.Message + func (x *Server) Reset() + func (x *Server) String() string + type Tracing struct + Enable bool + Endpoint string + MaxBatchSize int32 + MaxQueueSize int32 + SimpleRate float64 + Type string + UrlPath string + func (*Tracing) Descriptor() ([]byte, []int) + func (*Tracing) ProtoMessage() + func (x *Tracing) GetEnable() bool + func (x *Tracing) GetEndpoint() string + func (x *Tracing) GetMaxBatchSize() int32 + func (x *Tracing) GetMaxQueueSize() int32 + func (x *Tracing) GetSimpleRate() float64 + func (x *Tracing) GetType() string + func (x *Tracing) GetUrlPath() string + func (x *Tracing) ProtoReflect() protoreflect.Message + func (x *Tracing) Reset() + func (x *Tracing) String() string
Go to main page