broker

Documentation

Index

• Variables
• func Get(key string) ([]byte, error)
• func NewReader(key string) (io.ReadCloser, error)
• func NewWriter(key string) (io.WriteCloser, error)
• func NoContent(rd io.Reader, offset int64) bool
• func ReaderDone(rd io.Reader) bool
• func RenewExpiry(rd io.Reader)
• type RedisRegistrar
  • func NewRedisRegistrar() *RedisRegistrar
  • func (rr *RedisRegistrar) IsRegistered(channelName string) (registered bool)
  • func (rr *RedisRegistrar) Register(channelName string) (err error)
• type Registrar

Variables

var ErrNotRegistered = errors.New("Channel is not registered.")

Functions

func Get

func Get(key string) ([]byte, error)

func NewReader

func NewReader(key string) (io.ReadCloser, error)

func NewWriter

func NewWriter(key string) (io.WriteCloser, error)

func NoContent

func NoContent(rd io.Reader, offset int64) bool

func ReaderDone

func ReaderDone(rd io.Reader) bool

func RenewExpiry

func RenewExpiry(rd io.Reader)

Types

type RedisRegistrar

type RedisRegistrar struct{}

func NewRedisRegistrar

func NewRedisRegistrar() *RedisRegistrar

func (*RedisRegistrar) IsRegistered

func (rr *RedisRegistrar) IsRegistered(channelName string) (registered bool)

func (*RedisRegistrar) Register

func (rr *RedisRegistrar) Register(channelName string) (err error)

type Registrar

type Registrar interface {
	Register(key string) error
	IsRegistered(key string) bool
}