redis

Documentation

Index

• type Eventbus
  • func NewEventbus(opts ...Option) *Eventbus
  • func (eb *Eventbus) Close() error
  • func (eb *Eventbus) Publish(ctx context.Context, topic string, payload interface{}) error
  • func (eb *Eventbus) Subscribe(ctx context.Context, topic string, handler eventbus.EventHandler) error
  • func (eb *Eventbus) Unsubscribe(ctx context.Context, topic string, handler eventbus.EventHandler) error
• type Option
  • func WithAddrs(addrs ...string) Option
  • func WithClient(client redis.UniversalClient) Option
  • func WithContext(ctx context.Context) Option
  • func WithDB(db int) Option
  • func WithMaxRetries(maxRetries int) Option
  • func WithPassword(password string) Option
  • func WithPrefix(prefix string) Option
  • func WithUsername(username string) Option

Types

type Eventbus

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

func NewEventbus

func NewEventbus(opts ...Option) *Eventbus

func (*Eventbus) Close

func (eb *Eventbus) Close() error

Close 停止监听

func (*Eventbus) Publish

func (eb *Eventbus) Publish(ctx context.Context, topic string, payload interface{}) error

Publish 发布事件

func (*Eventbus) Subscribe

func (eb *Eventbus) Subscribe(ctx context.Context, topic string, handler eventbus.EventHandler) error

Subscribe 订阅事件

func (*Eventbus) Unsubscribe

func (eb *Eventbus) Unsubscribe(ctx context.Context, topic string, handler eventbus.EventHandler) error

Unsubscribe 取消订阅

type Option

type Option func(o *options)

func WithAddrs

func WithAddrs(addrs ...string) Option

WithAddrs 设置连接地址

func WithClient

func WithClient(client redis.UniversalClient) Option

WithClient 设置外部客户端

func WithContext

func WithContext(ctx context.Context) Option

WithContext 设置上下文

func WithDB

func WithDB(db int) Option

WithDB 设置数据库号

func WithMaxRetries

func WithMaxRetries(maxRetries int) Option

WithMaxRetries 设置最大重试次数

func WithPassword

func WithPassword(password string) Option

WithPassword 设置密码

func WithPrefix

func WithPrefix(prefix string) Option

WithPrefix 设置前缀

func WithUsername

func WithUsername(username string) Option

WithUsername 设置用户名