client

type ConfirmResult struct {
	TopicName      string
	ConfirmContext string
	PeerInfo       *PeerInfo
}

type Consumer interface {
	// GetMessage receive a single message.
	GetMessage() (*ConsumerResult, error)
	// Confirm the consumption of a message.
	Confirm(confirmContext string, consumed bool) (*ConfirmResult, error)
	// GetCurrConsumedInfo returns the consumptions of the consumer.
	GetCurrConsumedInfo() map[string]*remote.ConsumerOffset
	// Close closes the consumer client and release the resources.
	Close()
	// GetClientID returns the clientID of the consumer.
	GetClientID() string
}

type ConsumerResult struct {
	TopicName      string
	ConfirmContext string
	PeerInfo       *PeerInfo
	Messages       []*Message
}

type Message struct {
	Topic      string
	Data       []byte
	DataLen    int32
	ID         int64
	Flag       int32
	Properties map[string]string
}

type PeerInfo struct {
	PartitionID  uint32
	BrokerHost   string
	PartitionKey string
	CurrOffset   int64
	MaxOffset    int64
}

type Producer interface {
	Publish(topics []string)

	SendMessage(message *Message) (bool, int32, string)
}

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