inmem

Documentation

Index

• Constants
• func New(tree config.Tree) (pubsub.PubSub, error)
• type Config
• type Inmem
  • func (ps *Inmem) Close() error
  • func (ps *Inmem) Drain()
  • func (ps *Inmem) Publish(ctx context.Context, ch string, data []byte) error
  • func (ps *Inmem) Start(ctx context.Context) error
  • func (ps *Inmem) Subscribe(q, ch string, h pubsub.MsgHandler) error

Constants

const (
	Name = "inmem"
)

Functions

func New

func New(tree config.Tree) (pubsub.PubSub, error)

Types

type Config

type Config struct {
	Buffer int `toml:"buffer"`
}

type Inmem

type Inmem struct {
	Config Config
	// contains filtered or unexported fields
}

func (*Inmem) Close

func (ps *Inmem) Close() error

func (*Inmem) Drain

func (ps *Inmem) Drain()

func (*Inmem) Publish

func (ps *Inmem) Publish(
	ctx context.Context,
	ch string,
	data []byte,
) error

func (*Inmem) Start

func (ps *Inmem) Start(ctx context.Context) error

func (*Inmem) Subscribe

func (ps *Inmem) Subscribe(q, ch string, h pubsub.MsgHandler) error