prioritymq

type Level int64

type Logger interface {
	Printf(string, ...interface{})
}

type LoggerFunc func(string, ...interface{})

type MQ interface {
	// Publish 发送消息
	Publish(ctx context.Context, topic string, msg []byte, opts ...PubOption) error

	// Subscribe 消费消息
	Subscribe(ctx context.Context, topics []string, channel string, subHandler SubHandler, opts ...SubOption) error

	// Shutdown 平滑退出
	Shutdown(ctx context.Context) error
}

type PubOption func(p *PublishOptions)

type PublishOptions struct {
	Key string
}

type SubHandler func(ctx context.Context, msg []byte) error

type SubOption func(s *SubscribeOptions)

type SubscribeOptions struct {
	// specifies the consumer name
	// for kafka name eq group_id
	Name string

	// priority consumer buffer size
	BufferSize int

	// Commit the offset to the backend for kafka
	// Note: calling Commit performs a blocking synchronous operation.
	CommitOffsetBlock bool
}