trans

Documentation

Index

• type BoundHandler
• type Option
  • func AddInboundMiddleware(inbound ...less.Middleware) Option
  • func AddOnChannel(onChannel ...less.OnChannel) Option
  • func AddOnChannelClosed(onChannelClosed ...less.OnChannelClosed) Option
  • func AddOutboundMiddleware(outbound ...less.Middleware) Option
  • func Keepalive(kp keepalive.ServerParameters) Option
  • func MaxChannelSize(size uint32) Option
  • func MaxReceiveMessageSize(size uint32) Option
  • func MaxSendMessageSize(size uint32) Option
  • func WithPacketCodec(codec codec.PacketCodec) Option
  • func WithPayloadCodec(codec codec.PayloadCodec) Option
  • func WithRouter(router router.Router) Option
• type TransHandler
  • func NewTransHandler(ops ...Option) TransHandler

Types

type BoundHandler

type BoundHandler interface {
	OnRead(ch *channel.Channel, reader io.Reader) (err error)
	OnWrite(ch *channel.Channel, writer io.Writer, msg interface{}) error
}

type Option

type Option func(ops *options)

func AddInboundMiddleware

func AddInboundMiddleware(inbound ...less.Middleware) Option

func AddOnChannel

func AddOnChannel(onChannel ...less.OnChannel) Option

func AddOnChannelClosed

func AddOnChannelClosed(onChannelClosed ...less.OnChannelClosed) Option

func AddOutboundMiddleware

func AddOutboundMiddleware(outbound ...less.Middleware) Option

func Keepalive

func Keepalive(kp keepalive.ServerParameters) Option

func MaxChannelSize

func MaxChannelSize(size uint32) Option

func MaxReceiveMessageSize

func MaxReceiveMessageSize(size uint32) Option

func MaxSendMessageSize

func MaxSendMessageSize(size uint32) Option

func WithPacketCodec

func WithPacketCodec(codec codec.PacketCodec) Option

func WithPayloadCodec

func WithPayloadCodec(codec codec.PayloadCodec) Option

func WithRouter

func WithRouter(router router.Router) Option

type TransHandler

type TransHandler interface {
	transport.EventDriver
	BoundHandler
	transport.GracefulCloser
}

func NewTransHandler

func NewTransHandler(ops ...Option) TransHandler