subscriber

Documentation

Index

• type ProcessorFunc
• type RedisConfig
• type RedisSubscriber
  • func NewRedis(conf *RedisConfig) (*RedisSubscriber, error)
  • func (s *RedisSubscriber) Close() error

Types

type ProcessorFunc

type ProcessorFunc func(message []byte)

ProcessorFunc represents a processor function that consume message

type RedisConfig

type RedisConfig struct {
	RedisHost     string
	RedisPassword string
	Channel       string
	Processor     ProcessorFunc
}

RedisConfig represents a configuration for Redis subscriber

type RedisSubscriber

type RedisSubscriber struct {
	// contains filtered or unexported fields
}

RedisSubscriber handles event subscription

func NewRedis

func NewRedis(conf *RedisConfig) (*RedisSubscriber, error)

NewRedis creates a new Redis subscriber

func (*RedisSubscriber) Close

func (s *RedisSubscriber) Close() error

Close closes a subscription