handler

Documentation

Index

• type Services
  • func NewServices(lo interfaces.Listener) *Services
  • func (c *Services) AllowMethod(method string) (m []interfaces.Method)
  • func (c *Services) CurrentStatus(ctx context.Context, req *proto.MonitorRequest) (res *proto.MonitorResponse, err error)
  • func (c *Services) GetServiceDesc() []*grpc.ServiceDesc
  • func (c *Services) ListServices(ctx context.Context, req *emptypb.Empty) (res *proto.ServicesResponse, err error)
  • func (c *Services) Monitor(req *proto.MonitorRequest, serv proto.Listener_MonitorServer) (err error)

Types

type Services

type Services struct {
	proto.UnimplementedListenerServer
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewServices

func NewServices(lo interfaces.Listener) *Services

func (*Services) AllowMethod

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

func (*Services) CurrentStatus

func (c *Services) CurrentStatus(ctx context.Context, req *proto.MonitorRequest) (res *proto.MonitorResponse, err error)

CurrentStatus implement services.Listener/CurrentStatus

func (*Services) GetServiceDesc

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

func (*Services) ListServices

func (c *Services) ListServices(ctx context.Context, req *emptypb.Empty) (res *proto.ServicesResponse, err error)

ListServices implement services.Listener/ListServices

func (*Services) Monitor

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

Monitor implement services.Listener/Monitor