Documentation ¶
Overview ¶
Package services is a generated protocol buffer package.
It is generated from these files:
peer-svc.proto
It has these top-level messages:
RPCPeerAddReq RPCPeerAddResp RPCPeerGenericResp RPCPeerDeleteReq RPCEtcdConfigReq
Index ¶
- func RegisterServices(server *rpc.Server)
- type PeerService
- type RPCEtcdConfigReq
- func (m *RPCEtcdConfigReq) GetClient() bool
- func (m *RPCEtcdConfigReq) GetClusterState() string
- func (m *RPCEtcdConfigReq) GetInitialCluster() string
- func (m *RPCEtcdConfigReq) GetName() string
- func (m *RPCEtcdConfigReq) GetPeerName() string
- func (*RPCEtcdConfigReq) ProtoMessage()
- func (m *RPCEtcdConfigReq) Reset()
- func (m *RPCEtcdConfigReq) String() string
- type RPCPeerAddReq
- type RPCPeerAddResp
- type RPCPeerDeleteReq
- type RPCPeerGenericResp
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterServices ¶
Types ¶
type PeerService ¶
type PeerService int
func (*PeerService) ExportAndStoreETCDConfig ¶
func (etcd *PeerService) ExportAndStoreETCDConfig(c *RPCEtcdConfigReq, reply *RPCPeerGenericResp) error
ExportAndStoreETCDConfig() will store & export etcd environment variable along with storing etcd configuration
func (*PeerService) ValidateAdd ¶
func (p *PeerService) ValidateAdd(args *RPCPeerAddReq, reply *RPCPeerAddResp) error
ValidateAdd() will checks all validation for AddPeer at server side
func (*PeerService) ValidateDelete ¶
func (p *PeerService) ValidateDelete(args *RPCPeerDeleteReq, reply *RPCPeerGenericResp) error
ValidateDelete() will checks all validation for DeletePeer at server side
type RPCEtcdConfigReq ¶
type RPCEtcdConfigReq struct { PeerName *string `protobuf:"bytes,1,req" json:"PeerName,omitempty"` Name *string `protobuf:"bytes,2,req" json:"Name,omitempty"` InitialCluster *string `protobuf:"bytes,3,req" json:"InitialCluster,omitempty"` ClusterState *string `protobuf:"bytes,4,req" json:"ClusterState,omitempty"` Client *bool `protobuf:"varint,5,req" json:"Client,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*RPCEtcdConfigReq) GetClient ¶
func (m *RPCEtcdConfigReq) GetClient() bool
func (*RPCEtcdConfigReq) GetClusterState ¶
func (m *RPCEtcdConfigReq) GetClusterState() string
func (*RPCEtcdConfigReq) GetInitialCluster ¶
func (m *RPCEtcdConfigReq) GetInitialCluster() string
func (*RPCEtcdConfigReq) GetName ¶
func (m *RPCEtcdConfigReq) GetName() string
func (*RPCEtcdConfigReq) GetPeerName ¶
func (m *RPCEtcdConfigReq) GetPeerName() string
func (*RPCEtcdConfigReq) ProtoMessage ¶
func (*RPCEtcdConfigReq) ProtoMessage()
func (*RPCEtcdConfigReq) Reset ¶
func (m *RPCEtcdConfigReq) Reset()
func (*RPCEtcdConfigReq) String ¶
func (m *RPCEtcdConfigReq) String() string
type RPCPeerAddReq ¶
type RPCPeerAddReq struct { Name *string `protobuf:"bytes,1,req" json:"Name,omitempty"` Addresses []string `protobuf:"bytes,2,rep" json:"Addresses,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*RPCPeerAddReq) GetAddresses ¶
func (m *RPCPeerAddReq) GetAddresses() []string
func (*RPCPeerAddReq) GetName ¶
func (m *RPCPeerAddReq) GetName() string
func (*RPCPeerAddReq) ProtoMessage ¶
func (*RPCPeerAddReq) ProtoMessage()
func (*RPCPeerAddReq) Reset ¶
func (m *RPCPeerAddReq) Reset()
func (*RPCPeerAddReq) String ¶
func (m *RPCPeerAddReq) String() string
type RPCPeerAddResp ¶
type RPCPeerAddResp struct { OpRet *int32 `protobuf:"varint,1,req" json:"OpRet,omitempty"` OpError *string `protobuf:"bytes,2,req" json:"OpError,omitempty"` UUID *string `protobuf:"bytes,3,req" json:"UUID,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*RPCPeerAddResp) GetOpError ¶
func (m *RPCPeerAddResp) GetOpError() string
func (*RPCPeerAddResp) GetOpRet ¶
func (m *RPCPeerAddResp) GetOpRet() int32
func (*RPCPeerAddResp) GetUUID ¶
func (m *RPCPeerAddResp) GetUUID() string
func (*RPCPeerAddResp) ProtoMessage ¶
func (*RPCPeerAddResp) ProtoMessage()
func (*RPCPeerAddResp) Reset ¶
func (m *RPCPeerAddResp) Reset()
func (*RPCPeerAddResp) String ¶
func (m *RPCPeerAddResp) String() string
type RPCPeerDeleteReq ¶
type RPCPeerDeleteReq struct { ID *string `protobuf:"bytes,1,req" json:"ID,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*RPCPeerDeleteReq) GetID ¶
func (m *RPCPeerDeleteReq) GetID() string
func (*RPCPeerDeleteReq) ProtoMessage ¶
func (*RPCPeerDeleteReq) ProtoMessage()
func (*RPCPeerDeleteReq) Reset ¶
func (m *RPCPeerDeleteReq) Reset()
func (*RPCPeerDeleteReq) String ¶
func (m *RPCPeerDeleteReq) String() string
type RPCPeerGenericResp ¶
type RPCPeerGenericResp struct { OpRet *int32 `protobuf:"varint,1,req" json:"OpRet,omitempty"` OpError *string `protobuf:"bytes,2,req" json:"OpError,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*RPCPeerGenericResp) GetOpError ¶
func (m *RPCPeerGenericResp) GetOpError() string
func (*RPCPeerGenericResp) GetOpRet ¶
func (m *RPCPeerGenericResp) GetOpRet() int32
func (*RPCPeerGenericResp) ProtoMessage ¶
func (*RPCPeerGenericResp) ProtoMessage()
func (*RPCPeerGenericResp) Reset ¶
func (m *RPCPeerGenericResp) Reset()
func (*RPCPeerGenericResp) String ¶
func (m *RPCPeerGenericResp) String() string
Click to show internal directories.
Click to hide internal directories.