stream

Documentation

Index

• type StreamEventHandler
• type StreamingConfig
  • func (c *StreamingConfig) BuildRecvInvokeChain(ep endpoint.RecvEndpoint) endpoint.RecvEndpoint
  • func (c *StreamingConfig) BuildSendInvokeChain(ep endpoint.SendEndpoint) endpoint.SendEndpoint
  • func (c *StreamingConfig) InitMiddlewares(ctx context.Context)

Types

type StreamEventHandler

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

StreamEventHandler is used to handle stream events

type StreamingConfig

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

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

	EventHandler StreamEventHandler
}

func (*StreamingConfig) BuildRecvInvokeChain

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

func (*StreamingConfig) BuildSendInvokeChain

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

func (*StreamingConfig) InitMiddlewares

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