Documentation
¶
Index ¶
- func GetClusterID(ctx context.Context) (string, error)
- func GetCreateConsumer(ctx context.Context) (*streamingpb.CreateConsumerRequest, error)
- func GetCreateProducer(ctx context.Context) (*streamingpb.CreateProducerRequest, error)
- func GetPickServerID(ctx context.Context) (int64, bool)
- func WithClusterID(ctx context.Context, clusterID string) context.Context
- func WithCreateConsumer(ctx context.Context, req *streamingpb.CreateConsumerRequest) context.Context
- func WithCreateProducer(ctx context.Context, req *streamingpb.CreateProducerRequest) context.Context
- func WithPickServerID(ctx context.Context, serverID int64) context.Context
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetClusterID ¶
GetClusterID gets cluster id from context.
func GetCreateConsumer ¶
func GetCreateConsumer(ctx context.Context) (*streamingpb.CreateConsumerRequest, error)
GetCreateConsumer gets create consumer request from context.
func GetCreateProducer ¶
func GetCreateProducer(ctx context.Context) (*streamingpb.CreateProducerRequest, error)
GetCreateProducer gets create producer request from context.
func GetPickServerID ¶
GetPickServerID must get the pick result from context. panic otherwise.
func WithClusterID ¶
WithClusterID attaches cluster id to context.
func WithCreateConsumer ¶
func WithCreateConsumer(ctx context.Context, req *streamingpb.CreateConsumerRequest) context.Context
WithCreateConsumer attaches create consumer request to context.
func WithCreateProducer ¶
func WithCreateProducer(ctx context.Context, req *streamingpb.CreateProducerRequest) context.Context
WithCreateProducer attaches create producer request to context.
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.