pubsubfactory

Documentation

Index

• func NewFromConfig(cfg *Config) (pubsub.PubSub, error)
• func NewFromString(text string) (pubsub.PubSub, error)
• type Config
  • func ParseConfig(text string) (*Config, error)
• type InMemConfig
• type RedisConfig

Functions

func NewFromConfig

func NewFromConfig(cfg *Config) (pubsub.PubSub, error)

func NewFromString

func NewFromString(text string) (pubsub.PubSub, error)

Types

type Config

type Config struct {
	Type string `envconfig:"TYPE" json:"type"`

	InMem InMemConfig `envconfig:"INMEM" json:"inmem"`
	Redis RedisConfig `envconfig:"REDIS" json:"redis"`
}

func ParseConfig

func ParseConfig(text string) (*Config, error)

type InMemConfig

type InMemConfig struct {
	QueueSize int `envconfig:"QUEUE_SIZE" json:"queue_size"`
}

type RedisConfig

type RedisConfig struct {
	Address string `envconfig:"ADDRESS" default:"127.0.0.1:6379" json:"address"`
}