router

Documentation

Index

• type CommandHandler
• type Router
  • func New(svr *streams.StreamManger) *Router
  • func (r *Router) AddStatic(command string, handler CommandHandler, stream StreamHandler) error
  • func (r *Router) Handle(s streams.Stream)
• type StreamHandler

Types

type CommandHandler

type CommandHandler func(context.Context, streams.Connection, command.Body) (cr.Response, error)

type Router

type Router struct {
	// contains filtered or unexported fields
}

func New

func New(svr *streams.StreamManger) *Router

func (*Router) AddStatic

func (r *Router) AddStatic(command string, handler CommandHandler, stream StreamHandler) error

func (*Router) Handle

func (r *Router) Handle(s streams.Stream)

type StreamHandler

type StreamHandler func(context.Context, io.ReadWriter)