Categorygithub.com/milvus-io/milvus/pkg/v2mqmqimplrocksmqclient
package
2.5.7
Repository: https://github.com/milvus-io/milvus.git
Documentation: pkg.go.dev
Overview
Versions
1
Dependencies
17
Dependents
2
Files
590 SLOC

# Functions

EarliestMessageID is used to get the earliest message ID, default -1.
No description provided by the author
NewClient returns a rocksmq client.
No description provided by the author

# Constants

constant value used in error struct.
constant value used in error struct.
constant value used in error struct.

# Structs

ConsumerOptions is the options of a consumer.
Error is a struct contains error msg and result.
ClientOptions is the options of a client.
ProducerOptions is the options of a producer.
rmqMessage wraps the message for rocksmq.

# Interfaces

Client is the interface rocksmq client.
Consumer interface provide operations for a consumer.
Producer provedes some operations for a producer.

# Type aliases

Result is the type of int and represent error result.
RocksMQ is the type server.RocksMQ.
UniqueID is the type of message ID.