health

package
v0.1.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 15, 2018 License: MIT Imports: 8 Imported by: 0

Documentation

Index

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 {
	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 {
	Health(context.Context, *types.Empty) (*HealthResponse, error)
}

HealthServer is the server API for Health service.

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 {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Addr                 string   `protobuf:"bytes,2,opt,name=addr,proto3" json:"addr,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Peer) Descriptor 

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

func (*Peer) GetAddr 

func (m *Peer) GetAddr() string

func (*Peer) GetName 

func (m *Peer) GetName() string

func (*Peer) ProtoMessage 

func (*Peer) ProtoMessage()

func (*Peer) Reset 

func (m *Peer) Reset()

func (*Peer) String 

func (m *Peer) String() string

func (*Peer) XXX_DiscardUnknown 

func (m *Peer) XXX_DiscardUnknown()

func (*Peer) XXX_Marshal 

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

func (*Peer) XXX_Merge 

func (dst *Peer) XXX_Merge(src proto.Message)

func (*Peer) XXX_Size 

func (m *Peer) XXX_Size() int

func (*Peer) XXX_Unmarshal 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.