endpoint

package
v0.15.4 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 26, 2025 License: Apache-2.0 Imports: 2 Imported by: 177

Documentation

Index

Constants

View Source
const (
	CtxEventBusKey mwCtxKeyType = iota
	CtxEventQueueKey
)

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

Variables

This section is empty.

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(next 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.

func (Middleware) ToUnaryMiddleware added in v0.13.0

func (mw Middleware) ToUnaryMiddleware() UnaryMiddleware

type MiddlewareBuilder

type MiddlewareBuilder func(ctx context.Context) Middleware

MiddlewareBuilder builds a middleware with information from a context.

type RecvEndpoint added in v0.9.0

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

Deprecated, use client.StreamRecvEndpoint or server.StreamRecvEndpoint instead.

type RecvMiddleware added in v0.9.0

type RecvMiddleware func(next RecvEndpoint) RecvEndpoint

Deprecated, use client.StreamRecvMiddleware or server.StreamRecvMiddleware instead.

func RecvChain added in v0.9.0

func RecvChain(mws ...RecvMiddleware) RecvMiddleware

Deprecated, use client.StreamRecvChain or server.StreamRecvChain instead.

type RecvMiddlewareBuilder added in v0.9.0

type RecvMiddlewareBuilder func(ctx context.Context) RecvMiddleware

Deprecated, use client.StreamRecvMiddlewareBuilder or server.StreamRecvMiddlewareBuilder instead.

type SendEndpoint added in v0.9.0

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

Deprecated, use client.StreamSendEndpoint or server.StreamSendEndpoint instead.

type SendMiddleware added in v0.9.0

type SendMiddleware func(next SendEndpoint) SendEndpoint

Deprecated, use client.StreamSendMiddleware or server.StreamSendMiddleware instead.

func SendChain added in v0.9.0

func SendChain(mws ...SendMiddleware) SendMiddleware

Deprecated, use client.StreamSendChain or server.StreamSendChain instead.

type SendMiddlewareBuilder added in v0.9.0

type SendMiddlewareBuilder func(ctx context.Context) SendMiddleware

Deprecated, use client.StreamSendMiddlewareBuilder or server.StreamSendMiddlewareBuilder instead.

type UnaryEndpoint added in v0.13.0

type UnaryEndpoint Endpoint

type UnaryMiddleware added in v0.13.0

type UnaryMiddleware func(next UnaryEndpoint) UnaryEndpoint

func UnaryChain added in v0.13.0

func UnaryChain(mws ...UnaryMiddleware) UnaryMiddleware

func (UnaryMiddleware) ToMiddleware added in v0.13.0

func (mw UnaryMiddleware) ToMiddleware() Middleware

type UnaryMiddlewareBuilder added in v0.13.0

type UnaryMiddlewareBuilder func(ctx context.Context) UnaryMiddleware

Directories

Path Synopsis
Package cep means client endpoint in short.
Package cep means client endpoint in short.
Package sep means server endpoint in short.
Package sep means server endpoint in short.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL