go_micro_monitor

Documentation

Index

• func RegisterMonitorHandler(s server.Server, hdlr MonitorHandler, opts ...server.HandlerOption) error
• func RegisterMonitorServer(s *grpc.Server, srv MonitorServer)
• type CheckRequest
  • func (*CheckRequest) Descriptor() ([]byte, []int)
  • func (m *CheckRequest) GetService() string
  • func (*CheckRequest) ProtoMessage()
  • func (m *CheckRequest) Reset()
  • func (m *CheckRequest) String() string
  • func (m *CheckRequest) XXX_DiscardUnknown()
  • func (m *CheckRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *CheckRequest) XXX_Merge(src proto.Message)
  • func (m *CheckRequest) XXX_Size() int
  • func (m *CheckRequest) XXX_Unmarshal(b []byte) error
• type CheckResponse
  • func (*CheckResponse) Descriptor() ([]byte, []int)
  • func (m *CheckResponse) GetStatus() string
  • func (*CheckResponse) ProtoMessage()
  • func (m *CheckResponse) Reset()
  • func (m *CheckResponse) String() string
  • func (m *CheckResponse) XXX_DiscardUnknown()
  • func (m *CheckResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *CheckResponse) XXX_Merge(src proto.Message)
  • func (m *CheckResponse) XXX_Size() int
  • func (m *CheckResponse) XXX_Unmarshal(b []byte) error
• type MonitorClient
  • func NewMonitorClient(cc *grpc.ClientConn) MonitorClient
• type MonitorHandler
• type MonitorServer
• type MonitorService
  • func NewMonitorService(name string, c client.Client) MonitorService

Functions

func RegisterMonitorHandler

func RegisterMonitorHandler(s server.Server, hdlr MonitorHandler, opts ...server.HandlerOption) error

func RegisterMonitorServer

func RegisterMonitorServer(s *grpc.Server, srv MonitorServer)

Types

type CheckRequest

type CheckRequest struct {
	Service              string   `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CheckRequest) Descriptor

func (*CheckRequest) Descriptor() ([]byte, []int)

func (*CheckRequest) GetService

func (m *CheckRequest) GetService() string

func (*CheckRequest) ProtoMessage

func (*CheckRequest) ProtoMessage()

func (*CheckRequest) Reset

func (m *CheckRequest) Reset()

func (*CheckRequest) String

func (m *CheckRequest) String() string

func (*CheckRequest) XXX_DiscardUnknown

func (m *CheckRequest) XXX_DiscardUnknown()

func (*CheckRequest) XXX_Marshal

func (m *CheckRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CheckRequest) XXX_Merge

func (m *CheckRequest) XXX_Merge(src proto.Message)

func (*CheckRequest) XXX_Size

func (m *CheckRequest) XXX_Size() int

func (*CheckRequest) XXX_Unmarshal

func (m *CheckRequest) XXX_Unmarshal(b []byte) error

type CheckResponse

type CheckResponse struct {
	Status               string   `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CheckResponse) Descriptor

func (*CheckResponse) Descriptor() ([]byte, []int)

func (*CheckResponse) GetStatus

func (m *CheckResponse) GetStatus() string

func (*CheckResponse) ProtoMessage

func (*CheckResponse) ProtoMessage()

func (*CheckResponse) Reset

func (m *CheckResponse) Reset()

func (*CheckResponse) String

func (m *CheckResponse) String() string

func (*CheckResponse) XXX_DiscardUnknown

func (m *CheckResponse) XXX_DiscardUnknown()

func (*CheckResponse) XXX_Marshal

func (m *CheckResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CheckResponse) XXX_Merge

func (m *CheckResponse) XXX_Merge(src proto.Message)

func (*CheckResponse) XXX_Size

func (m *CheckResponse) XXX_Size() int

func (*CheckResponse) XXX_Unmarshal

func (m *CheckResponse) XXX_Unmarshal(b []byte) error

type MonitorClient

type MonitorClient interface {
	Check(ctx context.Context, in *CheckRequest, opts ...grpc.CallOption) (*CheckResponse, error)
}

MonitorClient is the client API for Monitor service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewMonitorClient

func NewMonitorClient(cc *grpc.ClientConn) MonitorClient

type MonitorHandler

type MonitorHandler interface {
	Check(context.Context, *CheckRequest, *CheckResponse) error
}

type MonitorServer

type MonitorServer interface {
	Check(context.Context, *CheckRequest) (*CheckResponse, error)
}

MonitorServer is the server API for Monitor service.

type MonitorService

type MonitorService interface {
	Check(ctx context.Context, in *CheckRequest, opts ...client.CallOption) (*CheckResponse, error)
}

func NewMonitorService

func NewMonitorService(name string, c client.Client) MonitorService