message

Documentation

Index

• Variables
• func Create(e *proto.Event) error
• func Delete(id, ns, ch string) error
• func Init(br broker.Broker, k data.Data, lk lock.Lock)
• func Read(id, ns, ch string) (*proto.Event, error)
• func Search(q, ns, ch string, limit, offset int, reverse bool) ([]*proto.Event, error)
• func Stream(ns, ch string) (chan *proto.Event, chan bool, error)
• func Update(e *proto.Event) error

Variables

var (
	Default *memory

	ErrAlreadyExists = errors.New("already exists")
	ErrNotFound      = errors.New("not found")
)

Functions

func Create

func Create(e *proto.Event) error

func Delete

func Delete(id, ns, ch string) error

func Init

func Init(br broker.Broker, k data.Data, lk lock.Lock)

func Read

func Read(id, ns, ch string) (*proto.Event, error)

func Search

func Search(q, ns, ch string, limit, offset int, reverse bool) ([]*proto.Event, error)

func Stream

func Stream(ns, ch string) (chan *proto.Event, chan bool, error)

func Update

func Update(e *proto.Event) error