topic

Documentation

Index

• func NewDisk() (*disk, error)
• func NewRedis(db goredis.UniversalClient) *redis
• type Ram
  • func NewRam() *Ram
  • func (r *Ram) Close() error
  • func (r *Ram) Init(cids ...string) error
  • func (r *Ram) Print()
  • func (r *Ram) Subscribe(cid string, subs ...*packets.Subscription) (bool, error)
  • func (r *Ram) Unsubscribe(cid string, topics ...string) error
  • func (r *Ram) UnsubscribeAll(cid string) error
• type Store

Functions

func NewDisk

func NewDisk() (*disk, error)

func NewRedis

func NewRedis(db goredis.UniversalClient) *redis

Types

type Ram

type Ram struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewRam

func NewRam() *Ram

func (*Ram) Close

func (r *Ram) Close() error

func (*Ram) Init

func (r *Ram) Init(cids ...string) error

func (*Ram) Print

func (r *Ram) Print()

func (*Ram) Subscribe

func (r *Ram) Subscribe(cid string, subs ...*packets.Subscription) (bool, error)

func (*Ram) Unsubscribe

func (r *Ram) Unsubscribe(cid string, topics ...string) error

func (*Ram) UnsubscribeAll

func (r *Ram) UnsubscribeAll(cid string) error

type Store

type Store interface {
	Init(...string) error
	Subscribe(string, ...*packets.Subscription) (bool, error)
	Unsubscribe(string, ...string) error
	UnsubscribeAll(string) error
	Close() error
}