endpoint

Documentation

Index

• Constants
• func DummyEndpoint(ctx context.Context, req, resp interface{}) (err error)
• type Endpoint
  • func DummyMiddleware(next Endpoint) Endpoint
• type Middleware
  • func Build(mws []Middleware) Middleware
  • func Chain(mws ...Middleware) Middleware
• type MiddlewareBuilder
• type RecvEndpoint
• type RecvMiddleware
  • func RecvChain(mws ...RecvMiddleware) RecvMiddleware
• type RecvMiddlewareBuilder
• type SendEndpoint
• type SendMiddleware
  • func SendChain(mws ...SendMiddleware) SendMiddleware
• type SendMiddlewareBuilder

Constants

const (
	CtxEventBusKey mwCtxKeyType = iota
	CtxEventQueueKey
)

Keys for components attached to the context for a middleware builder.

Functions

func DummyEndpoint

func DummyEndpoint(ctx context.Context, req, resp interface{}) (err error)

DummyEndpoint is a dummy endpoint.

Types

type Endpoint

type Endpoint func(ctx context.Context, req, resp interface{}) (err error)

Endpoint represent one method for calling from remote.

func DummyMiddleware

func DummyMiddleware(next Endpoint) Endpoint

DummyMiddleware is a dummy middleware.

type Middleware

type Middleware func(Endpoint) Endpoint

Middleware deal with input Endpoint and output Endpoint.

func Build

func Build(mws []Middleware) Middleware

Build builds the given middlewares into one middleware.

func Chain

func Chain(mws ...Middleware) Middleware

Chain connect middlewares into one middleware.

type MiddlewareBuilder

type MiddlewareBuilder func(ctx context.Context) Middleware

MiddlewareBuilder builds a middleware with information from a context.

type RecvEndpoint

type RecvEndpoint func(stream streaming.Stream, message interface{}) (err error)

RecvEndpoint represent one Recv call

type RecvMiddleware

type RecvMiddleware func(next RecvEndpoint) RecvEndpoint

RecvMiddleware deal with input Endpoint and output Endpoint.

func RecvChain

func RecvChain(mws ...RecvMiddleware) RecvMiddleware

RecvChain connect middlewares into one middleware.

type RecvMiddlewareBuilder

type RecvMiddlewareBuilder func(ctx context.Context) RecvMiddleware

RecvMiddlewareBuilder builds a middleware with information from a context.

type SendEndpoint

type SendEndpoint func(stream streaming.Stream, message interface{}) (err error)

SendEndpoint represent one Send call

type SendMiddleware

type SendMiddleware func(next SendEndpoint) SendEndpoint

SendMiddleware deal with input Endpoint and output Endpoint.

func SendChain

func SendChain(mws ...SendMiddleware) SendMiddleware

SendChain connect middlewares into one middleware.

type SendMiddlewareBuilder

type SendMiddlewareBuilder func(ctx context.Context) SendMiddleware

SendMiddlewareBuilder builds a middleware with information from a context.