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 {
	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

      type InfoRequest struct {
      	XXX_NoUnkeyedLiteral struct{} `json:"-"`
      	XXX_unrecognized     []byte   `json:"-"`
      	XXX_sizecache        int32    `json:"-"`
      }

      func (*InfoRequest) Descriptor

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

      func (*InfoRequest) ProtoMessage

      func (*InfoRequest) ProtoMessage()

      func (*InfoRequest) Reset

      func (m *InfoRequest) Reset()

      func (*InfoRequest) String

      func (m *InfoRequest) String() string

      func (*InfoRequest) XXX_DiscardUnknown

      func (m *InfoRequest) XXX_DiscardUnknown()

      func (*InfoRequest) XXX_Marshal

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

      func (*InfoRequest) XXX_Merge

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

      func (*InfoRequest) XXX_Size

      func (m *InfoRequest) XXX_Size() int

      func (*InfoRequest) XXX_Unmarshal

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

      type InfoResponse

      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

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

      func (*InfoResponse) GetID

      func (m *InfoResponse) GetID() string

      func (*InfoResponse) ProtoMessage

      func (*InfoResponse) ProtoMessage()

      func (*InfoResponse) Reset

      func (m *InfoResponse) Reset()

      func (*InfoResponse) String

      func (m *InfoResponse) String() string

      func (*InfoResponse) XXX_DiscardUnknown

      func (m *InfoResponse) XXX_DiscardUnknown()

      func (*InfoResponse) XXX_Marshal

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

      func (*InfoResponse) XXX_Merge

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

      func (*InfoResponse) XXX_Size

      func (m *InfoResponse) XXX_Size() int

      func (*InfoResponse) XXX_Unmarshal

      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) Descriptor() ([]byte, []int)

        func (*Peer) GetAddress

        func (m *Peer) GetAddress() string

        func (*Peer) GetID

        func (m *Peer) GetID() 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