handler

package
v1.1.31 Latest Latest
Warning

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

Go to latest
Published: Dec 21, 2021 License: Apache-2.0 Imports: 3 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ChannelHandler

type ChannelHandler func(c *context.Context, req chan *parcel.RocPacket, exit chan struct{}) chan proto.Message

ChannelHandler for rpc service channel handler

type DogHandler added in v1.1.11

type DogHandler func(c *context.Context) (proto.Message, error)

DogHandler is before socket establish connection to check

type Fire

type Fire func(c *context.Context, req proto.Message) proto.Message

Fire run interceptor action

type Handler

type Handler func(c *context.Context, req *parcel.RocPacket, interrupt Interceptor) (rsp proto.Message, err error)

Handler for rpc service handler

type Interceptor

type Interceptor func(c *context.Context, req proto.Message, fire Fire) (proto.Message, error)

Interceptor for rpc request response interceptor function

type StreamHandler

type StreamHandler func(c *context.Context, req *parcel.RocPacket) chan proto.Message

StreamHandler for rpc service stream handler

type WrapperHandler

type WrapperHandler func(c *context.Context) (proto.Message, error)

WrapperHandler for all rpc function middleware

Jump to

Keyboard shortcuts

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