messager

Documentation

Index

• Variables
• type MsgID
  • func ParseMsgID(s string) (*MsgID, error)
  • func (m *MsgID) Add(t time.Duration) *MsgID
  • func (m *MsgID) Gt(v *MsgID) bool
  • func (m *MsgID) String() string
• type RedisMessager
  • func NewRedisMessager(cli *redis.Client, stream string) (*RedisMessager, error)
  • func (r *RedisMessager) Ack(ctx context.Context, msgID string) error
  • func (r *RedisMessager) DupSub(ctx context.Context) (result map[string][]byte, err error)
  • func (r *RedisMessager) Pub(ctx context.Context, data []byte) (msgID string, err error)

Variables

var (
	MsgRetainDur = time.Minute * 10
	ReadBlockDur = time.Second * 1
)

Types

type MsgID

type MsgID struct {
	MsTimestamp int64
	Seq         int64
}

func ParseMsgID

func ParseMsgID(s string) (*MsgID, error)

func (*MsgID) Add

func (m *MsgID) Add(t time.Duration) *MsgID

func (*MsgID) Gt

func (m *MsgID) Gt(v *MsgID) bool

func (*MsgID) String

func (m *MsgID) String() string

type RedisMessager

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

func NewRedisMessager

func NewRedisMessager(cli *redis.Client, stream string) (*RedisMessager, error)

func (*RedisMessager) Ack

func (r *RedisMessager) Ack(ctx context.Context, msgID string) error

func (*RedisMessager) DupSub

func (r *RedisMessager) DupSub(ctx context.Context) (result map[string][]byte, err error)

result: msgID -> data

func (*RedisMessager) Pub

func (r *RedisMessager) Pub(ctx context.Context, data []byte) (msgID string, err error)