Versions in this module Expand all Collapse all v0 v0.0.3 Aug 10, 2024 v0.0.2 Aug 10, 2024 Changes in this version type Kafka + RackID string type KafkaProducerOptions + MaxMessageBytes int type S3 + Name string type Telemetry + Sampler TelemetrySampling + type TelemetrySampling string + func (k TelemetrySampling) Sampler() (trace.Sampler, error) + func (k TelemetrySampling) Valid() bool v0.0.1 Jun 6, 2023 Changes in this version + const TelemetryKindJaeger + const TelemetryKindOTLPGRPC + const TelemetryKindOTLPHTTP + const TelemetryKindZipkin + type ConfigValidator interface + Validate func() (err error) + type FileLogging struct + Compress bool + Enable bool + MaxAgeDays int + MaxBackups int + MaxSizeMB int + Path string + type GRPCClient struct + Address string + Credentials *GRPCClientCredentials + Timeout time.Duration + func (c *GRPCClient) Validate() (err error) + type GRPCClientCredentials struct + CertFile string + Secure bool + ServerNameOverride string + func (c GRPCClientCredentials) TransportCredentials() (credentials.TransportCredentials, error) + func (c GRPCClientCredentials) Validate() (err error) + type GRPCGatewayConfig struct + Client GRPCClient + Host string + Port int + func (c *GRPCGatewayConfig) HostPort() string + func (g *GRPCGatewayConfig) Validate() (err error) + type GRPCServer struct + Transports []GRPCServerTransport + func (c *GRPCServer) Validate() (err error) + type GRPCServerCredentials struct + CertFile string + KeyFile string + Secure bool + func (c *GRPCServerCredentials) TransportCredentials() (credentials.TransportCredentials, error) + func (c *GRPCServerCredentials) Validate() (err error) + type GRPCServerTransport struct + Credentials GRPCServerCredentials + Host string + Port int + func (g *GRPCServerTransport) Validate() (err error) + func (g GRPCServerTransport) HostPort() string + type Kafka struct + Brokers []string + Consumer *KafkaConsumerOptions + Name string + Producer *KafkaProducerOptions + Topic string + func (k *Kafka) Validate() (err error) + type KafkaConsumerOptions struct + BackoffDuration time.Duration + GroupID string + Offset *KafkaOffset + RebalanceStrategy *KafkaRebalanceStrategy + func (k *KafkaConsumerOptions) Assign(cfg *sarama.Config) + func (k *KafkaConsumerOptions) Validate() (err error) + type KafkaOffset string + const KafkaOffsetNewest + const KafkaOffsetOldest + func (k KafkaOffset) String() string + func (k KafkaOffset) Validate() error + func (k KafkaOffset) Value() int64 + type KafkaProducerOptions struct + BackoffDuration time.Duration + RetryMaximum int + Timeout time.Duration + func (k *KafkaProducerOptions) Assign(cfg *sarama.Config) + func (k *KafkaProducerOptions) Validate() (err error) + type KafkaRebalanceStrategy string + const KafkaRebalanceStrategyRange + const KafkaRebalanceStrategyRoundRobin + const KafkaRebalanceStrategySticky + func (k KafkaRebalanceStrategy) String() string + func (k KafkaRebalanceStrategy) Validate() error + func (k KafkaRebalanceStrategy) Value() sarama.BalanceStrategy + type Logging struct + File FileLogging + Level string + func (c *Logging) Validate() (err error) + func (c *Logging) ZapLevel() zapcore.Level + func (c *Logging) ZapWriteSync() zapcore.WriteSyncer + type NATSQueue struct + RetentionPolicy string + func (q *NATSQueue) Validate() (err error) + type PostgreSQL struct + Hostname string + Name string + Password string + Port uint16 + Properties map[string]string + Username string + func (d *PostgreSQL) Validate() (err error) + func (d PostgreSQL) String() string + func (d PostgreSQL) UnsafeString() string + type Redis struct + Addresses []string + DatabaseNumber int + MasterName string + Password string + ReadTimeout time.Duration + SentinelPassword string + SentinelUsername string + Username string + WriteTimeout time.Duration + func (r *Redis) Instance() redis.UniversalClient + func (r *Redis) Validate() (err error) + type S3 struct + AccessKey string + Bucket string + Endpoint string + Region string + SecretKey string + UseSSL bool + func (s *S3) Validate() (err error) + type Telemetry struct + CertFile *string + Enable bool + Endpoint string + Kind TelemetryKind + func (c *Telemetry) Validate() (err error) + type TelemetryKind string + func (k TelemetryKind) Valid() bool