broker

Mar 27, 2021

Changes in this version

+ var Defaultopt = Options

+ var ErrUnSupportSerializeProtocol = errors.New("未支持的序列化协议")

+ type AckModeType uint16

+ const AckModeAckWhenDone

+ const AckModeAckWhenGet

+ const AckModeNoAck

+ type Option interface

+ Apply func(*Options)

+ func SerializeWithJSON() Option

+ func SerializeWithMsgpack() Option

+ func WithBlockTime(d time.Duration) Option

+ func WithClientID(clientID uint16) Option

+ func WithStreamComsumerAckMode(ack AckModeType) Option

+ func WithStreamComsumerGroupName(groupname string) Option

+ func WithStreamComsumerRecvBatchSize(size int64) Option

+ func WithStreamComsumerStartAt(t time.Time) Option

+ func WithStreamComsumerStartAtID(id string) Option

+ func WithUUIDSonyflake() Option

+ func WithUUIDv4() Option

+ type Options struct

+ AckMode AckModeType

+ BlockTime time.Duration

+ ClientID uint16

+ Group string

+ RecvBatchSize int64

+ SerializeProtocol string

+ Start string

+ UUIDType string