redis

Documentation

Index

• type RedisPubSubAdapter
  • func NewRedisPubSubAdapter(addr string) (*RedisPubSubAdapter, error)
  • func (r *RedisPubSubAdapter) PollMessages(topic string, handler func(message string)) error
  • func (r *RedisPubSubAdapter) Publish(topicARN string, message interface{}, messageAttributes map[string]interface{}) error

Types

type RedisPubSubAdapter

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

func NewRedisPubSubAdapter

func NewRedisPubSubAdapter(addr string) (*RedisPubSubAdapter, error)

func (*RedisPubSubAdapter) PollMessages

func (r *RedisPubSubAdapter) PollMessages(topic string, handler func(message string)) error

func (*RedisPubSubAdapter) Publish

func (r *RedisPubSubAdapter) Publish(topicARN string, message interface{}, messageAttributes map[string]interface{}) error