Documentation
¶
Overview ¶
Package cep means client endpoint in short.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type StreamEndpoint ¶
type StreamEndpoint func(ctx context.Context) (st streaming.ClientStream, err error)
StreamEndpoint represent one Stream call, it returns a stream.
func DummyDummyMiddleware ¶
func DummyDummyMiddleware(next StreamEndpoint) StreamEndpoint
DummyDummyMiddleware is a dummy middleware.
type StreamMiddleware ¶
type StreamMiddleware func(next StreamEndpoint) StreamEndpoint
StreamMiddleware deal with input StreamEndpoint and output StreamEndpoint.
func StreamChain ¶
func StreamChain(mws ...StreamMiddleware) StreamMiddleware
StreamChain connect middlewares into one middleware.
type StreamMiddlewareBuilder ¶
type StreamMiddlewareBuilder func(ctx context.Context) StreamMiddleware
StreamMiddlewareBuilder builds a stream middleware with information from a context.
type StreamRecvEndpoint ¶
type StreamRecvEndpoint func(ctx context.Context, stream streaming.ClientStream, message interface{}) (err error)
StreamRecvEndpoint represent one Stream Recv call, the inner endpoint will call stream.RecvMsg(ctx, message).
func (StreamRecvEndpoint) EqualsTo ¶
func (e StreamRecvEndpoint) EqualsTo(e2 StreamRecvEndpoint) bool
type StreamRecvMiddleware ¶
type StreamRecvMiddleware func(next StreamRecvEndpoint) StreamRecvEndpoint
StreamRecvMiddleware deal with input StreamRecvEndpoint and output StreamRecvEndpoint.
func StreamRecvChain ¶
func StreamRecvChain(mws ...StreamRecvMiddleware) StreamRecvMiddleware
StreamRecvChain connect recv middlewares into one middleware.
type StreamRecvMiddlewareBuilder ¶
type StreamRecvMiddlewareBuilder func(ctx context.Context) StreamRecvMiddleware
StreamRecvMiddlewareBuilder builds a stream recv middleware with information from a context.
type StreamSendEndpoint ¶
type StreamSendEndpoint func(ctx context.Context, stream streaming.ClientStream, message interface{}) (err error)
StreamSendEndpoint represent one Stream Send call.
func (StreamSendEndpoint) EqualsTo ¶
func (e StreamSendEndpoint) EqualsTo(e2 StreamSendEndpoint) bool
type StreamSendMiddleware ¶
type StreamSendMiddleware func(next StreamSendEndpoint) StreamSendEndpoint
StreamSendMiddleware deal with input StreamSendEndpoint and output StreamSendEndpoint.
func StreamSendChain ¶
func StreamSendChain(mws ...StreamSendMiddleware) StreamSendMiddleware
StreamSendChain connect send middlewares into one middleware.
type StreamSendMiddlewareBuilder ¶
type StreamSendMiddlewareBuilder func(ctx context.Context) StreamSendMiddleware
StreamSendMiddlewareBuilder builds a stream send middleware with information from a context.
Source Files