Versions in this module Expand all Collapse all v0 v0.0.9 Feb 5, 2025 v0.0.8 Feb 5, 2025 v0.0.7 Feb 5, 2025 v0.0.6 Nov 10, 2024 v0.0.5 Nov 10, 2024 v0.0.4 Nov 10, 2024 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
Go to main page