handler

Documentation

Index

• type Services
  • func NewServices(lo interfaces.Listener, onPushMessage interfaces.OnPushMessage) *Services
  • func (c *Services) AllowMethod(method string) (m []interfaces.Method)
  • func (c *Services) Forward(serv global.Router_ForwardServer) error
  • func (c *Services) GetServiceDesc() []*grpc.ServiceDesc
  • func (c *Services) Monitor(req *listener.MonitorRequest, serv listener.Listener_MonitorServer) error
  • func (c *Services) Services(ctx context.Context, req *global.NoParameter) (res *listener.ServicesResponse, err error)

Types

type Services

type Services struct {
	global.UnimplementedRouterServer
	listener.UnimplementedListenerServer
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewServices

func NewServices(lo interfaces.Listener,
	onPushMessage interfaces.OnPushMessage) *Services

func (*Services) AllowMethod

func (c *Services) AllowMethod(method string) (m []interfaces.Method)

func (*Services) Forward

func (c *Services) Forward(serv global.Router_ForwardServer) error

implement global.Router/Forward

func (*Services) GetServiceDesc

func (c *Services) GetServiceDesc() []*grpc.ServiceDesc

func (*Services) Monitor

func (c *Services) Monitor(req *listener.MonitorRequest, serv listener.Listener_MonitorServer) error

implement listener.Listener/Monitor

func (*Services) Services

func (c *Services) Services(ctx context.Context, req *global.NoParameter) (res *listener.ServicesResponse, err error)

implement listener.Listener/Services