Documentation
¶
Index ¶
- Variables
- func RegisterManagerServer(s *grpc.Server, srv ManagerServer)
- type HealthResponse
- func (*HealthResponse) Descriptor() ([]byte, []int)
- func (m *HealthResponse) GetStatus() string
- func (m *HealthResponse) Marshal() (dAtA []byte, err error)
- func (m *HealthResponse) MarshalTo(dAtA []byte) (int, error)
- func (*HealthResponse) ProtoMessage()
- func (m *HealthResponse) Reset()
- func (m *HealthResponse) Size() (n int)
- func (m *HealthResponse) String() string
- func (m *HealthResponse) Unmarshal(dAtA []byte) error
- func (m *HealthResponse) XXX_DiscardUnknown()
- func (m *HealthResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *HealthResponse) XXX_Merge(src proto.Message)
- func (m *HealthResponse) XXX_Size() int
- func (m *HealthResponse) XXX_Unmarshal(b []byte) error
- type ManagerClient
- type ManagerServer
- type RestartResponse
- func (*RestartResponse) Descriptor() ([]byte, []int)
- func (m *RestartResponse) GetMsg() string
- func (m *RestartResponse) Marshal() (dAtA []byte, err error)
- func (m *RestartResponse) MarshalTo(dAtA []byte) (int, error)
- func (*RestartResponse) ProtoMessage()
- func (m *RestartResponse) Reset()
- func (m *RestartResponse) Size() (n int)
- func (m *RestartResponse) String() string
- func (m *RestartResponse) Unmarshal(dAtA []byte) error
- func (m *RestartResponse) XXX_DiscardUnknown()
- func (m *RestartResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RestartResponse) XXX_Merge(src proto.Message)
- func (m *RestartResponse) XXX_Size() int
- func (m *RestartResponse) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrInvalidLengthE2Dpb = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowE2Dpb = fmt.Errorf("proto: integer overflow") )
Functions ¶
func RegisterManagerServer ¶
func RegisterManagerServer(s *grpc.Server, srv ManagerServer)
Types ¶
type HealthResponse ¶
type HealthResponse 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 (*HealthResponse) Descriptor ¶
func (*HealthResponse) Descriptor() ([]byte, []int)
func (*HealthResponse) GetStatus ¶
func (m *HealthResponse) GetStatus() string
func (*HealthResponse) Marshal ¶
func (m *HealthResponse) Marshal() (dAtA []byte, err error)
func (*HealthResponse) ProtoMessage ¶
func (*HealthResponse) ProtoMessage()
func (*HealthResponse) Reset ¶
func (m *HealthResponse) Reset()
func (*HealthResponse) Size ¶
func (m *HealthResponse) Size() (n int)
func (*HealthResponse) String ¶
func (m *HealthResponse) String() string
func (*HealthResponse) Unmarshal ¶
func (m *HealthResponse) Unmarshal(dAtA []byte) error
func (*HealthResponse) XXX_DiscardUnknown ¶
func (m *HealthResponse) XXX_DiscardUnknown()
func (*HealthResponse) XXX_Marshal ¶
func (m *HealthResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*HealthResponse) XXX_Merge ¶
func (m *HealthResponse) XXX_Merge(src proto.Message)
func (*HealthResponse) XXX_Size ¶
func (m *HealthResponse) XXX_Size() int
func (*HealthResponse) XXX_Unmarshal ¶
func (m *HealthResponse) XXX_Unmarshal(b []byte) error
type ManagerClient ¶
type ManagerClient interface {
Health(ctx context.Context, in *types.Empty, opts ...grpc.CallOption) (*HealthResponse, error)
Restart(ctx context.Context, in *types.Empty, opts ...grpc.CallOption) (*RestartResponse, error)
}
ManagerClient is the client API for Manager service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewManagerClient ¶
func NewManagerClient(cc *grpc.ClientConn) ManagerClient
type ManagerServer ¶
type ManagerServer interface {
Health(context.Context, *types.Empty) (*HealthResponse, error)
Restart(context.Context, *types.Empty) (*RestartResponse, error)
}
ManagerServer is the server API for Manager service.
type RestartResponse ¶
type RestartResponse struct {
Msg string `protobuf:"bytes,1,opt,name=msg,proto3" json:"msg,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*RestartResponse) Descriptor ¶
func (*RestartResponse) Descriptor() ([]byte, []int)
func (*RestartResponse) GetMsg ¶
func (m *RestartResponse) GetMsg() string
func (*RestartResponse) Marshal ¶
func (m *RestartResponse) Marshal() (dAtA []byte, err error)
func (*RestartResponse) ProtoMessage ¶
func (*RestartResponse) ProtoMessage()
func (*RestartResponse) Reset ¶
func (m *RestartResponse) Reset()
func (*RestartResponse) Size ¶
func (m *RestartResponse) Size() (n int)
func (*RestartResponse) String ¶
func (m *RestartResponse) String() string
func (*RestartResponse) Unmarshal ¶
func (m *RestartResponse) Unmarshal(dAtA []byte) error
func (*RestartResponse) XXX_DiscardUnknown ¶
func (m *RestartResponse) XXX_DiscardUnknown()
func (*RestartResponse) XXX_Marshal ¶
func (m *RestartResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RestartResponse) XXX_Merge ¶
func (m *RestartResponse) XXX_Merge(src proto.Message)
func (*RestartResponse) XXX_Size ¶
func (m *RestartResponse) XXX_Size() int
func (*RestartResponse) XXX_Unmarshal ¶
func (m *RestartResponse) XXX_Unmarshal(b []byte) error
Source Files
Click to show internal directories.
Click to hide internal directories.