cmdctrlsvc

Documentation

Overview

Package cmdctrlsvc is a generated protocol buffer package.

It is generated from these files:

cmdctrlsvc.proto

It has these top-level messages:

RingUpdateResult
StatsMsg
EmptyMsg
StatusMsg
Ring
HealthCheckMsg
SelfUpgradeMsg
SoftwareVersionMsg

Index

• func RegisterCmdCtrlServer(s *grpc.Server, srv CmdCtrlServer)
• type CmdCtrlClient
  • func NewCmdCtrlClient(cc *grpc.ClientConn) CmdCtrlClient
• type CmdCtrlServer
• type EmptyMsg
  • func (*EmptyMsg) Descriptor() ([]byte, []int)
  • func (*EmptyMsg) ProtoMessage()
  • func (m *EmptyMsg) Reset()
  • func (m *EmptyMsg) String() string
• type HealthCheckMsg
  • func (*HealthCheckMsg) Descriptor() ([]byte, []int)
  • func (*HealthCheckMsg) ProtoMessage()
  • func (m *HealthCheckMsg) Reset()
  • func (m *HealthCheckMsg) String() string
• type Ring
  • func (*Ring) Descriptor() ([]byte, []int)
  • func (*Ring) ProtoMessage()
  • func (m *Ring) Reset()
  • func (m *Ring) String() string
• type RingUpdateResult
  • func (*RingUpdateResult) Descriptor() ([]byte, []int)
  • func (*RingUpdateResult) ProtoMessage()
  • func (m *RingUpdateResult) Reset()
  • func (m *RingUpdateResult) String() string
• type SelfUpgradeMsg
  • func (*SelfUpgradeMsg) Descriptor() ([]byte, []int)
  • func (*SelfUpgradeMsg) ProtoMessage()
  • func (m *SelfUpgradeMsg) Reset()
  • func (m *SelfUpgradeMsg) String() string
• type SoftwareVersionMsg
  • func (*SoftwareVersionMsg) Descriptor() ([]byte, []int)
  • func (*SoftwareVersionMsg) ProtoMessage()
  • func (m *SoftwareVersionMsg) Reset()
  • func (m *SoftwareVersionMsg) String() string
• type StatsMsg
  • func (*StatsMsg) Descriptor() ([]byte, []int)
  • func (*StatsMsg) ProtoMessage()
  • func (m *StatsMsg) Reset()
  • func (m *StatsMsg) String() string
• type StatusMsg
  • func (*StatusMsg) Descriptor() ([]byte, []int)
  • func (*StatusMsg) ProtoMessage()
  • func (m *StatusMsg) Reset()
  • func (m *StatusMsg) String() string

Functions

func RegisterCmdCtrlServer

func RegisterCmdCtrlServer(s *grpc.Server, srv CmdCtrlServer)

Types

type CmdCtrlClient

type CmdCtrlClient interface {
	RingUpdate(ctx context.Context, in *Ring, opts ...grpc.CallOption) (*RingUpdateResult, error)
	Reload(ctx context.Context, in *EmptyMsg, opts ...grpc.CallOption) (*StatusMsg, error)
	Restart(ctx context.Context, in *EmptyMsg, opts ...grpc.CallOption) (*StatusMsg, error)
	Start(ctx context.Context, in *EmptyMsg, opts ...grpc.CallOption) (*StatusMsg, error)
	Stop(ctx context.Context, in *EmptyMsg, opts ...grpc.CallOption) (*StatusMsg, error)
	Exit(ctx context.Context, in *EmptyMsg, opts ...grpc.CallOption) (*StatusMsg, error)
	Stats(ctx context.Context, in *EmptyMsg, opts ...grpc.CallOption) (*StatsMsg, error)
	HealthCheck(ctx context.Context, in *EmptyMsg, opts ...grpc.CallOption) (*HealthCheckMsg, error)
	SelfUpgrade(ctx context.Context, in *SelfUpgradeMsg, opts ...grpc.CallOption) (*StatusMsg, error)
	SoftwareVersion(ctx context.Context, in *EmptyMsg, opts ...grpc.CallOption) (*SoftwareVersionMsg, error)
}

func NewCmdCtrlClient

func NewCmdCtrlClient(cc *grpc.ClientConn) CmdCtrlClient

type CmdCtrlServer

type CmdCtrlServer interface {
	RingUpdate(context.Context, *Ring) (*RingUpdateResult, error)
	Reload(context.Context, *EmptyMsg) (*StatusMsg, error)
	Restart(context.Context, *EmptyMsg) (*StatusMsg, error)
	Start(context.Context, *EmptyMsg) (*StatusMsg, error)
	Stop(context.Context, *EmptyMsg) (*StatusMsg, error)
	Exit(context.Context, *EmptyMsg) (*StatusMsg, error)
	Stats(context.Context, *EmptyMsg) (*StatsMsg, error)
	HealthCheck(context.Context, *EmptyMsg) (*HealthCheckMsg, error)
	SelfUpgrade(context.Context, *SelfUpgradeMsg) (*StatusMsg, error)
	SoftwareVersion(context.Context, *EmptyMsg) (*SoftwareVersionMsg, error)
}

type EmptyMsg

type EmptyMsg struct {
}

func (*EmptyMsg) Descriptor

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

func (*EmptyMsg) ProtoMessage

func (*EmptyMsg) ProtoMessage()

func (*EmptyMsg) Reset

func (m *EmptyMsg) Reset()

func (*EmptyMsg) String

func (m *EmptyMsg) String() string

type HealthCheckMsg

type HealthCheckMsg struct {
	Status bool   `protobuf:"varint,1,opt,name=status" json:"status,omitempty"`
	Msg    string `protobuf:"bytes,2,opt,name=msg" json:"msg,omitempty"`
	Ts     int64  `protobuf:"varint,3,opt,name=ts" json:"ts,omitempty"`
}

func (*HealthCheckMsg) Descriptor

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

func (*HealthCheckMsg) ProtoMessage

func (*HealthCheckMsg) ProtoMessage()

func (*HealthCheckMsg) Reset

func (m *HealthCheckMsg) Reset()

func (*HealthCheckMsg) String

func (m *HealthCheckMsg) String() string

type Ring

type Ring struct {
	Version int64  `protobuf:"varint,1,opt,name=version" json:"version,omitempty"`
	Ring    []byte `protobuf:"bytes,2,opt,name=ring,proto3" json:"ring,omitempty"`
}

func (*Ring) Descriptor

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

func (*Ring) ProtoMessage

func (*Ring) ProtoMessage()

func (*Ring) Reset

func (m *Ring) Reset()

func (*Ring) String

func (m *Ring) String() string

type RingUpdateResult

type RingUpdateResult struct {
	Newversion int64 `protobuf:"varint,1,opt,name=newversion" json:"newversion,omitempty"`
}

func (*RingUpdateResult) Descriptor

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

func (*RingUpdateResult) ProtoMessage

func (*RingUpdateResult) ProtoMessage()

func (*RingUpdateResult) Reset

func (m *RingUpdateResult) Reset()

func (*RingUpdateResult) String

func (m *RingUpdateResult) String() string

type SelfUpgradeMsg

type SelfUpgradeMsg struct {
	Version  string `protobuf:"bytes,1,opt,name=version" json:"version,omitempty"`
	Bindiff  []byte `protobuf:"bytes,2,opt,name=bindiff,proto3" json:"bindiff,omitempty"`
	Checksum []byte `protobuf:"bytes,3,opt,name=checksum,proto3" json:"checksum,omitempty"`
}

func (*SelfUpgradeMsg) Descriptor

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

func (*SelfUpgradeMsg) ProtoMessage

func (*SelfUpgradeMsg) ProtoMessage()

func (*SelfUpgradeMsg) Reset

func (m *SelfUpgradeMsg) Reset()

func (*SelfUpgradeMsg) String

func (m *SelfUpgradeMsg) String() string

type SoftwareVersionMsg

type SoftwareVersionMsg struct {
	Version string `protobuf:"bytes,1,opt,name=version" json:"version,omitempty"`
}

func (*SoftwareVersionMsg) Descriptor

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

func (*SoftwareVersionMsg) ProtoMessage

func (*SoftwareVersionMsg) ProtoMessage()

func (*SoftwareVersionMsg) Reset

func (m *SoftwareVersionMsg) Reset()

func (*SoftwareVersionMsg) String

func (m *SoftwareVersionMsg) String() string

type StatsMsg

type StatsMsg struct {
	Statsjson []byte `protobuf:"bytes,1,opt,name=statsjson,proto3" json:"statsjson,omitempty"`
}

func (*StatsMsg) Descriptor

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

func (*StatsMsg) ProtoMessage

func (*StatsMsg) ProtoMessage()

func (*StatsMsg) Reset

func (m *StatsMsg) Reset()

func (*StatsMsg) String

func (m *StatsMsg) String() string

type StatusMsg

type StatusMsg struct {
	Status bool   `protobuf:"varint,1,opt,name=status" json:"status,omitempty"`
	Msg    string `protobuf:"bytes,2,opt,name=msg" json:"msg,omitempty"`
}

func (*StatusMsg) Descriptor

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

func (*StatusMsg) ProtoMessage

func (*StatusMsg) ProtoMessage()

func (*StatusMsg) Reset

func (m *StatusMsg) Reset()

func (*StatusMsg) String

func (m *StatusMsg) String() string