inmem

Documentation

Index

• Constants
• func New(tree config.Tree) (stream.Stream, 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 stream.MsgHandler, opts ...stream.SubscriptionOption) (stream.Subscription, error)

Constants

const (
	Name = "inmem"
)

Functions

func New

func New(tree config.Tree) (stream.Stream, 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 stream.MsgHandler, opts ...stream.SubscriptionOption,
) (stream.Subscription, error)