redis

Documentation

Index

• func NewMsgBus(client *redis.Client) xmsgbus.IMsgBus
• func NewSharedStorage(client *redis.Client) 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, 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 SharedStorage
  • func (x *SharedStorage) Del(ctx context.Context, key string) error
  • func (x *SharedStorage) Keys(ctx context.Context, prefix string) ([]string, error)
  • func (x *SharedStorage) SetEx(ctx context.Context, key string, value interface{}, ttl time.Duration) error

Functions

func NewMsgBus

func NewMsgBus(client *redis.Client) xmsgbus.IMsgBus

func NewSharedStorage

func NewSharedStorage(client *redis.Client) 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, 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 SharedStorage

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

func (*SharedStorage) Del

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

func (*SharedStorage) Keys

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

func (*SharedStorage) SetEx

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