redisstream

Documentation

Index

• Constants
• func Publish(ctx context.Context, name, topic string, msg []byte) (msgID string, err error)
• func RegisterHandler(name, topic string, handler MsgHandler)
• type MsgHandler

Constants

const (
	StreamMaxLen = 10000           // stream最大长度
	BlockTime    = time.Minute     // 阻塞读取时间
	ErrWaitTime  = time.Second * 3 // 请求错误后的重试时间
)

const (
	RedisStreamPubName = "redis_stream"
)

const (
	RedisStreamSubName = "redis_stream"
)

Functions

func Publish

func Publish(ctx context.Context, name, topic string, msg []byte) (msgID string, err error)

func RegisterHandler

func RegisterHandler(name, topic string, handler MsgHandler)

Types

type MsgHandler

type MsgHandler func(ctx context.Context, data []byte) error