acproto

package
v0.0.0-...-b371d68 Latest Latest
Warning

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

 Go to latest Published: Jan 30, 2024 License: BSD-3-Clause Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthAchb        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowAchb          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupAchb = fmt.Errorf("proto: unexpected end of group")
)

Functions

func RegisterACrpcServer 

func RegisterACrpcServer(s *grpc.Server, srv ACrpcServer)

Types

type ACPDatabaseInfo 

type ACPDatabaseInfo struct {
	Name                 string      `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Raft                 *ACPRaftish `protobuf:"bytes,2,opt,name=raft,proto3" json:"raft,omitempty"`
	SpaceTotal           int32       `protobuf:"varint,3,opt,name=space_total,json=spaceTotal,proto3" json:"space_total,omitempty"`
	SpaceAvail           int32       `protobuf:"varint,4,opt,name=space_avail,json=spaceAvail,proto3" json:"space_avail,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*ACPDatabaseInfo) Descriptor 

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

func (*ACPDatabaseInfo) GetName 

func (m *ACPDatabaseInfo) GetName() string

func (*ACPDatabaseInfo) GetRaft 

func (m *ACPDatabaseInfo) GetRaft() *ACPRaftish

func (*ACPDatabaseInfo) GetSpaceAvail 

func (m *ACPDatabaseInfo) GetSpaceAvail() int32

func (*ACPDatabaseInfo) GetSpaceTotal 

func (m *ACPDatabaseInfo) GetSpaceTotal() int32

func (*ACPDatabaseInfo) Marshal 

func (m *ACPDatabaseInfo) Marshal() (dAtA []byte, err error)

func (*ACPDatabaseInfo) MarshalTo 

func (m *ACPDatabaseInfo) MarshalTo(dAtA []byte) (int, error)

func (*ACPDatabaseInfo) MarshalToSizedBuffer 

func (m *ACPDatabaseInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ACPDatabaseInfo) ProtoMessage 

func (*ACPDatabaseInfo) ProtoMessage()

func (*ACPDatabaseInfo) Reset 

func (m *ACPDatabaseInfo) Reset()

func (*ACPDatabaseInfo) Size 

func (m *ACPDatabaseInfo) Size() (n int)

func (*ACPDatabaseInfo) String 

func (m *ACPDatabaseInfo) String() string

func (*ACPDatabaseInfo) Unmarshal 

func (m *ACPDatabaseInfo) Unmarshal(dAtA []byte) error

func (*ACPDatabaseInfo) XXX_DiscardUnknown 

func (m *ACPDatabaseInfo) XXX_DiscardUnknown()

func (*ACPDatabaseInfo) XXX_Marshal 

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

func (*ACPDatabaseInfo) XXX_Merge 

func (m *ACPDatabaseInfo) XXX_Merge(src proto.Message)

func (*ACPDatabaseInfo) XXX_Size 

func (m *ACPDatabaseInfo) XXX_Size() int

func (*ACPDatabaseInfo) XXX_Unmarshal 

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

type ACPHeartBeat 

type ACPHeartBeat struct {
	PeerInfo             *kibitz.PeerInfo   `protobuf:"bytes,1,opt,name=peer_info,json=peerInfo,proto3" json:"peer_info,omitempty"`
	SortMetric           int32              `protobuf:"varint,2,opt,name=sort_metric,json=sortMetric,proto3" json:"sort_metric,omitempty"`
	ProcessId            int32              `protobuf:"varint,3,opt,name=process_id,json=processId,proto3" json:"process_id,omitempty"`
	CpuMetric            int32              `protobuf:"varint,4,opt,name=cpu_metric,json=cpuMetric,proto3" json:"cpu_metric,omitempty"`
	CapacityMetric       int32              `protobuf:"varint,5,opt,name=capacity_metric,json=capacityMetric,proto3" json:"capacity_metric,omitempty"`
	Database             []*ACPDatabaseInfo `protobuf:"bytes,6,rep,name=database,proto3" json:"database,omitempty"`
	Uptodate             bool               `protobuf:"varint,7,opt,name=uptodate,proto3" json:"uptodate,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*ACPHeartBeat) Descriptor 

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

func (*ACPHeartBeat) GetCapacityMetric 

func (m *ACPHeartBeat) GetCapacityMetric() int32

func (*ACPHeartBeat) GetCpuMetric 

func (m *ACPHeartBeat) GetCpuMetric() int32

func (*ACPHeartBeat) GetDatabase 

func (m *ACPHeartBeat) GetDatabase() []*ACPDatabaseInfo

func (*ACPHeartBeat) GetPeerInfo 

func (m *ACPHeartBeat) GetPeerInfo() *kibitz.PeerInfo

func (*ACPHeartBeat) GetProcessId 

func (m *ACPHeartBeat) GetProcessId() int32

func (*ACPHeartBeat) GetSortMetric 

func (m *ACPHeartBeat) GetSortMetric() int32

func (*ACPHeartBeat) GetUptodate 

func (m *ACPHeartBeat) GetUptodate() bool

func (*ACPHeartBeat) Marshal 

func (m *ACPHeartBeat) Marshal() (dAtA []byte, err error)

func (*ACPHeartBeat) MarshalTo 

func (m *ACPHeartBeat) MarshalTo(dAtA []byte) (int, error)

func (*ACPHeartBeat) MarshalToSizedBuffer 

func (m *ACPHeartBeat) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ACPHeartBeat) ProtoMessage 

func (*ACPHeartBeat) ProtoMessage()

func (*ACPHeartBeat) Reset 

func (m *ACPHeartBeat) Reset()

func (*ACPHeartBeat) SetPeerInfo 

func (p *ACPHeartBeat) SetPeerInfo(pi *kibitz.PeerInfo)

func (*ACPHeartBeat) Size 

func (m *ACPHeartBeat) Size() (n int)

func (*ACPHeartBeat) String 

func (m *ACPHeartBeat) String() string

func (*ACPHeartBeat) Unmarshal 

func (m *ACPHeartBeat) Unmarshal(dAtA []byte) error

func (*ACPHeartBeat) XXX_DiscardUnknown 

func (m *ACPHeartBeat) XXX_DiscardUnknown()

func (*ACPHeartBeat) XXX_Marshal 

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

func (*ACPHeartBeat) XXX_Merge 

func (m *ACPHeartBeat) XXX_Merge(src proto.Message)

func (*ACPHeartBeat) XXX_Size 

func (m *ACPHeartBeat) XXX_Size() int

func (*ACPHeartBeat) XXX_Unmarshal 

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

type ACPHeartBeatReply 

type ACPHeartBeatReply struct {
	StatusCode           int32           `protobuf:"varint,1,opt,name=status_code,json=statusCode,proto3" json:"status_code,omitempty"`
	StatusMessage        string          `protobuf:"bytes,2,opt,name=status_message,json=statusMessage,proto3" json:"status_message,omitempty"`
	Hbinfo               []*ACPHeartBeat `protobuf:"bytes,3,rep,name=hbinfo,proto3" json:"hbinfo,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*ACPHeartBeatReply) Descriptor 

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

func (*ACPHeartBeatReply) GetHbinfo 

func (m *ACPHeartBeatReply) GetHbinfo() []*ACPHeartBeat

func (*ACPHeartBeatReply) GetStatusCode 

func (m *ACPHeartBeatReply) GetStatusCode() int32

func (*ACPHeartBeatReply) GetStatusMessage 

func (m *ACPHeartBeatReply) GetStatusMessage() string

func (*ACPHeartBeatReply) Marshal 

func (m *ACPHeartBeatReply) Marshal() (dAtA []byte, err error)

func (*ACPHeartBeatReply) MarshalTo 

func (m *ACPHeartBeatReply) MarshalTo(dAtA []byte) (int, error)

func (*ACPHeartBeatReply) MarshalToSizedBuffer 

func (m *ACPHeartBeatReply) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ACPHeartBeatReply) ProtoMessage 

func (*ACPHeartBeatReply) ProtoMessage()

func (*ACPHeartBeatReply) Reset 

func (m *ACPHeartBeatReply) Reset()

func (*ACPHeartBeatReply) Size 

func (m *ACPHeartBeatReply) Size() (n int)

func (*ACPHeartBeatReply) String 

func (m *ACPHeartBeatReply) String() string

func (*ACPHeartBeatReply) Unmarshal 

func (m *ACPHeartBeatReply) Unmarshal(dAtA []byte) error

func (*ACPHeartBeatReply) XXX_DiscardUnknown 

func (m *ACPHeartBeatReply) XXX_DiscardUnknown()

func (*ACPHeartBeatReply) XXX_Marshal 

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

func (*ACPHeartBeatReply) XXX_Merge 

func (m *ACPHeartBeatReply) XXX_Merge(src proto.Message)

func (*ACPHeartBeatReply) XXX_Size 

func (m *ACPHeartBeatReply) XXX_Size() int

func (*ACPHeartBeatReply) XXX_Unmarshal 

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

type ACPHeartBeatRequest 

type ACPHeartBeatRequest struct {
	Myself               *ACPHeartBeat `protobuf:"bytes,1,opt,name=myself,proto3" json:"myself,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*ACPHeartBeatRequest) Descriptor 

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

func (*ACPHeartBeatRequest) GetMyself 

func (m *ACPHeartBeatRequest) GetMyself() *ACPHeartBeat

func (*ACPHeartBeatRequest) Marshal 

func (m *ACPHeartBeatRequest) Marshal() (dAtA []byte, err error)

func (*ACPHeartBeatRequest) MarshalTo 

func (m *ACPHeartBeatRequest) MarshalTo(dAtA []byte) (int, error)

func (*ACPHeartBeatRequest) MarshalToSizedBuffer 

func (m *ACPHeartBeatRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ACPHeartBeatRequest) ProtoMessage 

func (*ACPHeartBeatRequest) ProtoMessage()

func (*ACPHeartBeatRequest) Reset 

func (m *ACPHeartBeatRequest) Reset()

func (*ACPHeartBeatRequest) Size 

func (m *ACPHeartBeatRequest) Size() (n int)

func (*ACPHeartBeatRequest) String 

func (m *ACPHeartBeatRequest) String() string

func (*ACPHeartBeatRequest) Unmarshal 

func (m *ACPHeartBeatRequest) Unmarshal(dAtA []byte) error

func (*ACPHeartBeatRequest) XXX_DiscardUnknown 

func (m *ACPHeartBeatRequest) XXX_DiscardUnknown()

func (*ACPHeartBeatRequest) XXX_Marshal 

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

func (*ACPHeartBeatRequest) XXX_Merge 

func (m *ACPHeartBeatRequest) XXX_Merge(src proto.Message)

func (*ACPHeartBeatRequest) XXX_Size 

func (m *ACPHeartBeatRequest) XXX_Size() int

func (*ACPHeartBeatRequest) XXX_Unmarshal 

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

type ACPRaftish 

type ACPRaftish struct {
	Leader               string   `protobuf:"bytes,1,opt,name=leader,proto3" json:"leader,omitempty"`
	Vote                 string   `protobuf:"bytes,2,opt,name=vote,proto3" json:"vote,omitempty"`
	TermStart            uint64   `protobuf:"varint,3,opt,name=term_start,json=termStart,proto3" json:"term_start,omitempty"`
	TimeVoted            uint64   `protobuf:"varint,4,opt,name=time_voted,json=timeVoted,proto3" json:"time_voted,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ACPRaftish) Descriptor 

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

func (*ACPRaftish) GetLeader 

func (m *ACPRaftish) GetLeader() string

func (*ACPRaftish) GetTermStart 

func (m *ACPRaftish) GetTermStart() uint64

func (*ACPRaftish) GetTimeVoted 

func (m *ACPRaftish) GetTimeVoted() uint64

func (*ACPRaftish) GetVote 

func (m *ACPRaftish) GetVote() string

func (*ACPRaftish) Marshal 

func (m *ACPRaftish) Marshal() (dAtA []byte, err error)

func (*ACPRaftish) MarshalTo 

func (m *ACPRaftish) MarshalTo(dAtA []byte) (int, error)

func (*ACPRaftish) MarshalToSizedBuffer 

func (m *ACPRaftish) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ACPRaftish) ProtoMessage 

func (*ACPRaftish) ProtoMessage()

func (*ACPRaftish) Reset 

func (m *ACPRaftish) Reset()

func (*ACPRaftish) Size 

func (m *ACPRaftish) Size() (n int)

func (*ACPRaftish) String 

func (m *ACPRaftish) String() string

func (*ACPRaftish) Unmarshal 

func (m *ACPRaftish) Unmarshal(dAtA []byte) error

func (*ACPRaftish) XXX_DiscardUnknown 

func (m *ACPRaftish) XXX_DiscardUnknown()

func (*ACPRaftish) XXX_Marshal 

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

func (*ACPRaftish) XXX_Merge 

func (m *ACPRaftish) XXX_Merge(src proto.Message)

func (*ACPRaftish) XXX_Size 

func (m *ACPRaftish) XXX_Size() int

func (*ACPRaftish) XXX_Unmarshal 

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

type ACPY2CheckReply 

type ACPY2CheckReply struct {
	Check                []*ACPY2CheckValue `protobuf:"bytes,1,rep,name=check,proto3" json:"check,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*ACPY2CheckReply) Descriptor 

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

func (*ACPY2CheckReply) GetCheck 

func (m *ACPY2CheckReply) GetCheck() []*ACPY2CheckValue

func (*ACPY2CheckReply) Marshal 

func (m *ACPY2CheckReply) Marshal() (dAtA []byte, err error)

func (*ACPY2CheckReply) MarshalTo 

func (m *ACPY2CheckReply) MarshalTo(dAtA []byte) (int, error)

func (*ACPY2CheckReply) MarshalToSizedBuffer 

func (m *ACPY2CheckReply) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ACPY2CheckReply) ProtoMessage 

func (*ACPY2CheckReply) ProtoMessage()

func (*ACPY2CheckReply) Reset 

func (m *ACPY2CheckReply) Reset()

func (*ACPY2CheckReply) Size 

func (m *ACPY2CheckReply) Size() (n int)

func (*ACPY2CheckReply) String 

func (m *ACPY2CheckReply) String() string

func (*ACPY2CheckReply) Unmarshal 

func (m *ACPY2CheckReply) Unmarshal(dAtA []byte) error

func (*ACPY2CheckReply) XXX_DiscardUnknown 

func (m *ACPY2CheckReply) XXX_DiscardUnknown()

func (*ACPY2CheckReply) XXX_Marshal 

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

func (*ACPY2CheckReply) XXX_Merge 

func (m *ACPY2CheckReply) XXX_Merge(src proto.Message)

func (*ACPY2CheckReply) XXX_Size 

func (m *ACPY2CheckReply) XXX_Size() int

func (*ACPY2CheckReply) XXX_Unmarshal 

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

type ACPY2CheckRequest 

type ACPY2CheckRequest struct {
	Map                  string   `protobuf:"bytes,1,opt,name=map,proto3" json:"map,omitempty"`
	Treeid               uint32   `protobuf:"varint,2,opt,name=treeid,proto3" json:"treeid,omitempty"`
	Level                int32    `protobuf:"varint,3,opt,name=level,proto3" json:"level,omitempty"`
	Version              uint64   `protobuf:"varint,4,opt,name=version,proto3" json:"version,omitempty"`
	Maxresult            int32    `protobuf:"varint,5,opt,name=maxresult,proto3" json:"maxresult,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ACPY2CheckRequest) Descriptor 

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

func (*ACPY2CheckRequest) GetLevel 

func (m *ACPY2CheckRequest) GetLevel() int32

func (*ACPY2CheckRequest) GetMap 

func (m *ACPY2CheckRequest) GetMap() string

func (*ACPY2CheckRequest) GetMaxresult 

func (m *ACPY2CheckRequest) GetMaxresult() int32

func (*ACPY2CheckRequest) GetTreeid 

func (m *ACPY2CheckRequest) GetTreeid() uint32

func (*ACPY2CheckRequest) GetVersion 

func (m *ACPY2CheckRequest) GetVersion() uint64

func (*ACPY2CheckRequest) Marshal 

func (m *ACPY2CheckRequest) Marshal() (dAtA []byte, err error)

func (*ACPY2CheckRequest) MarshalTo 

func (m *ACPY2CheckRequest) MarshalTo(dAtA []byte) (int, error)

func (*ACPY2CheckRequest) MarshalToSizedBuffer 

func (m *ACPY2CheckRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ACPY2CheckRequest) ProtoMessage 

func (*ACPY2CheckRequest) ProtoMessage()

func (*ACPY2CheckRequest) Reset 

func (m *ACPY2CheckRequest) Reset()

func (*ACPY2CheckRequest) Size 

func (m *ACPY2CheckRequest) Size() (n int)

func (*ACPY2CheckRequest) String 

func (m *ACPY2CheckRequest) String() string

func (*ACPY2CheckRequest) Unmarshal 

func (m *ACPY2CheckRequest) Unmarshal(dAtA []byte) error

func (*ACPY2CheckRequest) XXX_DiscardUnknown 

func (m *ACPY2CheckRequest) XXX_DiscardUnknown()

func (*ACPY2CheckRequest) XXX_Marshal 

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

func (*ACPY2CheckRequest) XXX_Merge 

func (m *ACPY2CheckRequest) XXX_Merge(src proto.Message)

func (*ACPY2CheckRequest) XXX_Size 

func (m *ACPY2CheckRequest) XXX_Size() int

func (*ACPY2CheckRequest) XXX_Unmarshal 

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

type ACPY2CheckValue 

type ACPY2CheckValue struct {
	Map                  string   `protobuf:"bytes,1,opt,name=map,proto3" json:"map,omitempty"`
	Treeid               uint32   `protobuf:"varint,2,opt,name=treeid,proto3" json:"treeid,omitempty"`
	Level                int32    `protobuf:"varint,3,opt,name=level,proto3" json:"level,omitempty"`
	Version              uint64   `protobuf:"varint,4,opt,name=version,proto3" json:"version,omitempty"`
	Shard                uint32   `protobuf:"varint,5,opt,name=shard,proto3" json:"shard,omitempty"`
	Key                  string   `protobuf:"bytes,6,opt,name=key,proto3" json:"key,omitempty"`
	Hash                 []byte   `protobuf:"bytes,7,opt,name=hash,proto3" json:"hash,omitempty"`
	Keycount             int64    `protobuf:"varint,8,opt,name=keycount,proto3" json:"keycount,omitempty"`
	Children             int32    `protobuf:"varint,9,opt,name=children,proto3" json:"children,omitempty"`
	Isvalid              bool     `protobuf:"varint,10,opt,name=isvalid,proto3" json:"isvalid,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ACPY2CheckValue) Descriptor 

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

func (*ACPY2CheckValue) GetChildren 

func (m *ACPY2CheckValue) GetChildren() int32

func (*ACPY2CheckValue) GetHash 

func (m *ACPY2CheckValue) GetHash() []byte

func (*ACPY2CheckValue) GetIsvalid 

func (m *ACPY2CheckValue) GetIsvalid() bool

func (*ACPY2CheckValue) GetKey 

func (m *ACPY2CheckValue) GetKey() string

func (*ACPY2CheckValue) GetKeycount 

func (m *ACPY2CheckValue) GetKeycount() int64

func (*ACPY2CheckValue) GetLevel 

func (m *ACPY2CheckValue) GetLevel() int32

func (*ACPY2CheckValue) GetMap 

func (m *ACPY2CheckValue) GetMap() string

func (*ACPY2CheckValue) GetShard 

func (m *ACPY2CheckValue) GetShard() uint32

func (*ACPY2CheckValue) GetTreeid 

func (m *ACPY2CheckValue) GetTreeid() uint32

func (*ACPY2CheckValue) GetVersion 

func (m *ACPY2CheckValue) GetVersion() uint64

func (*ACPY2CheckValue) Marshal 

func (m *ACPY2CheckValue) Marshal() (dAtA []byte, err error)

func (*ACPY2CheckValue) MarshalTo 

func (m *ACPY2CheckValue) MarshalTo(dAtA []byte) (int, error)

func (*ACPY2CheckValue) MarshalToSizedBuffer 

func (m *ACPY2CheckValue) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ACPY2CheckValue) ProtoMessage 

func (*ACPY2CheckValue) ProtoMessage()

func (*ACPY2CheckValue) Reset 

func (m *ACPY2CheckValue) Reset()

func (*ACPY2CheckValue) Size 

func (m *ACPY2CheckValue) Size() (n int)

func (*ACPY2CheckValue) String 

func (m *ACPY2CheckValue) String() string

func (*ACPY2CheckValue) Unmarshal 

func (m *ACPY2CheckValue) Unmarshal(dAtA []byte) error

func (*ACPY2CheckValue) XXX_DiscardUnknown 

func (m *ACPY2CheckValue) XXX_DiscardUnknown()

func (*ACPY2CheckValue) XXX_Marshal 

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

func (*ACPY2CheckValue) XXX_Merge 

func (m *ACPY2CheckValue) XXX_Merge(src proto.Message)

func (*ACPY2CheckValue) XXX_Size 

func (m *ACPY2CheckValue) XXX_Size() int

func (*ACPY2CheckValue) XXX_Unmarshal 

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

type ACPY2DistReply 

type ACPY2DistReply struct {
	StatusCode           int32    `protobuf:"varint,1,opt,name=status_code,json=statusCode,proto3" json:"status_code,omitempty"`
	StatusMessage        string   `protobuf:"bytes,2,opt,name=status_message,json=statusMessage,proto3" json:"status_message,omitempty"`
	ResultCode           int32    `protobuf:"varint,3,opt,name=result_code,json=resultCode,proto3" json:"result_code,omitempty"`
	ConfTime             int64    `protobuf:"varint,4,opt,name=conf_time,json=confTime,proto3" json:"conf_time,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ACPY2DistReply) Descriptor 

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

func (*ACPY2DistReply) GetConfTime 

func (m *ACPY2DistReply) GetConfTime() int64

func (*ACPY2DistReply) GetResultCode 

func (m *ACPY2DistReply) GetResultCode() int32

func (*ACPY2DistReply) GetStatusCode 

func (m *ACPY2DistReply) GetStatusCode() int32

func (*ACPY2DistReply) GetStatusMessage 

func (m *ACPY2DistReply) GetStatusMessage() string

func (*ACPY2DistReply) Marshal 

func (m *ACPY2DistReply) Marshal() (dAtA []byte, err error)

func (*ACPY2DistReply) MarshalTo 

func (m *ACPY2DistReply) MarshalTo(dAtA []byte) (int, error)

func (*ACPY2DistReply) MarshalToSizedBuffer 

func (m *ACPY2DistReply) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ACPY2DistReply) ProtoMessage 

func (*ACPY2DistReply) ProtoMessage()

func (*ACPY2DistReply) Reset 

func (m *ACPY2DistReply) Reset()

func (*ACPY2DistReply) Size 

func (m *ACPY2DistReply) Size() (n int)

func (*ACPY2DistReply) String 

func (m *ACPY2DistReply) String() string

func (*ACPY2DistReply) Unmarshal 

func (m *ACPY2DistReply) Unmarshal(dAtA []byte) error

func (*ACPY2DistReply) XXX_DiscardUnknown 

func (m *ACPY2DistReply) XXX_DiscardUnknown()

func (*ACPY2DistReply) XXX_Marshal 

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

func (*ACPY2DistReply) XXX_Merge 

func (m *ACPY2DistReply) XXX_Merge(src proto.Message)

func (*ACPY2DistReply) XXX_Size 

func (m *ACPY2DistReply) XXX_Size() int

func (*ACPY2DistReply) XXX_Unmarshal 

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

type ACPY2DistRequest 

type ACPY2DistRequest struct {
	Hop                  int32          `protobuf:"varint,1,opt,name=hop,proto3" json:"hop,omitempty"`
	Expire               uint64         `protobuf:"varint,2,opt,name=expire,proto3" json:"expire,omitempty"`
	Sender               string         `protobuf:"bytes,3,opt,name=sender,proto3" json:"sender,omitempty"`
	Data                 *ACPY2MapDatum `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*ACPY2DistRequest) Descriptor 

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

func (*ACPY2DistRequest) GetData 

func (m *ACPY2DistRequest) GetData() *ACPY2MapDatum

func (*ACPY2DistRequest) GetExpire 

func (m *ACPY2DistRequest) GetExpire() uint64

func (*ACPY2DistRequest) GetHop 

func (m *ACPY2DistRequest) GetHop() int32

func (*ACPY2DistRequest) GetSender 

func (m *ACPY2DistRequest) GetSender() string

func (*ACPY2DistRequest) Marshal 

func (m *ACPY2DistRequest) Marshal() (dAtA []byte, err error)

func (*ACPY2DistRequest) MarshalTo 

func (m *ACPY2DistRequest) MarshalTo(dAtA []byte) (int, error)

func (*ACPY2DistRequest) MarshalToSizedBuffer 

func (m *ACPY2DistRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ACPY2DistRequest) ProtoMessage 

func (*ACPY2DistRequest) ProtoMessage()

func (*ACPY2DistRequest) Reset 

func (m *ACPY2DistRequest) Reset()

func (*ACPY2DistRequest) Size 

func (m *ACPY2DistRequest) Size() (n int)

func (*ACPY2DistRequest) String 

func (m *ACPY2DistRequest) String() string

func (*ACPY2DistRequest) Unmarshal 

func (m *ACPY2DistRequest) Unmarshal(dAtA []byte) error

func (*ACPY2DistRequest) XXX_DiscardUnknown 

func (m *ACPY2DistRequest) XXX_DiscardUnknown()

func (*ACPY2DistRequest) XXX_Marshal 

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

func (*ACPY2DistRequest) XXX_Merge 

func (m *ACPY2DistRequest) XXX_Merge(src proto.Message)

func (*ACPY2DistRequest) XXX_Size 

func (m *ACPY2DistRequest) XXX_Size() int

func (*ACPY2DistRequest) XXX_Unmarshal 

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

type ACPY2Empty 

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

func (*ACPY2Empty) Descriptor 

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

func (*ACPY2Empty) Marshal 

func (m *ACPY2Empty) Marshal() (dAtA []byte, err error)

func (*ACPY2Empty) MarshalTo 

func (m *ACPY2Empty) MarshalTo(dAtA []byte) (int, error)

func (*ACPY2Empty) MarshalToSizedBuffer 

func (m *ACPY2Empty) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ACPY2Empty) ProtoMessage 

func (*ACPY2Empty) ProtoMessage()

func (*ACPY2Empty) Reset 

func (m *ACPY2Empty) Reset()

func (*ACPY2Empty) Size 

func (m *ACPY2Empty) Size() (n int)

func (*ACPY2Empty) String 

func (m *ACPY2Empty) String() string

func (*ACPY2Empty) Unmarshal 

func (m *ACPY2Empty) Unmarshal(dAtA []byte) error

func (*ACPY2Empty) XXX_DiscardUnknown 

func (m *ACPY2Empty) XXX_DiscardUnknown()

func (*ACPY2Empty) XXX_Marshal 

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

func (*ACPY2Empty) XXX_Merge 

func (m *ACPY2Empty) XXX_Merge(src proto.Message)

func (*ACPY2Empty) XXX_Size 

func (m *ACPY2Empty) XXX_Size() int

func (*ACPY2Empty) XXX_Unmarshal 

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

type ACPY2GetRange 

type ACPY2GetRange struct {
	Map                  string   `protobuf:"bytes,1,opt,name=map,proto3" json:"map,omitempty"`
	Key0                 string   `protobuf:"bytes,2,opt,name=key0,proto3" json:"key0,omitempty"`
	Key1                 string   `protobuf:"bytes,3,opt,name=key1,proto3" json:"key1,omitempty"`
	Version0             uint64   `protobuf:"varint,4,opt,name=version0,proto3" json:"version0,omitempty"`
	Version1             uint64   `protobuf:"varint,5,opt,name=version1,proto3" json:"version1,omitempty"`
	Shard                uint32   `protobuf:"varint,6,opt,name=shard,proto3" json:"shard,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ACPY2GetRange) Descriptor 

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

func (*ACPY2GetRange) GetKey0 

func (m *ACPY2GetRange) GetKey0() string

func (*ACPY2GetRange) GetKey1 

func (m *ACPY2GetRange) GetKey1() string

func (*ACPY2GetRange) GetMap 

func (m *ACPY2GetRange) GetMap() string

func (*ACPY2GetRange) GetShard 

func (m *ACPY2GetRange) GetShard() uint32

func (*ACPY2GetRange) GetVersion0 

func (m *ACPY2GetRange) GetVersion0() uint64

func (*ACPY2GetRange) GetVersion1 

func (m *ACPY2GetRange) GetVersion1() uint64

func (*ACPY2GetRange) Marshal 

func (m *ACPY2GetRange) Marshal() (dAtA []byte, err error)

func (*ACPY2GetRange) MarshalTo 

func (m *ACPY2GetRange) MarshalTo(dAtA []byte) (int, error)

func (*ACPY2GetRange) MarshalToSizedBuffer 

func (m *ACPY2GetRange) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ACPY2GetRange) ProtoMessage 

func (*ACPY2GetRange) ProtoMessage()

func (*ACPY2GetRange) Reset 

func (m *ACPY2GetRange) Reset()

func (*ACPY2GetRange) Size 

func (m *ACPY2GetRange) Size() (n int)

func (*ACPY2GetRange) String 

func (m *ACPY2GetRange) String() string

func (*ACPY2GetRange) Unmarshal 

func (m *ACPY2GetRange) Unmarshal(dAtA []byte) error

func (*ACPY2GetRange) XXX_DiscardUnknown 

func (m *ACPY2GetRange) XXX_DiscardUnknown()

func (*ACPY2GetRange) XXX_Marshal 

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

func (*ACPY2GetRange) XXX_Merge 

func (m *ACPY2GetRange) XXX_Merge(src proto.Message)

func (*ACPY2GetRange) XXX_Size 

func (m *ACPY2GetRange) XXX_Size() int

func (*ACPY2GetRange) XXX_Unmarshal 

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

type ACPY2GetSet 

type ACPY2GetSet struct {
	Data                 []*ACPY2MapDatum `protobuf:"bytes,1,rep,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*ACPY2GetSet) Descriptor 

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

func (*ACPY2GetSet) GetData 

func (m *ACPY2GetSet) GetData() []*ACPY2MapDatum

func (*ACPY2GetSet) Marshal 

func (m *ACPY2GetSet) Marshal() (dAtA []byte, err error)

func (*ACPY2GetSet) MarshalTo 

func (m *ACPY2GetSet) MarshalTo(dAtA []byte) (int, error)

func (*ACPY2GetSet) MarshalToSizedBuffer 

func (m *ACPY2GetSet) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ACPY2GetSet) ProtoMessage 

func (*ACPY2GetSet) ProtoMessage()

func (*ACPY2GetSet) Reset 

func (m *ACPY2GetSet) Reset()

func (*ACPY2GetSet) Size 

func (m *ACPY2GetSet) Size() (n int)

func (*ACPY2GetSet) String 

func (m *ACPY2GetSet) String() string

func (*ACPY2GetSet) Unmarshal 

func (m *ACPY2GetSet) Unmarshal(dAtA []byte) error

func (*ACPY2GetSet) XXX_DiscardUnknown 

func (m *ACPY2GetSet) XXX_DiscardUnknown()

func (*ACPY2GetSet) XXX_Marshal 

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

func (*ACPY2GetSet) XXX_Merge 

func (m *ACPY2GetSet) XXX_Merge(src proto.Message)

func (*ACPY2GetSet) XXX_Size 

func (m *ACPY2GetSet) XXX_Size() int

func (*ACPY2GetSet) XXX_Unmarshal 

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

type ACPY2MapDatum 

type ACPY2MapDatum struct {
	Map                  string   `protobuf:"bytes,1,opt,name=map,proto3" json:"map,omitempty"`
	Shard                uint32   `protobuf:"varint,2,opt,name=shard,proto3" json:"shard,omitempty"`
	Key                  string   `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
	Version              uint64   `protobuf:"varint,4,opt,name=version,proto3" json:"version,omitempty"`
	Value                []byte   `protobuf:"bytes,5,opt,name=value,proto3" json:"value,omitempty"`
	Expire               uint64   `protobuf:"varint,7,opt,name=expire,proto3" json:"expire,omitempty"`
	ConfTime             uint64   `protobuf:"varint,9,opt,name=conf_time,json=confTime,proto3" json:"conf_time,omitempty"`
	IfVersion            uint64   `protobuf:"varint,10,opt,name=if_version,json=ifVersion,proto3" json:"if_version,omitempty"`
	Location             []string `protobuf:"bytes,11,rep,name=location,proto3" json:"location,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ACPY2MapDatum) Descriptor 

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

func (*ACPY2MapDatum) GetConfTime 

func (m *ACPY2MapDatum) GetConfTime() uint64

func (*ACPY2MapDatum) GetExpire 

func (m *ACPY2MapDatum) GetExpire() uint64

func (*ACPY2MapDatum) GetIfVersion 

func (m *ACPY2MapDatum) GetIfVersion() uint64

func (*ACPY2MapDatum) GetKey 

func (m *ACPY2MapDatum) GetKey() string

func (*ACPY2MapDatum) GetLocation 

func (m *ACPY2MapDatum) GetLocation() []string

func (*ACPY2MapDatum) GetMap 

func (m *ACPY2MapDatum) GetMap() string

func (*ACPY2MapDatum) GetShard 

func (m *ACPY2MapDatum) GetShard() uint32

func (*ACPY2MapDatum) GetValue 

func (m *ACPY2MapDatum) GetValue() []byte

func (*ACPY2MapDatum) GetVersion 

func (m *ACPY2MapDatum) GetVersion() uint64

func (*ACPY2MapDatum) Marshal 

func (m *ACPY2MapDatum) Marshal() (dAtA []byte, err error)

func (*ACPY2MapDatum) MarshalTo 

func (m *ACPY2MapDatum) MarshalTo(dAtA []byte) (int, error)

func (*ACPY2MapDatum) MarshalToSizedBuffer 

func (m *ACPY2MapDatum) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ACPY2MapDatum) ProtoMessage 

func (*ACPY2MapDatum) ProtoMessage()

func (*ACPY2MapDatum) Reset 

func (m *ACPY2MapDatum) Reset()

func (*ACPY2MapDatum) Size 

func (m *ACPY2MapDatum) Size() (n int)

func (*ACPY2MapDatum) String 

func (m *ACPY2MapDatum) String() string

func (*ACPY2MapDatum) Unmarshal 

func (m *ACPY2MapDatum) Unmarshal(dAtA []byte) error

func (*ACPY2MapDatum) XXX_DiscardUnknown 

func (m *ACPY2MapDatum) XXX_DiscardUnknown()

func (*ACPY2MapDatum) XXX_Marshal 

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

func (*ACPY2MapDatum) XXX_Merge 

func (m *ACPY2MapDatum) XXX_Merge(src proto.Message)

func (*ACPY2MapDatum) XXX_Size 

func (m *ACPY2MapDatum) XXX_Size() int

func (*ACPY2MapDatum) XXX_Unmarshal 

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

type ACPY2RingConfReply 

type ACPY2RingConfReply struct {
	Version              uint64           `protobuf:"varint,1,opt,name=version,proto3" json:"version,omitempty"`
	IsStable             bool             `protobuf:"varint,2,opt,name=is_stable,json=isStable,proto3" json:"is_stable,omitempty"`
	Part                 []*ACPY2RingPart `protobuf:"bytes,3,rep,name=part,proto3" json:"part,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*ACPY2RingConfReply) Descriptor 

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

func (*ACPY2RingConfReply) GetIsStable 

func (m *ACPY2RingConfReply) GetIsStable() bool

func (*ACPY2RingConfReply) GetPart 

func (m *ACPY2RingConfReply) GetPart() []*ACPY2RingPart

func (*ACPY2RingConfReply) GetVersion 

func (m *ACPY2RingConfReply) GetVersion() uint64

func (*ACPY2RingConfReply) Marshal 

func (m *ACPY2RingConfReply) Marshal() (dAtA []byte, err error)

func (*ACPY2RingConfReply) MarshalTo 

func (m *ACPY2RingConfReply) MarshalTo(dAtA []byte) (int, error)

func (*ACPY2RingConfReply) MarshalToSizedBuffer 

func (m *ACPY2RingConfReply) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ACPY2RingConfReply) ProtoMessage 

func (*ACPY2RingConfReply) ProtoMessage()

func (*ACPY2RingConfReply) Reset 

func (m *ACPY2RingConfReply) Reset()

func (*ACPY2RingConfReply) Size 

func (m *ACPY2RingConfReply) Size() (n int)

func (*ACPY2RingConfReply) String 

func (m *ACPY2RingConfReply) String() string

func (*ACPY2RingConfReply) Unmarshal 

func (m *ACPY2RingConfReply) Unmarshal(dAtA []byte) error

func (*ACPY2RingConfReply) XXX_DiscardUnknown 

func (m *ACPY2RingConfReply) XXX_DiscardUnknown()

func (*ACPY2RingConfReply) XXX_Marshal 

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

func (*ACPY2RingConfReply) XXX_Merge 

func (m *ACPY2RingConfReply) XXX_Merge(src proto.Message)

func (*ACPY2RingConfReply) XXX_Size 

func (m *ACPY2RingConfReply) XXX_Size() int

func (*ACPY2RingConfReply) XXX_Unmarshal 

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

type ACPY2RingConfReq 

type ACPY2RingConfReq struct {
	Map                  string   `protobuf:"bytes,1,opt,name=map,proto3" json:"map,omitempty"`
	Datacenter           string   `protobuf:"bytes,2,opt,name=datacenter,proto3" json:"datacenter,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ACPY2RingConfReq) Descriptor 

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

func (*ACPY2RingConfReq) GetDatacenter 

func (m *ACPY2RingConfReq) GetDatacenter() string

func (*ACPY2RingConfReq) GetMap 

func (m *ACPY2RingConfReq) GetMap() string

func (*ACPY2RingConfReq) Marshal 

func (m *ACPY2RingConfReq) Marshal() (dAtA []byte, err error)

func (*ACPY2RingConfReq) MarshalTo 

func (m *ACPY2RingConfReq) MarshalTo(dAtA []byte) (int, error)

func (*ACPY2RingConfReq) MarshalToSizedBuffer 

func (m *ACPY2RingConfReq) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ACPY2RingConfReq) ProtoMessage 

func (*ACPY2RingConfReq) ProtoMessage()

func (*ACPY2RingConfReq) Reset 

func (m *ACPY2RingConfReq) Reset()

func (*ACPY2RingConfReq) Size 

func (m *ACPY2RingConfReq) Size() (n int)

func (*ACPY2RingConfReq) String 

func (m *ACPY2RingConfReq) String() string

func (*ACPY2RingConfReq) Unmarshal 

func (m *ACPY2RingConfReq) Unmarshal(dAtA []byte) error

func (*ACPY2RingConfReq) XXX_DiscardUnknown 

func (m *ACPY2RingConfReq) XXX_DiscardUnknown()

func (*ACPY2RingConfReq) XXX_Marshal 

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

func (*ACPY2RingConfReq) XXX_Merge 

func (m *ACPY2RingConfReq) XXX_Merge(src proto.Message)

func (*ACPY2RingConfReq) XXX_Size 

func (m *ACPY2RingConfReq) XXX_Size() int

func (*ACPY2RingConfReq) XXX_Unmarshal 

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

type ACPY2RingPart 

type ACPY2RingPart struct {
	Shard                uint32   `protobuf:"varint,1,opt,name=shard,proto3" json:"shard,omitempty"`
	Server               []string `protobuf:"bytes,2,rep,name=server,proto3" json:"server,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ACPY2RingPart) Descriptor 

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

func (*ACPY2RingPart) GetServer 

func (m *ACPY2RingPart) GetServer() []string

func (*ACPY2RingPart) GetShard 

func (m *ACPY2RingPart) GetShard() uint32

func (*ACPY2RingPart) Marshal 

func (m *ACPY2RingPart) Marshal() (dAtA []byte, err error)

func (*ACPY2RingPart) MarshalTo 

func (m *ACPY2RingPart) MarshalTo(dAtA []byte) (int, error)

func (*ACPY2RingPart) MarshalToSizedBuffer 

func (m *ACPY2RingPart) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ACPY2RingPart) ProtoMessage 

func (*ACPY2RingPart) ProtoMessage()

func (*ACPY2RingPart) Reset 

func (m *ACPY2RingPart) Reset()

func (*ACPY2RingPart) Size 

func (m *ACPY2RingPart) Size() (n int)

func (*ACPY2RingPart) String 

func (m *ACPY2RingPart) String() string

func (*ACPY2RingPart) Unmarshal 

func (m *ACPY2RingPart) Unmarshal(dAtA []byte) error

func (*ACPY2RingPart) XXX_DiscardUnknown 

func (m *ACPY2RingPart) XXX_DiscardUnknown()

func (*ACPY2RingPart) XXX_Marshal 

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

func (*ACPY2RingPart) XXX_Merge 

func (m *ACPY2RingPart) XXX_Merge(src proto.Message)

func (*ACPY2RingPart) XXX_Size 

func (m *ACPY2RingPart) XXX_Size() int

func (*ACPY2RingPart) XXX_Unmarshal 

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

type ACPY2ServerData 

type ACPY2ServerData struct {
	Subsystem            string            `protobuf:"bytes,1,opt,name=subsystem,proto3" json:"subsystem,omitempty"`
	Environment          string            `protobuf:"bytes,2,opt,name=environment,proto3" json:"environment,omitempty"`
	Hostname             string            `protobuf:"bytes,3,opt,name=hostname,proto3" json:"hostname,omitempty"`
	Datacenter           string            `protobuf:"bytes,4,opt,name=datacenter,proto3" json:"datacenter,omitempty"`
	Rack                 string            `protobuf:"bytes,5,opt,name=rack,proto3" json:"rack,omitempty"`
	ServerId             string            `protobuf:"bytes,6,opt,name=server_id,json=serverId,proto3" json:"server_id,omitempty"`
	NetInfo              []*kibitz.NetInfo `protobuf:"bytes,7,rep,name=net_info,json=netInfo,proto3" json:"net_info,omitempty"`
	IsUp                 bool              `protobuf:"varint,8,opt,name=is_up,json=isUp,proto3" json:"is_up,omitempty"`
	IsLocal              bool              `protobuf:"varint,9,opt,name=is_local,json=isLocal,proto3" json:"is_local,omitempty"`
	SortMetric           int32             `protobuf:"varint,10,opt,name=sort_metric,json=sortMetric,proto3" json:"sort_metric,omitempty"`
	CpuMetric            int32             `protobuf:"varint,11,opt,name=cpu_metric,json=cpuMetric,proto3" json:"cpu_metric,omitempty"`
	CapacityMetric       int32             `protobuf:"varint,12,opt,name=capacity_metric,json=capacityMetric,proto3" json:"capacity_metric,omitempty"`
	Database             []string          `protobuf:"bytes,14,rep,name=database,proto3" json:"database,omitempty"`
	Uptodate             bool              `protobuf:"varint,15,opt,name=uptodate,proto3" json:"uptodate,omitempty"`
	TimeLastUp           uint64            `protobuf:"varint,16,opt,name=time_last_up,json=timeLastUp,proto3" json:"time_last_up,omitempty"`
	TimeUpSince          uint64            `protobuf:"varint,17,opt,name=time_up_since,json=timeUpSince,proto3" json:"time_up_since,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*ACPY2ServerData) Descriptor 

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

func (*ACPY2ServerData) GetCapacityMetric 

func (m *ACPY2ServerData) GetCapacityMetric() int32

func (*ACPY2ServerData) GetCpuMetric 

func (m *ACPY2ServerData) GetCpuMetric() int32

func (*ACPY2ServerData) GetDatabase 

func (m *ACPY2ServerData) GetDatabase() []string

func (*ACPY2ServerData) GetDatacenter 

func (m *ACPY2ServerData) GetDatacenter() string

func (*ACPY2ServerData) GetEnvironment 

func (m *ACPY2ServerData) GetEnvironment() string

func (*ACPY2ServerData) GetHostname 

func (m *ACPY2ServerData) GetHostname() string

func (*ACPY2ServerData) GetIsLocal 

func (m *ACPY2ServerData) GetIsLocal() bool

func (*ACPY2ServerData) GetIsUp 

func (m *ACPY2ServerData) GetIsUp() bool

func (*ACPY2ServerData) GetNetInfo 

func (m *ACPY2ServerData) GetNetInfo() []*kibitz.NetInfo

func (*ACPY2ServerData) GetRack 

func (m *ACPY2ServerData) GetRack() string

func (*ACPY2ServerData) GetServerId 

func (m *ACPY2ServerData) GetServerId() string

func (*ACPY2ServerData) GetSortMetric 

func (m *ACPY2ServerData) GetSortMetric() int32

func (*ACPY2ServerData) GetSubsystem 

func (m *ACPY2ServerData) GetSubsystem() string

func (*ACPY2ServerData) GetTimeLastUp 

func (m *ACPY2ServerData) GetTimeLastUp() uint64

func (*ACPY2ServerData) GetTimeUpSince 

func (m *ACPY2ServerData) GetTimeUpSince() uint64

func (*ACPY2ServerData) GetUptodate 

func (m *ACPY2ServerData) GetUptodate() bool

func (*ACPY2ServerData) Marshal 

func (m *ACPY2ServerData) Marshal() (dAtA []byte, err error)

func (*ACPY2ServerData) MarshalTo 

func (m *ACPY2ServerData) MarshalTo(dAtA []byte) (int, error)

func (*ACPY2ServerData) MarshalToSizedBuffer 

func (m *ACPY2ServerData) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ACPY2ServerData) ProtoMessage 

func (*ACPY2ServerData) ProtoMessage()

func (*ACPY2ServerData) Reset 

func (m *ACPY2ServerData) Reset()

func (*ACPY2ServerData) Size 

func (m *ACPY2ServerData) Size() (n int)

func (*ACPY2ServerData) String 

func (m *ACPY2ServerData) String() string

func (*ACPY2ServerData) Unmarshal 

func (m *ACPY2ServerData) Unmarshal(dAtA []byte) error

func (*ACPY2ServerData) XXX_DiscardUnknown 

func (m *ACPY2ServerData) XXX_DiscardUnknown()

func (*ACPY2ServerData) XXX_Marshal 

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

func (*ACPY2ServerData) XXX_Merge 

func (m *ACPY2ServerData) XXX_Merge(src proto.Message)

func (*ACPY2ServerData) XXX_Size 

func (m *ACPY2ServerData) XXX_Size() int

func (*ACPY2ServerData) XXX_Unmarshal 

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

type ACPY2ServerReply 

type ACPY2ServerReply struct {
	Data                 []*ACPY2ServerData `protobuf:"bytes,1,rep,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*ACPY2ServerReply) Descriptor 

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

func (*ACPY2ServerReply) GetData 

func (m *ACPY2ServerReply) GetData() []*ACPY2ServerData

func (*ACPY2ServerReply) Marshal 

func (m *ACPY2ServerReply) Marshal() (dAtA []byte, err error)

func (*ACPY2ServerReply) MarshalTo 

func (m *ACPY2ServerReply) MarshalTo(dAtA []byte) (int, error)

func (*ACPY2ServerReply) MarshalToSizedBuffer 

func (m *ACPY2ServerReply) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ACPY2ServerReply) ProtoMessage 

func (*ACPY2ServerReply) ProtoMessage()

func (*ACPY2ServerReply) Reset 

func (m *ACPY2ServerReply) Reset()

func (*ACPY2ServerReply) Size 

func (m *ACPY2ServerReply) Size() (n int)

func (*ACPY2ServerReply) String 

func (m *ACPY2ServerReply) String() string

func (*ACPY2ServerReply) Unmarshal 

func (m *ACPY2ServerReply) Unmarshal(dAtA []byte) error

func (*ACPY2ServerReply) XXX_DiscardUnknown 

func (m *ACPY2ServerReply) XXX_DiscardUnknown()

func (*ACPY2ServerReply) XXX_Marshal 

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

func (*ACPY2ServerReply) XXX_Merge 

func (m *ACPY2ServerReply) XXX_Merge(src proto.Message)

func (*ACPY2ServerReply) XXX_Size 

func (m *ACPY2ServerReply) XXX_Size() int

func (*ACPY2ServerReply) XXX_Unmarshal 

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

type ACPY2ServerRequest 

type ACPY2ServerRequest struct {
	Subsystem            string   `protobuf:"bytes,1,opt,name=subsystem,proto3" json:"subsystem,omitempty"`
	Environment          string   `protobuf:"bytes,2,opt,name=environment,proto3" json:"environment,omitempty"`
	Hostname             string   `protobuf:"bytes,3,opt,name=hostname,proto3" json:"hostname,omitempty"`
	Datacenter           string   `protobuf:"bytes,4,opt,name=datacenter,proto3" json:"datacenter,omitempty"`
	ServerId             string   `protobuf:"bytes,5,opt,name=server_id,json=serverId,proto3" json:"server_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ACPY2ServerRequest) Descriptor 

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

func (*ACPY2ServerRequest) GetDatacenter 

func (m *ACPY2ServerRequest) GetDatacenter() string

func (*ACPY2ServerRequest) GetEnvironment 

func (m *ACPY2ServerRequest) GetEnvironment() string

func (*ACPY2ServerRequest) GetHostname 

func (m *ACPY2ServerRequest) GetHostname() string

func (*ACPY2ServerRequest) GetServerId 

func (m *ACPY2ServerRequest) GetServerId() string

func (*ACPY2ServerRequest) GetSubsystem 

func (m *ACPY2ServerRequest) GetSubsystem() string

func (*ACPY2ServerRequest) Marshal 

func (m *ACPY2ServerRequest) Marshal() (dAtA []byte, err error)

func (*ACPY2ServerRequest) MarshalTo 

func (m *ACPY2ServerRequest) MarshalTo(dAtA []byte) (int, error)

func (*ACPY2ServerRequest) MarshalToSizedBuffer 

func (m *ACPY2ServerRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ACPY2ServerRequest) ProtoMessage 

func (*ACPY2ServerRequest) ProtoMessage()

func (*ACPY2ServerRequest) Reset 

func (m *ACPY2ServerRequest) Reset()

func (*ACPY2ServerRequest) Size 

func (m *ACPY2ServerRequest) Size() (n int)

func (*ACPY2ServerRequest) String 

func (m *ACPY2ServerRequest) String() string

func (*ACPY2ServerRequest) Unmarshal 

func (m *ACPY2ServerRequest) Unmarshal(dAtA []byte) error

func (*ACPY2ServerRequest) XXX_DiscardUnknown 

func (m *ACPY2ServerRequest) XXX_DiscardUnknown()

func (*ACPY2ServerRequest) XXX_Marshal 

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

func (*ACPY2ServerRequest) XXX_Merge 

func (m *ACPY2ServerRequest) XXX_Merge(src proto.Message)

func (*ACPY2ServerRequest) XXX_Size 

func (m *ACPY2ServerRequest) XXX_Size() int

func (*ACPY2ServerRequest) XXX_Unmarshal 

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

type ACrpcClient 

type ACrpcClient interface {
	SendHB(ctx context.Context, in *ACPHeartBeatRequest, opts ...grpc.CallOption) (*ACPHeartBeatReply, error)
	GetMerkle(ctx context.Context, in *ACPY2CheckRequest, opts ...grpc.CallOption) (*ACPY2CheckReply, error)
	Get(ctx context.Context, in *ACPY2GetSet, opts ...grpc.CallOption) (*ACPY2GetSet, error)
	Put(ctx context.Context, in *ACPY2DistRequest, opts ...grpc.CallOption) (*ACPY2DistReply, error)
	Range(ctx context.Context, in *ACPY2GetRange, opts ...grpc.CallOption) (*ACPY2GetSet, error)
	RingConf(ctx context.Context, in *ACPY2RingConfReq, opts ...grpc.CallOption) (*ACPY2RingConfReply, error)
	Servers(ctx context.Context, in *ACPY2ServerRequest, opts ...grpc.CallOption) (*ACPY2ServerReply, error)
	ShutDown(ctx context.Context, in *ACPY2Empty, opts ...grpc.CallOption) (*ACPHeartBeatReply, error)
}

ACrpcClient is the client API for ACrpc service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewACrpcClient 

func NewACrpcClient(cc *grpc.ClientConn) ACrpcClient

type ACrpcServer 

type ACrpcServer interface {
	SendHB(context.Context, *ACPHeartBeatRequest) (*ACPHeartBeatReply, error)
	GetMerkle(context.Context, *ACPY2CheckRequest) (*ACPY2CheckReply, error)
	Get(context.Context, *ACPY2GetSet) (*ACPY2GetSet, error)
	Put(context.Context, *ACPY2DistRequest) (*ACPY2DistReply, error)
	Range(context.Context, *ACPY2GetRange) (*ACPY2GetSet, error)
	RingConf(context.Context, *ACPY2RingConfReq) (*ACPY2RingConfReply, error)
	Servers(context.Context, *ACPY2ServerRequest) (*ACPY2ServerReply, error)
	ShutDown(context.Context, *ACPY2Empty) (*ACPHeartBeatReply, error)
}

ACrpcServer is the server API for ACrpc service.

type UnimplementedACrpcServer 

type UnimplementedACrpcServer struct {
}

UnimplementedACrpcServer can be embedded to have forward compatible implementations.

func (*UnimplementedACrpcServer) Get 

func (*UnimplementedACrpcServer) Get(ctx context.Context, req *ACPY2GetSet) (*ACPY2GetSet, error)

func (*UnimplementedACrpcServer) GetMerkle 

func (*UnimplementedACrpcServer) GetMerkle(ctx context.Context, req *ACPY2CheckRequest) (*ACPY2CheckReply, error)

func (*UnimplementedACrpcServer) Put 

func (*UnimplementedACrpcServer) Put(ctx context.Context, req *ACPY2DistRequest) (*ACPY2DistReply, error)

func (*UnimplementedACrpcServer) Range 

func (*UnimplementedACrpcServer) Range(ctx context.Context, req *ACPY2GetRange) (*ACPY2GetSet, error)

func (*UnimplementedACrpcServer) RingConf 

func (*UnimplementedACrpcServer) RingConf(ctx context.Context, req *ACPY2RingConfReq) (*ACPY2RingConfReply, error)

func (*UnimplementedACrpcServer) SendHB 

func (*UnimplementedACrpcServer) SendHB(ctx context.Context, req *ACPHeartBeatRequest) (*ACPHeartBeatReply, error)

func (*UnimplementedACrpcServer) Servers 

func (*UnimplementedACrpcServer) Servers(ctx context.Context, req *ACPY2ServerRequest) (*ACPY2ServerReply, error)

func (*UnimplementedACrpcServer) ShutDown 

func (*UnimplementedACrpcServer) ShutDown(ctx context.Context, req *ACPY2Empty) (*ACPHeartBeatReply, 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.