Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AProvider ¶
type AProvider struct { ClientURL string `env:"URL" envDefault:"http://0.0.0.0:8080"` Token string `env:"Token" envDefault:""` }
func (*AProvider) GetCircuitBreakerConfig ¶
func (p *AProvider) GetCircuitBreakerConfig() *gobreaker.CircuitBreaker
type BProvider ¶
type BProvider struct { ClientURL string `env:"URL" envDefault:"http://0.0.0.0:8080"` Token string `env:"Token" envDefault:""` }
func (*BProvider) GetCircuitBreakerConfig ¶
func (p *BProvider) GetCircuitBreakerConfig() *gobreaker.CircuitBreaker
type Configs ¶
type KafkaConfig ¶
type KafkaConfig struct {
Brokers []string `env:"KAFKA_BROKERS" envSeparator:"," envDefault:"localhost:9092"`
}
func (KafkaConfig) ToSaramaConfig ¶
func (conf KafkaConfig) ToSaramaConfig() (*sarama.Config, error)
Click to show internal directories.
Click to hide internal directories.