contextutil

Documentation

Index

• func GetCreateConsumer(ctx context.Context) (*streamingpb.CreateConsumerRequest, error)
• func GetCreateProducer(ctx context.Context) (*streamingpb.CreateProducerRequest, error)
• func GetPickServerID(ctx context.Context) (int64, bool)
• 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

Functions

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

func GetPickServerID(ctx context.Context) (int64, bool)

GetPickServerID must get the pick result from context. panic otherwise.

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.

func WithPickServerID

func WithPickServerID(ctx context.Context, serverID int64) context.Context

WithPickServerID returns a new context with the pick result.