router

Documentation

Index

• type Router
  • func NewRouter(wrappers []parcel.Wrapper, err parcel.ErrorPackager, c codec.Codec) *Router
  • func (r *Router) Codec() codec.Codec
  • func (r *Router) Error() parcel.ErrorPackager
  • func (r *Router) List()
  • func (r *Router) RCProcess(c *context.Context, req chan *parcel.RocPacket, errs chan error) (chan proto.Message, chan error)
  • func (r *Router) RRProcess(c *context.Context, req *parcel.RocPacket, rsp *parcel.RocPacket) error
  • func (r *Router) RSProcess(c *context.Context, req *parcel.RocPacket) (chan proto.Message, chan error)
  • func (r *Router) RegisterChannelHandler(service string, rc parcel.ChannelHandler)
  • func (r *Router) RegisterHandler(method string, rr parcel.Handler)
  • func (r *Router) RegisterStreamHandler(method string, rs parcel.StreamHandler)

Types

type Router

type Router struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewRouter

func NewRouter(wrappers []parcel.Wrapper, err parcel.ErrorPackager, c codec.Codec) *Router

NewRouter create a new router

func (*Router) Codec

func (r *Router) Codec() codec.Codec

func (*Router) Error

func (r *Router) Error() parcel.ErrorPackager

func (*Router) List

func (r *Router) List()

func (*Router) RCProcess

func (r *Router) RCProcess(c *context.Context, req chan *parcel.RocPacket, errs chan error) (chan proto.Message, chan error)

func (*Router) RRProcess

func (r *Router) RRProcess(c *context.Context, req *parcel.RocPacket, rsp *parcel.RocPacket) error

func (*Router) RSProcess

func (r *Router) RSProcess(c *context.Context, req *parcel.RocPacket) (chan proto.Message, chan error)

func (*Router) RegisterChannelHandler

func (r *Router) RegisterChannelHandler(service string, rc parcel.ChannelHandler)

func (*Router) RegisterHandler

func (r *Router) RegisterHandler(method string, rr parcel.Handler)

func (*Router) RegisterStreamHandler

func (r *Router) RegisterStreamHandler(method string, rs parcel.StreamHandler)