Documentation
¶
Overview ¶
Package sep means server 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.ServerStream) (err error)
StreamEndpoint represent one Stream call, it provides a stream to server handler.
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 stream middlewares into one stream 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.ServerStream, message interface{}) (err error)
StreamRecvEndpoint represent one Stream recv call.
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 stream recv middlewares into one stream recv 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.ServerStream, message interface{}) (err error)
StreamSendEndpoint represent one Stream send call.
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 stream send middlewares into one stream send middleware.
type StreamSendMiddlewareBuilder ¶
type StreamSendMiddlewareBuilder func(ctx context.Context) StreamSendMiddleware
StreamSendMiddlewareBuilder builds a stream send middleware with information from a context.
Source Files