Documentation ¶
Index ¶
- func RegisterHealthServer(s *grpc.Server, srv HealthServer)
- type HealthClient
- type HealthResponse
- func (*HealthResponse) Descriptor() ([]byte, []int)
- func (m *HealthResponse) GetHealth() *NodeHealth
- func (*HealthResponse) ProtoMessage()
- func (m *HealthResponse) Reset()
- func (m *HealthResponse) String() string
- func (m *HealthResponse) XXX_DiscardUnknown()
- func (m *HealthResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *HealthResponse) XXX_Merge(src proto.Message)
- func (m *HealthResponse) XXX_Size() int
- func (m *HealthResponse) XXX_Unmarshal(b []byte) error
- type HealthServer
- type InfoRequest
- func (*InfoRequest) Descriptor() ([]byte, []int)
- func (*InfoRequest) ProtoMessage()
- func (m *InfoRequest) Reset()
- func (m *InfoRequest) String() string
- func (m *InfoRequest) XXX_DiscardUnknown()
- func (m *InfoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *InfoRequest) XXX_Merge(src proto.Message)
- func (m *InfoRequest) XXX_Size() int
- func (m *InfoRequest) XXX_Unmarshal(b []byte) error
- type InfoResponse
- func (*InfoResponse) Descriptor() ([]byte, []int)
- func (m *InfoResponse) GetID() string
- func (*InfoResponse) ProtoMessage()
- func (m *InfoResponse) Reset()
- func (m *InfoResponse) String() string
- func (m *InfoResponse) XXX_DiscardUnknown()
- func (m *InfoResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *InfoResponse) XXX_Merge(src proto.Message)
- func (m *InfoResponse) XXX_Size() int
- func (m *InfoResponse) XXX_Unmarshal(b []byte) error
- type NodeHealth
- func (*NodeHealth) Descriptor() ([]byte, []int)
- func (m *NodeHealth) GetCpus() int64
- func (m *NodeHealth) GetMemoryFree() int64
- func (m *NodeHealth) GetMemoryTotal() int64
- func (m *NodeHealth) GetMemoryUsed() int64
- func (m *NodeHealth) GetOSName() string
- func (m *NodeHealth) GetOSVersion() string
- func (m *NodeHealth) GetPeers() []*Peer
- func (m *NodeHealth) GetStartedAt() *types.Timestamp
- func (*NodeHealth) ProtoMessage()
- func (m *NodeHealth) Reset()
- func (m *NodeHealth) Started() (time.Time, error)
- func (m *NodeHealth) String() string
- func (m *NodeHealth) XXX_DiscardUnknown()
- func (m *NodeHealth) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *NodeHealth) XXX_Merge(src proto.Message)
- func (m *NodeHealth) XXX_Size() int
- func (m *NodeHealth) XXX_Unmarshal(b []byte) error
- type Peer
- func (*Peer) Descriptor() ([]byte, []int)
- func (m *Peer) GetAddress() string
- func (m *Peer) GetID() string
- func (*Peer) ProtoMessage()
- func (m *Peer) Reset()
- func (m *Peer) String() string
- func (m *Peer) XXX_DiscardUnknown()
- func (m *Peer) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *Peer) XXX_Merge(src proto.Message)
- func (m *Peer) XXX_Size() int
- func (m *Peer) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterHealthServer ¶
func RegisterHealthServer(s *grpc.Server, srv HealthServer)
Types ¶
type HealthClient ¶
type HealthClient interface { Info(ctx context.Context, in *InfoRequest, opts ...grpc.CallOption) (*InfoResponse, error) Health(ctx context.Context, in *types.Empty, opts ...grpc.CallOption) (*HealthResponse, error) }
HealthClient is the client API for Health service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewHealthClient ¶
func NewHealthClient(cc *grpc.ClientConn) HealthClient
type HealthResponse ¶
type HealthResponse struct { Health *NodeHealth `protobuf:"bytes,1,opt,name=health" json:"health,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*HealthResponse) Descriptor ¶
func (*HealthResponse) Descriptor() ([]byte, []int)
func (*HealthResponse) GetHealth ¶
func (m *HealthResponse) GetHealth() *NodeHealth
func (*HealthResponse) ProtoMessage ¶
func (*HealthResponse) ProtoMessage()
func (*HealthResponse) Reset ¶
func (m *HealthResponse) Reset()
func (*HealthResponse) String ¶
func (m *HealthResponse) String() string
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 (dst *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 HealthServer ¶
type HealthServer interface { Info(context.Context, *InfoRequest) (*InfoResponse, error) Health(context.Context, *types.Empty) (*HealthResponse, error) }
HealthServer is the server API for Health service.
type InfoRequest ¶ added in v0.2.0
type InfoRequest struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*InfoRequest) Descriptor ¶ added in v0.2.0
func (*InfoRequest) Descriptor() ([]byte, []int)
func (*InfoRequest) ProtoMessage ¶ added in v0.2.0
func (*InfoRequest) ProtoMessage()
func (*InfoRequest) Reset ¶ added in v0.2.0
func (m *InfoRequest) Reset()
func (*InfoRequest) String ¶ added in v0.2.0
func (m *InfoRequest) String() string
func (*InfoRequest) XXX_DiscardUnknown ¶ added in v0.2.0
func (m *InfoRequest) XXX_DiscardUnknown()
func (*InfoRequest) XXX_Marshal ¶ added in v0.2.0
func (m *InfoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*InfoRequest) XXX_Merge ¶ added in v0.2.0
func (dst *InfoRequest) XXX_Merge(src proto.Message)
func (*InfoRequest) XXX_Size ¶ added in v0.2.0
func (m *InfoRequest) XXX_Size() int
func (*InfoRequest) XXX_Unmarshal ¶ added in v0.2.0
func (m *InfoRequest) XXX_Unmarshal(b []byte) error
type InfoResponse ¶ added in v0.2.0
type InfoResponse struct { ID string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*InfoResponse) Descriptor ¶ added in v0.2.0
func (*InfoResponse) Descriptor() ([]byte, []int)
func (*InfoResponse) GetID ¶ added in v0.2.0
func (m *InfoResponse) GetID() string
func (*InfoResponse) ProtoMessage ¶ added in v0.2.0
func (*InfoResponse) ProtoMessage()
func (*InfoResponse) Reset ¶ added in v0.2.0
func (m *InfoResponse) Reset()
func (*InfoResponse) String ¶ added in v0.2.0
func (m *InfoResponse) String() string
func (*InfoResponse) XXX_DiscardUnknown ¶ added in v0.2.0
func (m *InfoResponse) XXX_DiscardUnknown()
func (*InfoResponse) XXX_Marshal ¶ added in v0.2.0
func (m *InfoResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*InfoResponse) XXX_Merge ¶ added in v0.2.0
func (dst *InfoResponse) XXX_Merge(src proto.Message)
func (*InfoResponse) XXX_Size ¶ added in v0.2.0
func (m *InfoResponse) XXX_Size() int
func (*InfoResponse) XXX_Unmarshal ¶ added in v0.2.0
func (m *InfoResponse) XXX_Unmarshal(b []byte) error
type NodeHealth ¶
type NodeHealth struct { OSName string `protobuf:"bytes,1,opt,name=os_name,json=osName,proto3" json:"os_name,omitempty"` OSVersion string `protobuf:"bytes,2,opt,name=os_version,json=osVersion,proto3" json:"os_version,omitempty"` // TODO: use gogoproto.stdtime (returning panic: message/group field time.Time:bytes without pointer when trying to use) StartedAt *types.Timestamp `protobuf:"bytes,3,opt,name=started_at,json=startedAt" json:"started_at,omitempty"` Cpus int64 `protobuf:"varint,4,opt,name=cpus,proto3" json:"cpus,omitempty"` MemoryTotal int64 `protobuf:"varint,5,opt,name=memory_total,json=memoryTotal,proto3" json:"memory_total,omitempty"` MemoryFree int64 `protobuf:"varint,6,opt,name=memory_free,json=memoryFree,proto3" json:"memory_free,omitempty"` MemoryUsed int64 `protobuf:"varint,7,opt,name=memory_used,json=memoryUsed,proto3" json:"memory_used,omitempty"` Peers []*Peer `protobuf:"bytes,8,rep,name=peers" json:"peers,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*NodeHealth) Descriptor ¶
func (*NodeHealth) Descriptor() ([]byte, []int)
func (*NodeHealth) GetCpus ¶
func (m *NodeHealth) GetCpus() int64
func (*NodeHealth) GetMemoryFree ¶
func (m *NodeHealth) GetMemoryFree() int64
func (*NodeHealth) GetMemoryTotal ¶
func (m *NodeHealth) GetMemoryTotal() int64
func (*NodeHealth) GetMemoryUsed ¶
func (m *NodeHealth) GetMemoryUsed() int64
func (*NodeHealth) GetOSName ¶
func (m *NodeHealth) GetOSName() string
func (*NodeHealth) GetOSVersion ¶
func (m *NodeHealth) GetOSVersion() string
func (*NodeHealth) GetPeers ¶
func (m *NodeHealth) GetPeers() []*Peer
func (*NodeHealth) GetStartedAt ¶
func (m *NodeHealth) GetStartedAt() *types.Timestamp
func (*NodeHealth) ProtoMessage ¶
func (*NodeHealth) ProtoMessage()
func (*NodeHealth) Reset ¶
func (m *NodeHealth) Reset()
func (*NodeHealth) Started ¶
func (m *NodeHealth) Started() (time.Time, error)
Started returns the timestamp as time.Time
func (*NodeHealth) String ¶
func (m *NodeHealth) String() string
func (*NodeHealth) XXX_DiscardUnknown ¶
func (m *NodeHealth) XXX_DiscardUnknown()
func (*NodeHealth) XXX_Marshal ¶
func (m *NodeHealth) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*NodeHealth) XXX_Merge ¶
func (dst *NodeHealth) XXX_Merge(src proto.Message)
func (*NodeHealth) XXX_Size ¶
func (m *NodeHealth) XXX_Size() int
func (*NodeHealth) XXX_Unmarshal ¶
func (m *NodeHealth) XXX_Unmarshal(b []byte) error
type Peer ¶
type Peer struct { ID string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Peer) Descriptor ¶
func (*Peer) GetAddress ¶ added in v0.2.0
func (*Peer) ProtoMessage ¶
func (*Peer) ProtoMessage()
func (*Peer) XXX_DiscardUnknown ¶
func (m *Peer) XXX_DiscardUnknown()
func (*Peer) XXX_Unmarshal ¶
Click to show internal directories.
Click to hide internal directories.