client

type Client interface {
	// Create a producer instance
	CreateProducer(options ProducerOptions) (Producer, error)

	// Create a consumer instance and subscribe a topic
	Subscribe(options ConsumerOptions) (Consumer, error)

	// Close the client and free associated resources
	Close()
}

type Consumer interface {
	// returns the subscription for the consumer
	Subscription() string

	// returns the topic for the consumer
	Topic() string

	// Signal channel
	MsgMutex() chan struct{}

	// Message channel
	Chan() <-chan mqwrapper.Message

	// Seek to the uniqueID position
	Seek(UniqueID) error //nolint:govet

	// Close consumer
	Close()

	// GetLatestMsgID get the latest msgID
	GetLatestMsgID() (int64, error)

	// check created topic whether vaild or not
	CheckTopicValid(topic string) error
}

type ConsumerOptions struct {
	// The topic that this consumer will subscribe on
	Topic string

	// The subscription name for this consumer
	SubscriptionName string

	// InitialPosition at which the cursor will be set when subscribe
	// Default is `Latest`
	mqwrapper.SubscriptionInitialPosition

	// Message for this consumer
	// When a message is received, it will be pushed to this channel for consumption
	MessageChannel chan mqwrapper.Message
}

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

type Options struct {
	Server RocksMQ
}

type Producer interface {
	// return the topic which producer is publishing to
	Topic() string

	// publish a message
	Send(message *mqwrapper.ProducerMessage) (UniqueID, error)

	// Close a producer
	Close()
}

type ProducerOptions struct {
	Topic string
}

type Result int

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

type RocksMQ = server.RocksMQ

type UniqueID = server.UniqueID