Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var (
Redis *redis.Client
)
Functions ¶
Types ¶
type Config ¶
type Config struct { Address *string `default:":6379"` Password *string `default:""` GroupName *string `default:"gate-group"` ConsumerName *string `default:"gate1" envconfig:"hostname"` StreamName *string `default:"ci-notifications"` ClaimMinIdle *time.Duration `default:"3m"` ClaimMax *int `default:"10"` Enabled *bool `default:"true"` }
Config represents a configuration object with values that can be passed via env variable
type MessageBroker ¶
type MessageBroker struct {
Redis *redis.Client
}
func (*MessageBroker) PublishMessage ¶
func (b *MessageBroker) PublishMessage(p *domain.Property)
Click to show internal directories.
Click to hide internal directories.