pool

Documentation

Index

• type Manager
  • func NewManager(messageChan chan message) *Manager
  • func (manager *Manager) Manage()
• type Pool
  • func New() *Pool
  • func (pool *Pool) Publish(redisURI, redisQueueName string, data []byte)

Types

type Manager

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

Manager manages different redis connections

func NewManager

func NewManager(messageChan chan message) *Manager

NewManager constructs a new Manager

func (*Manager) Manage

func (manager *Manager) Manage()

Manage tells the manager to manage. I'm a people person

type Pool

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

Pool is a redis connection pool

func New

func New() *Pool

New constructs a new Pool

func (*Pool) Publish

func (pool *Pool) Publish(redisURI, redisQueueName string, data []byte)

Publish publishes to redis