memory

Documentation

Index

• func NewMsgBus() xmsgbus.IMsgBus
• func NewStorage() xmsgbus.ISharedStorage
• type MsgBus
  • func (x *MsgBus) AddChannel(ctx context.Context, topic string, channel string) error
  • func (x *MsgBus) ListChannel(ctx context.Context, topic string) ([]string, error)
  • func (x *MsgBus) Pop(ctx context.Context, topic, channel string, blockTimeout time.Duration) ([]byte, func(), error)
  • func (x *MsgBus) Push(ctx context.Context, topic string, bs []byte) error
  • func (x *MsgBus) RemoveChannel(ctx context.Context, topic string, channel string) error
• type Storage
  • func (x *Storage) Del(ctx context.Context, key string) error
  • func (x *Storage) Keys(ctx context.Context, prefix string) ([]string, error)
  • func (x *Storage) SetEx(ctx context.Context, key string, value interface{}, ttl time.Duration) error

Functions

func NewMsgBus

func NewMsgBus() xmsgbus.IMsgBus

func NewStorage

func NewStorage() xmsgbus.ISharedStorage

Types

type MsgBus

type MsgBus struct {
	// contains filtered or unexported fields
}

func (*MsgBus) AddChannel

func (x *MsgBus) AddChannel(ctx context.Context, topic string, channel string) error

func (*MsgBus) ListChannel

func (x *MsgBus) ListChannel(ctx context.Context, topic string) ([]string, error)

func (*MsgBus) Pop

func (x *MsgBus) Pop(ctx context.Context, topic, channel string, blockTimeout time.Duration) ([]byte, func(), error)

func (*MsgBus) Push

func (x *MsgBus) Push(ctx context.Context, topic string, bs []byte) error

func (*MsgBus) RemoveChannel

func (x *MsgBus) RemoveChannel(ctx context.Context, topic string, channel string) error

type Storage

type Storage struct {
	// contains filtered or unexported fields
}

func (*Storage) Del

func (x *Storage) Del(ctx context.Context, key string) error

func (*Storage) Keys

func (x *Storage) Keys(ctx context.Context, prefix string) ([]string, error)

func (*Storage) SetEx

func (x *Storage) SetEx(ctx context.Context, key string, value interface{}, ttl time.Duration) error