mmq

Documentation

Index

• type AckHandler
• type QCloser
• type QDelete
• type QReader
• type QWriter
• type QueueModel

Types

type AckHandler

type AckHandler interface {
	Ack(ctx context.Context) error
}

AckHandler 统一为 AckHandler

type QCloser

type QCloser interface {
	Close(ctx context.Context) error
}

type QDelete

type QDelete interface {
	Del(ctx context.Context, topic, msgID string) error
}

type QReader

type QReader interface {
	QCloser
	// ReadMsgByGroup 读完消息后会自动提交offset
	ReadMsgByGroup(ctx context.Context, topic, groupID string, value interface{}) (context.Context, error)
	// ReadMsgByPartition ...
	ReadMsgByPartition(ctx context.Context, topic string, partition int, value interface{}) (context.Context, error)
	// FetchMsgByGroup 读完消息后不会自动提交offset,需要手动调用Handle.CommitMsg方法来提交offset
	FetchMsgByGroup(ctx context.Context, topic, groupID string, value interface{}) (context.Context, AckHandler, error)
}

type QWriter

type QWriter interface {
	QCloser

	// WriteMsg 写入消息
	WriteMsg(ctx context.Context, topic string, key string, val interface{}) (jobID string, err error)
}

type QueueModel

type QueueModel interface {
	QWriter
	QReader

	QDelete
}