stream

type CancelableClientStream ¶ added in v0.16.0

type CancelableClientStream interface {
	CancelWithErr(err error)
}

CancelableClientStream is implemented by client-side Stream of gRPC in transport layer. It terminates the local stream's lifecycle and cancels the remote peer.

type StreamEventHandler ¶

type StreamEventHandler = func(ctx context.Context, evt stats.Event, err error)

StreamEventHandler is used to handle stream events Deprecated: using HandleStreamRecvEvent/HandleStreamSendEvent in pkg/rpcinfo/ClientStreamEventHandler or pkg/rpcinfo/ServerStreamEventHandler directly

type StreamingConfig ¶

type StreamingConfig struct {
	RecvMiddlewareBuilders []endpoint.RecvMiddlewareBuilder
	RecvMiddlewares        []endpoint.RecvMiddleware

	SendMiddlewareBuilders []endpoint.SendMiddlewareBuilder
	SendMiddlewares        []endpoint.SendMiddleware
}

func (c *StreamingConfig) BuildRecvInvokeChain() endpoint.RecvEndpoint

func (c *StreamingConfig) BuildSendInvokeChain() endpoint.SendEndpoint

func (c *StreamingConfig) InitMiddlewares(ctx context.Context)