Documentation ¶
Index ¶
- func AckConsumeInternal(r RpcInterface, req *pb.AckConsumeRequest) (*pb.AckConsumeResponse, error)
- func ConsumeInternal(r RpcInterface, req *pb.ConsumeRequest) (*pb.ConsumeResponse, error)
- func CreateConsumerGroupInternal(r RpcInterface, req *pb.CreateConsumerGroupRequest) (*pb.CreateConsumerGroupResponse, error)
- func CreateTopicInternal(r RpcInterface, req *pb.CreateTopicRequest) (*pb.CreateTopicResponse, error)
- func GetConsumerGroupsInternal(r RpcInterface, req *pb.GetConsumerGroupsRequest) (*pb.GetConsumerGroupsResponse, error)
- func GetMetaInternal(r RpcInterface, req *pb.GetMetaRequest) (*pb.GetMetaResponse, error)
- func PublishMessagesInternal(r RpcInterface, req *pb.PublishMessageRequest) ([]*pb.Message, error)
- type RpcInterface
- func (r RpcInterface) AckConsume(_ context.Context, req *pb.AckConsumeRequest) (*pb.AckConsumeResponse, error)
- func (r RpcInterface) Consume(_ context.Context, req *pb.ConsumeRequest) (*pb.ConsumeResponse, error)
- func (r RpcInterface) CreateConsumerGroup(_ context.Context, req *pb.CreateConsumerGroupRequest) (*pb.CreateConsumerGroupResponse, error)
- func (r RpcInterface) CreateTopic(_ context.Context, req *pb.CreateTopicRequest) (*pb.CreateTopicResponse, error)
- func (r RpcInterface) GetConsumerGroups(_ context.Context, req *pb.GetConsumerGroupsRequest) (*pb.GetConsumerGroupsResponse, error)
- func (r RpcInterface) GetMeta(_ context.Context, req *pb.GetMetaRequest) (*pb.GetMetaResponse, error)
- func (r RpcInterface) PublishMessages(ctx context.Context, req *pb.PublishMessageRequest) (*pb.PublishMessageResponse, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AckConsumeInternal ¶
func AckConsumeInternal(r RpcInterface, req *pb.AckConsumeRequest) (*pb.AckConsumeResponse, error)
func ConsumeInternal ¶
func ConsumeInternal(r RpcInterface, req *pb.ConsumeRequest) (*pb.ConsumeResponse, error)
func CreateConsumerGroupInternal ¶
func CreateConsumerGroupInternal(r RpcInterface, req *pb.CreateConsumerGroupRequest) (*pb.CreateConsumerGroupResponse, error)
func CreateTopicInternal ¶
func CreateTopicInternal(r RpcInterface, req *pb.CreateTopicRequest) (*pb.CreateTopicResponse, error)
func GetConsumerGroupsInternal ¶
func GetConsumerGroupsInternal(r RpcInterface, req *pb.GetConsumerGroupsRequest) (*pb.GetConsumerGroupsResponse, error)
func GetMetaInternal ¶
func GetMetaInternal(r RpcInterface, req *pb.GetMetaRequest) (*pb.GetMetaResponse, error)
func PublishMessagesInternal ¶
func PublishMessagesInternal(r RpcInterface, req *pb.PublishMessageRequest) ([]*pb.Message, error)
Types ¶
type RpcInterface ¶
type RpcInterface struct { NodeState *fsm.NodeState Raft *raft.Raft pb.UnimplementedMessageServiceServer }
func (RpcInterface) AckConsume ¶
func (r RpcInterface) AckConsume(_ context.Context, req *pb.AckConsumeRequest) (*pb.AckConsumeResponse, error)
func (RpcInterface) Consume ¶
func (r RpcInterface) Consume(_ context.Context, req *pb.ConsumeRequest) (*pb.ConsumeResponse, error)
func (RpcInterface) CreateConsumerGroup ¶
func (r RpcInterface) CreateConsumerGroup(_ context.Context, req *pb.CreateConsumerGroupRequest) (*pb.CreateConsumerGroupResponse, error)
func (RpcInterface) CreateTopic ¶
func (r RpcInterface) CreateTopic(_ context.Context, req *pb.CreateTopicRequest) (*pb.CreateTopicResponse, error)
func (RpcInterface) GetConsumerGroups ¶
func (r RpcInterface) GetConsumerGroups(_ context.Context, req *pb.GetConsumerGroupsRequest) (*pb.GetConsumerGroupsResponse, error)
func (RpcInterface) GetMeta ¶
func (r RpcInterface) GetMeta(_ context.Context, req *pb.GetMetaRequest) (*pb.GetMetaResponse, error)
func (RpcInterface) PublishMessages ¶
func (r RpcInterface) PublishMessages(ctx context.Context, req *pb.PublishMessageRequest) (*pb.PublishMessageResponse, error)
Click to show internal directories.
Click to hide internal directories.