protos

package
v0.0.0-...-81f3bb6 Latest Latest
Warning

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

 Go to latest Published: Jun 3, 2018 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Overview

Package protos is a generated protocol buffer package.

It is generated from these files: 

mon.proto
osd.proto
payload.proto

It has these top-level messages: 

MonConfigRequest
MonConfigReply
OsdStatusReportRequest
GetPgStatusRequest
GetPgStatusReply
OsdStatusReportReply
LayoutRequest
LayoutReply
Osd
OsdMap
OsdConfigRequest
OsdConfigReply
PoolMap
Pool
PoolConfigRequest
PoolConfigReply
PgMaps
PgMap
PgReplica
Pg
PgMembers
PgStatus
Op
Transaction
PgConfigRequest
PgConfigReply
Mon
MonMap
UnionMap
SyncMapRequest
SyncMapReply
MigrateGetRequest
MigrateGetReply
CreatePgRequest
CreatePgReply
DeletePgRequest
DeletePgReply
MergedPGState
Payload
RaftContext
Proposal

Index

Constants

View Source 
const (
	PG_STATE_CREATING = (1 << 0) // creating
	PG_STATE_ACTIVE   = (1 << 1) // i am active.  (primary: replicas too)
	PG_STATE_CLEAN    = (1 << 2) // peers are complete, clean of stray replicas.
	PG_STATE_DOWN     = (1 << 4) // a needed replica is down, PG offline
	PG_STATE_REPLAY   = (1 << 5) // crashed, waiting for replay
	//e PG_STATE_STRAY      (1<<6)  // i must notify the primary i exist.
	PG_STATE_MIGRATING        = (1 << 7)  // i am splitting
	PG_STATE_SCRUBBING        = (1 << 8)  // scrubbing
	PG_STATE_SCRUBQ           = (1 << 9)  // queued for scrub
	PG_STATE_DEGRADED         = (1 << 10) // pg contains objects with reduced redundancy
	PG_STATE_INCONSISTENT     = (1 << 11) // pg replicas are inconsistent (but shouldn't be)
	PG_STATE_PEERING          = (1 << 12) // pg is (re)peering
	PG_STATE_REPAIR           = (1 << 13) // pg should repair on next scrub
	PG_STATE_RECOVERING       = (1 << 14) // pg is recovering/migrating objects
	PG_STATE_BACKFILL_WAIT    = (1 << 15) // [active] reserving backfill
	PG_STATE_INCOMPLETE       = (1 << 16) // incomplete content, peering failed.
	PG_STATE_STALE            = (1 << 17) // our state for this pg is stale, unknown.
	PG_STATE_REMAPPED         = (1 << 18) // pg is explicitly remapped to different OSDs than CRUSH
	PG_STATE_DEEP_SCRUB       = (1 << 19) // deep scrub: check CRC32 on files
	PG_STATE_BACKFILL         = (1 << 20) // [active] backfilling pg content
	PG_STATE_BACKFILL_TOOFULL = (1 << 21) // backfill can't proceed: too full
	PG_STATE_RECOVERY_WAIT    = (1 << 22) // waiting for recovery reservations
	PG_STATE_UNDERSIZED       = (1 << 23) // pg acting < pool size
	PG_STATE_ACTIVATING       = (1 << 24) // pg is peered but not yet active
	PG_STATE_PEERED           = (1 << 25) // peered, cannot go active, can recover
	PG_STATE_UNINITIAL        = (1 << 26) // unstable stable, maybe change at next term
)

Variables

View Source 
var (
	ErrInvalidLengthMon = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMon   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthOsd = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowOsd   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthPayload = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowPayload   = fmt.Errorf("proto: integer overflow")
)
View Source 
var DistributePolicy_name = map[int32]string{
	0: "OSD",
	1: "HOST",
	2: "ZONE",
}
View Source 
var DistributePolicy_value = map[string]int32{
	"OSD":  0,
	"HOST": 1,
	"ZONE": 2,
}
View Source 
var Op_OpType_name = map[int32]string{
	0: "OP_PUT",
	1: "OP_ERASE",
	2: "OP_COMPACT",
}
View Source 
var Op_OpType_value = map[string]int32{
	"OP_PUT":     0,
	"OP_ERASE":   1,
	"OP_COMPACT": 2,
}
View Source 
var OsdConfigRequest_OpType_name = map[int32]string{
	0: "ADD",
	1: "DEL",
	2: "IN",
	3: "OUT",
	4: "UP",
	5: "DOWN",
	6: "LIST",
}
View Source 
var OsdConfigRequest_OpType_value = map[string]int32{
	"ADD":  0,
	"DEL":  1,
	"IN":   2,
	"OUT":  3,
	"UP":   4,
	"DOWN": 5,
	"LIST": 6,
}
View Source 
var PgConfigRequest_OpType_name = map[int32]string{
	0: "ADD",
	1: "DEL",
	2: "EDT",
	3: "LIST",
}
View Source 
var PgConfigRequest_OpType_value = map[string]int32{
	"ADD":  0,
	"DEL":  1,
	"EDT":  2,
	"LIST": 3,
}
View Source 
var PoolConfigRequest_OpType_name = map[int32]string{
	0: "ADD",
	1: "DEL",
	2: "LIST",
	3: "SET_SIZE",
	4: "SET_PGS",
}
View Source 
var PoolConfigRequest_OpType_value = map[string]int32{
	"ADD":      0,
	"DEL":      1,
	"LIST":     2,
	"SET_SIZE": 3,
	"SET_PGS":  4,
}
View Source 
var SyncMapType_name = map[int32]string{
	0: "PGMAP",
	1: "OSDMAP",
	2: "POOLMAP",
}
View Source 
var SyncMapType_value = map[string]int32{
	"PGMAP":   0,
	"OSDMAP":  1,
	"POOLMAP": 2,
}

Functions

func Calc_origin_pg 

func Calc_origin_pg(pg_id, old_pg_num int) int

func Calc_pg_masks 

func Calc_pg_masks(pg_num int) int

func Cale_bits_of 

func Cale_bits_of(num int) int

func Nentropy_stable_mod 

func Nentropy_stable_mod(x, b, bmask int) int

func Nentropy_str_hash 

func Nentropy_str_hash(s string) uint32

func Pg_state_string 

func Pg_state_string(state int32) string

func RegisterMonitorServer 

func RegisterMonitorServer(s *grpc.Server, srv MonitorServer)

func RegisterOsdRpcServer 

func RegisterOsdRpcServer(s *grpc.Server, srv OsdRpcServer)

func RegisterRaftNodeServer 

func RegisterRaftNodeServer(s *grpc.Server, srv RaftNodeServer)

Types

type CreatePgReply 

type CreatePgReply struct {
	RetCode int32 `protobuf:"varint,1,opt,name=ret_code,json=retCode,proto3" json:"ret_code,omitempty"`
}

func (*CreatePgReply) Descriptor 

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

func (*CreatePgReply) GetRetCode 

func (m *CreatePgReply) GetRetCode() int32

func (*CreatePgReply) Marshal 

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

func (*CreatePgReply) MarshalTo 

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

func (*CreatePgReply) ProtoMessage 

func (*CreatePgReply) ProtoMessage()

func (*CreatePgReply) Reset 

func (m *CreatePgReply) Reset()

func (*CreatePgReply) Size 

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

func (*CreatePgReply) String 

func (m *CreatePgReply) String() string

func (*CreatePgReply) Unmarshal 

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

type CreatePgRequest 

type CreatePgRequest struct {
	PgName          string                         `protobuf:"bytes,1,opt,name=pg_name,json=pgName,proto3" json:"pg_name,omitempty"`
	GroupDescriptor *multiraftbase.GroupDescriptor `protobuf:"bytes,2,opt,name=group_descriptor,json=groupDescriptor" json:"group_descriptor,omitempty"`
}

func (*CreatePgRequest) Descriptor 

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

func (*CreatePgRequest) GetGroupDescriptor 

func (m *CreatePgRequest) GetGroupDescriptor() *multiraftbase.GroupDescriptor

func (*CreatePgRequest) GetPgName 

func (m *CreatePgRequest) GetPgName() string

func (*CreatePgRequest) Marshal 

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

func (*CreatePgRequest) MarshalTo 

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

func (*CreatePgRequest) ProtoMessage 

func (*CreatePgRequest) ProtoMessage()

func (*CreatePgRequest) Reset 

func (m *CreatePgRequest) Reset()

func (*CreatePgRequest) Size 

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

func (*CreatePgRequest) String 

func (m *CreatePgRequest) String() string

func (*CreatePgRequest) Unmarshal 

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

type DeletePgReply 

type DeletePgReply struct {
	RetCode int32 `protobuf:"varint,1,opt,name=ret_code,json=retCode,proto3" json:"ret_code,omitempty"`
}

func (*DeletePgReply) Descriptor 

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

func (*DeletePgReply) GetRetCode 

func (m *DeletePgReply) GetRetCode() int32

func (*DeletePgReply) Marshal 

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

func (*DeletePgReply) MarshalTo 

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

func (*DeletePgReply) ProtoMessage 

func (*DeletePgReply) ProtoMessage()

func (*DeletePgReply) Reset 

func (m *DeletePgReply) Reset()

func (*DeletePgReply) Size 

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

func (*DeletePgReply) String 

func (m *DeletePgReply) String() string

func (*DeletePgReply) Unmarshal 

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

type DeletePgRequest 

type DeletePgRequest struct {
	PgName string `protobuf:"bytes,1,opt,name=pg_name,json=pgName,proto3" json:"pg_name,omitempty"`
}

func (*DeletePgRequest) Descriptor 

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

func (*DeletePgRequest) GetPgName 

func (m *DeletePgRequest) GetPgName() string

func (*DeletePgRequest) Marshal 

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

func (*DeletePgRequest) MarshalTo 

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

func (*DeletePgRequest) ProtoMessage 

func (*DeletePgRequest) ProtoMessage()

func (*DeletePgRequest) Reset 

func (m *DeletePgRequest) Reset()

func (*DeletePgRequest) Size 

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

func (*DeletePgRequest) String 

func (m *DeletePgRequest) String() string

func (*DeletePgRequest) Unmarshal 

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

type DistributePolicy 

type DistributePolicy int32
const (
	DistributePolicy_OSD  DistributePolicy = 0
	DistributePolicy_HOST DistributePolicy = 1
	DistributePolicy_ZONE DistributePolicy = 2
)

func (DistributePolicy) EnumDescriptor 

func (DistributePolicy) EnumDescriptor() ([]byte, []int)

func (DistributePolicy) String 

func (x DistributePolicy) String() string

type GetPgStatusReply 

type GetPgStatusReply struct {
	Status *PgStatus `protobuf:"bytes,1,opt,name=status" json:"status,omitempty"`
}

func (*GetPgStatusReply) Descriptor 

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

func (*GetPgStatusReply) GetStatus 

func (m *GetPgStatusReply) GetStatus() *PgStatus

func (*GetPgStatusReply) Marshal 

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

func (*GetPgStatusReply) MarshalTo 

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

func (*GetPgStatusReply) ProtoMessage 

func (*GetPgStatusReply) ProtoMessage()

func (*GetPgStatusReply) Reset 

func (m *GetPgStatusReply) Reset()

func (*GetPgStatusReply) Size 

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

func (*GetPgStatusReply) String 

func (m *GetPgStatusReply) String() string

func (*GetPgStatusReply) Unmarshal 

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

type GetPgStatusRequest 

type GetPgStatusRequest struct {
	PgId string `protobuf:"bytes,1,opt,name=pg_id,json=pgId,proto3" json:"pg_id,omitempty"`
}

func (*GetPgStatusRequest) Descriptor 

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

func (*GetPgStatusRequest) GetPgId 

func (m *GetPgStatusRequest) GetPgId() string

func (*GetPgStatusRequest) Marshal 

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

func (*GetPgStatusRequest) MarshalTo 

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

func (*GetPgStatusRequest) ProtoMessage 

func (*GetPgStatusRequest) ProtoMessage()

func (*GetPgStatusRequest) Reset 

func (m *GetPgStatusRequest) Reset()

func (*GetPgStatusRequest) Size 

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

func (*GetPgStatusRequest) String 

func (m *GetPgStatusRequest) String() string

func (*GetPgStatusRequest) Unmarshal 

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

type LayoutReply 

type LayoutReply struct {
	RetCode int32  `protobuf:"varint,1,opt,name=ret_code,json=retCode,proto3" json:"ret_code,omitempty"`
	PgName  string `protobuf:"bytes,2,opt,name=pg_name,json=pgName,proto3" json:"pg_name,omitempty"`
	Osds    []*Osd `protobuf:"bytes,3,rep,name=osds" json:"osds,omitempty"`
}

func (*LayoutReply) Descriptor 

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

func (*LayoutReply) GetOsds 

func (m *LayoutReply) GetOsds() []*Osd

func (*LayoutReply) GetPgName 

func (m *LayoutReply) GetPgName() string

func (*LayoutReply) GetRetCode 

func (m *LayoutReply) GetRetCode() int32

func (*LayoutReply) Marshal 

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

func (*LayoutReply) MarshalTo 

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

func (*LayoutReply) ProtoMessage 

func (*LayoutReply) ProtoMessage()

func (*LayoutReply) Reset 

func (m *LayoutReply) Reset()

func (*LayoutReply) Size 

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

func (*LayoutReply) String 

func (m *LayoutReply) String() string

func (*LayoutReply) Unmarshal 

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

type LayoutRequest 

type LayoutRequest struct {
	ObjectName string `protobuf:"bytes,1,opt,name=object_name,json=objectName,proto3" json:"object_name,omitempty"`
	PoolName   string `protobuf:"bytes,2,opt,name=pool_name,json=poolName,proto3" json:"pool_name,omitempty"`
}

func (*LayoutRequest) Descriptor 

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

func (*LayoutRequest) GetObjectName 

func (m *LayoutRequest) GetObjectName() string

func (*LayoutRequest) GetPoolName 

func (m *LayoutRequest) GetPoolName() string

func (*LayoutRequest) Marshal 

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

func (*LayoutRequest) MarshalTo 

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

func (*LayoutRequest) ProtoMessage 

func (*LayoutRequest) ProtoMessage()

func (*LayoutRequest) Reset 

func (m *LayoutRequest) Reset()

func (*LayoutRequest) Size 

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

func (*LayoutRequest) String 

func (m *LayoutRequest) String() string

func (*LayoutRequest) Unmarshal 

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

type MergedPGState 

type MergedPGState struct {
	Members []PgReplica `protobuf:"bytes,1,rep,name=members" json:"members"`
}

func (*MergedPGState) Descriptor 

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

func (*MergedPGState) GetMembers 

func (m *MergedPGState) GetMembers() []PgReplica

func (*MergedPGState) Marshal 

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

func (*MergedPGState) MarshalTo 

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

func (*MergedPGState) ProtoMessage 

func (*MergedPGState) ProtoMessage()

func (*MergedPGState) Reset 

func (m *MergedPGState) Reset()

func (*MergedPGState) Size 

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

func (*MergedPGState) String 

func (m *MergedPGState) String() string

func (*MergedPGState) Unmarshal 

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

type MigrateGetReply 

type MigrateGetReply struct {
	Key    []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value  []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	Marker []byte `protobuf:"bytes,3,opt,name=marker,proto3" json:"marker,omitempty"`
}

func (*MigrateGetReply) Descriptor 

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

func (*MigrateGetReply) GetKey 

func (m *MigrateGetReply) GetKey() []byte

func (*MigrateGetReply) GetMarker 

func (m *MigrateGetReply) GetMarker() []byte

func (*MigrateGetReply) GetValue 

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

func (*MigrateGetReply) Marshal 

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

func (*MigrateGetReply) MarshalTo 

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

func (*MigrateGetReply) ProtoMessage 

func (*MigrateGetReply) ProtoMessage()

func (*MigrateGetReply) Reset 

func (m *MigrateGetReply) Reset()

func (*MigrateGetReply) Size 

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

func (*MigrateGetReply) String 

func (m *MigrateGetReply) String() string

func (*MigrateGetReply) Unmarshal 

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

type MigrateGetRequest 

type MigrateGetRequest struct {
	ParentPgId string `protobuf:"bytes,1,opt,name=parent_pg_id,json=parentPgId,proto3" json:"parent_pg_id,omitempty"`
	ChildPgId  string `protobuf:"bytes,2,opt,name=child_pg_id,json=childPgId,proto3" json:"child_pg_id,omitempty"`
	Marker     []byte `protobuf:"bytes,3,opt,name=marker,proto3" json:"marker,omitempty"`
	FlagNext   bool   `protobuf:"varint,4,opt,name=flag_next,json=flagNext,proto3" json:"flag_next,omitempty"`
}

func (*MigrateGetRequest) Descriptor 

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

func (*MigrateGetRequest) GetChildPgId 

func (m *MigrateGetRequest) GetChildPgId() string

func (*MigrateGetRequest) GetFlagNext 

func (m *MigrateGetRequest) GetFlagNext() bool

func (*MigrateGetRequest) GetMarker 

func (m *MigrateGetRequest) GetMarker() []byte

func (*MigrateGetRequest) GetParentPgId 

func (m *MigrateGetRequest) GetParentPgId() string

func (*MigrateGetRequest) Marshal 

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

func (*MigrateGetRequest) MarshalTo 

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

func (*MigrateGetRequest) ProtoMessage 

func (*MigrateGetRequest) ProtoMessage()

func (*MigrateGetRequest) Reset 

func (m *MigrateGetRequest) Reset()

func (*MigrateGetRequest) Size 

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

func (*MigrateGetRequest) String 

func (m *MigrateGetRequest) String() string

func (*MigrateGetRequest) Unmarshal 

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

type Mon 

type Mon struct {
	Id   uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Addr string `protobuf:"bytes,2,opt,name=addr,proto3" json:"addr,omitempty"`
}

func (*Mon) Descriptor 

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

func (*Mon) GetAddr 

func (m *Mon) GetAddr() string

func (*Mon) GetId 

func (m *Mon) GetId() uint64

func (*Mon) Marshal 

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

func (*Mon) MarshalTo 

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

func (*Mon) ProtoMessage 

func (*Mon) ProtoMessage()

func (*Mon) Reset 

func (m *Mon) Reset()

func (*Mon) Size 

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

func (*Mon) String 

func (m *Mon) String() string

func (*Mon) Unmarshal 

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

type MonConfigReply 

type MonConfigReply struct {
	LeadId uint64  `protobuf:"varint,1,opt,name=lead_id,json=leadId,proto3" json:"lead_id,omitempty"`
	Map    *MonMap `protobuf:"bytes,2,opt,name=map" json:"map,omitempty"`
}

func (*MonConfigReply) Descriptor 

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

func (*MonConfigReply) GetLeadId 

func (m *MonConfigReply) GetLeadId() uint64

func (*MonConfigReply) GetMap 

func (m *MonConfigReply) GetMap() *MonMap

func (*MonConfigReply) Marshal 

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

func (*MonConfigReply) MarshalTo 

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

func (*MonConfigReply) ProtoMessage 

func (*MonConfigReply) ProtoMessage()

func (*MonConfigReply) Reset 

func (m *MonConfigReply) Reset()

func (*MonConfigReply) Size 

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

func (*MonConfigReply) String 

func (m *MonConfigReply) String() string

func (*MonConfigReply) Unmarshal 

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

type MonConfigRequest 

type MonConfigRequest struct {
	Method string `protobuf:"bytes,1,opt,name=method,proto3" json:"method,omitempty"`
}

func (*MonConfigRequest) Descriptor 

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

func (*MonConfigRequest) GetMethod 

func (m *MonConfigRequest) GetMethod() string

func (*MonConfigRequest) Marshal 

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

func (*MonConfigRequest) MarshalTo 

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

func (*MonConfigRequest) ProtoMessage 

func (*MonConfigRequest) ProtoMessage()

func (*MonConfigRequest) Reset 

func (m *MonConfigRequest) Reset()

func (*MonConfigRequest) Size 

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

func (*MonConfigRequest) String 

func (m *MonConfigRequest) String() string

func (*MonConfigRequest) Unmarshal 

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

type MonMap 

type MonMap struct {
	Epoch  uint64          `protobuf:"varint,1,opt,name=epoch,proto3" json:"epoch,omitempty"`
	MonMap map[uint64]*Mon `` /* 140-byte string literal not displayed */
}

func (*MonMap) Descriptor 

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

func (*MonMap) GetEpoch 

func (m *MonMap) GetEpoch() uint64

func (*MonMap) GetMonMap 

func (m *MonMap) GetMonMap() map[uint64]*Mon

func (*MonMap) Marshal 

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

func (*MonMap) MarshalTo 

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

func (*MonMap) ProtoMessage 

func (*MonMap) ProtoMessage()

func (*MonMap) Reset 

func (m *MonMap) Reset()

func (*MonMap) Size 

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

func (*MonMap) String 

func (m *MonMap) String() string

func (*MonMap) Unmarshal 

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

type MonitorClient 

type MonitorClient interface {
	GetMonMap(ctx context.Context, in *MonConfigRequest, opts ...grpc.CallOption) (*MonConfigReply, error)
	GetLayout(ctx context.Context, in *LayoutRequest, opts ...grpc.CallOption) (*LayoutReply, error)
	OsdConfig(ctx context.Context, in *OsdConfigRequest, opts ...grpc.CallOption) (*OsdConfigReply, error)
	PoolConfig(ctx context.Context, in *PoolConfigRequest, opts ...grpc.CallOption) (*PoolConfigReply, error)
	PgConfig(ctx context.Context, in *PgConfigRequest, opts ...grpc.CallOption) (*PgConfigReply, error)
	OsdStatusReport(ctx context.Context, in *OsdStatusReportRequest, opts ...grpc.CallOption) (*OsdStatusReportReply, error)
	GetPgStatus(ctx context.Context, in *GetPgStatusRequest, opts ...grpc.CallOption) (*GetPgStatusReply, error)
}

func NewMonitorClient 

func NewMonitorClient(cc *grpc.ClientConn) MonitorClient

type MonitorServer 

type MonitorServer interface {
	GetMonMap(context.Context, *MonConfigRequest) (*MonConfigReply, error)
	GetLayout(context.Context, *LayoutRequest) (*LayoutReply, error)
	OsdConfig(context.Context, *OsdConfigRequest) (*OsdConfigReply, error)
	PoolConfig(context.Context, *PoolConfigRequest) (*PoolConfigReply, error)
	PgConfig(context.Context, *PgConfigRequest) (*PgConfigReply, error)
	OsdStatusReport(context.Context, *OsdStatusReportRequest) (*OsdStatusReportReply, error)
	GetPgStatus(context.Context, *GetPgStatusRequest) (*GetPgStatusReply, error)
}

type Op 

type Op struct {
	Type   Op_OpType `protobuf:"varint,1,opt,name=type,proto3,enum=protos.Op_OpType" json:"type,omitempty"`
	Prefix string    `protobuf:"bytes,2,opt,name=prefix,proto3" json:"prefix,omitempty"`
	Key    string    `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
	EndKey string    `protobuf:"bytes,4,opt,name=endKey,proto3" json:"endKey,omitempty"`
	Data   []byte    `protobuf:"bytes,5,opt,name=data,proto3" json:"data,omitempty"`
}

func (*Op) Descriptor 

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

func (*Op) GetData 

func (m *Op) GetData() []byte

func (*Op) GetEndKey 

func (m *Op) GetEndKey() string

func (*Op) GetKey 

func (m *Op) GetKey() string

func (*Op) GetPrefix 

func (m *Op) GetPrefix() string

func (*Op) GetType 

func (m *Op) GetType() Op_OpType

func (*Op) Marshal 

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

func (*Op) MarshalTo 

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

func (*Op) ProtoMessage 

func (*Op) ProtoMessage()

func (*Op) Reset 

func (m *Op) Reset()

func (*Op) Size 

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

func (*Op) String 

func (m *Op) String() string

func (*Op) Unmarshal 

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

type Op_OpType 

type Op_OpType int32
const (
	Op_OP_PUT     Op_OpType = 0
	Op_OP_ERASE   Op_OpType = 1
	Op_OP_COMPACT Op_OpType = 2
)

func (Op_OpType) EnumDescriptor 

func (Op_OpType) EnumDescriptor() ([]byte, []int)

func (Op_OpType) String 

func (x Op_OpType) String() string

type Osd 

type Osd struct {
	Id     int32  `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Addr   string `protobuf:"bytes,2,opt,name=addr,proto3" json:"addr,omitempty"`
	Weight uint64 `protobuf:"varint,3,opt,name=weight,proto3" json:"weight,omitempty"`
	Host   string `protobuf:"bytes,4,opt,name=host,proto3" json:"host,omitempty"`
	Zone   string `protobuf:"bytes,5,opt,name=zone,proto3" json:"zone,omitempty"`
	Up     bool   `protobuf:"varint,6,opt,name=up,proto3" json:"up,omitempty"`
	In     bool   `protobuf:"varint,7,opt,name=in,proto3" json:"in,omitempty"`
}

func (*Osd) Descriptor 

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

func (*Osd) GetAddr 

func (m *Osd) GetAddr() string

func (*Osd) GetHost 

func (m *Osd) GetHost() string

func (*Osd) GetId 

func (m *Osd) GetId() int32

func (*Osd) GetIn 

func (m *Osd) GetIn() bool

func (*Osd) GetUp 

func (m *Osd) GetUp() bool

func (*Osd) GetWeight 

func (m *Osd) GetWeight() uint64

func (*Osd) GetZone 

func (m *Osd) GetZone() string

func (*Osd) Marshal 

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

func (*Osd) MarshalTo 

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

func (*Osd) ProtoMessage 

func (*Osd) ProtoMessage()

func (*Osd) Reset 

func (m *Osd) Reset()

func (*Osd) Size 

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

func (*Osd) String 

func (m *Osd) String() string

func (*Osd) Unmarshal 

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

type OsdConfigReply 

type OsdConfigReply struct {
	RetCode int32   `protobuf:"varint,1,opt,name=ret_code,json=retCode,proto3" json:"ret_code,omitempty"`
	Map     *OsdMap `protobuf:"bytes,2,opt,name=map" json:"map,omitempty"`
}

func (*OsdConfigReply) Descriptor 

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

func (*OsdConfigReply) GetMap 

func (m *OsdConfigReply) GetMap() *OsdMap

func (*OsdConfigReply) GetRetCode 

func (m *OsdConfigReply) GetRetCode() int32

func (*OsdConfigReply) Marshal 

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

func (*OsdConfigReply) MarshalTo 

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

func (*OsdConfigReply) ProtoMessage 

func (*OsdConfigReply) ProtoMessage()

func (*OsdConfigReply) Reset 

func (m *OsdConfigReply) Reset()

func (*OsdConfigReply) Size 

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

func (*OsdConfigReply) String 

func (m *OsdConfigReply) String() string

func (*OsdConfigReply) Unmarshal 

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

type OsdConfigRequest 

type OsdConfigRequest struct {
	KeyRing string                  `protobuf:"bytes,1,opt,name=keyRing,proto3" json:"keyRing,omitempty"`
	Osd     *Osd                    `protobuf:"bytes,2,opt,name=osd" json:"osd,omitempty"`
	OpType  OsdConfigRequest_OpType `protobuf:"varint,3,opt,name=op_type,json=opType,proto3,enum=protos.OsdConfigRequest_OpType" json:"op_type,omitempty"`
}

func (*OsdConfigRequest) Descriptor 

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

func (*OsdConfigRequest) GetKeyRing 

func (m *OsdConfigRequest) GetKeyRing() string

func (*OsdConfigRequest) GetOpType 

func (m *OsdConfigRequest) GetOpType() OsdConfigRequest_OpType

func (*OsdConfigRequest) GetOsd 

func (m *OsdConfigRequest) GetOsd() *Osd

func (*OsdConfigRequest) Marshal 

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

func (*OsdConfigRequest) MarshalTo 

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

func (*OsdConfigRequest) ProtoMessage 

func (*OsdConfigRequest) ProtoMessage()

func (*OsdConfigRequest) Reset 

func (m *OsdConfigRequest) Reset()

func (*OsdConfigRequest) Size 

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

func (*OsdConfigRequest) String 

func (m *OsdConfigRequest) String() string

func (*OsdConfigRequest) Unmarshal 

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

type OsdConfigRequest_OpType 

type OsdConfigRequest_OpType int32
const (
	OsdConfigRequest_ADD  OsdConfigRequest_OpType = 0
	OsdConfigRequest_DEL  OsdConfigRequest_OpType = 1
	OsdConfigRequest_IN   OsdConfigRequest_OpType = 2
	OsdConfigRequest_OUT  OsdConfigRequest_OpType = 3
	OsdConfigRequest_UP   OsdConfigRequest_OpType = 4
	OsdConfigRequest_DOWN OsdConfigRequest_OpType = 5
	OsdConfigRequest_LIST OsdConfigRequest_OpType = 6
)

func (OsdConfigRequest_OpType) EnumDescriptor 

func (OsdConfigRequest_OpType) EnumDescriptor() ([]byte, []int)

func (OsdConfigRequest_OpType) String 

func (x OsdConfigRequest_OpType) String() string

type OsdMap 

type OsdMap struct {
	Epoch      uint64         `protobuf:"varint,1,opt,name=epoch,proto3" json:"epoch,omitempty"`
	MemberList map[int32]*Osd `` /* 148-byte string literal not displayed */
}

func (*OsdMap) Descriptor 

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

func (*OsdMap) GetEpoch 

func (m *OsdMap) GetEpoch() uint64

func (*OsdMap) GetMemberList 

func (m *OsdMap) GetMemberList() map[int32]*Osd

func (*OsdMap) Marshal 

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

func (*OsdMap) MarshalTo 

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

func (*OsdMap) ProtoMessage 

func (*OsdMap) ProtoMessage()

func (*OsdMap) Reset 

func (m *OsdMap) Reset()

func (*OsdMap) Size 

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

func (*OsdMap) String 

func (m *OsdMap) String() string

func (*OsdMap) Unmarshal 

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

type OsdRpcClient 

type OsdRpcClient interface {
	CreatePg(ctx context.Context, in *CreatePgRequest, opts ...grpc.CallOption) (*CreatePgReply, error)
	DeletePg(ctx context.Context, in *DeletePgRequest, opts ...grpc.CallOption) (*DeletePgReply, error)
	SyncMap(ctx context.Context, in *SyncMapRequest, opts ...grpc.CallOption) (*SyncMapReply, error)
	MigrateGet(ctx context.Context, in *MigrateGetRequest, opts ...grpc.CallOption) (*MigrateGetReply, error)
}

func NewOsdRpcClient 

func NewOsdRpcClient(cc *grpc.ClientConn) OsdRpcClient

type OsdRpcServer 

type OsdRpcServer interface {
	CreatePg(context.Context, *CreatePgRequest) (*CreatePgReply, error)
	DeletePg(context.Context, *DeletePgRequest) (*DeletePgReply, error)
	SyncMap(context.Context, *SyncMapRequest) (*SyncMapReply, error)
	MigrateGet(context.Context, *MigrateGetRequest) (*MigrateGetReply, error)
}

type OsdStatusReportReply 

type OsdStatusReportReply struct {
	RetCode int32 `protobuf:"varint,1,opt,name=ret_code,json=retCode,proto3" json:"ret_code,omitempty"`
}

func (*OsdStatusReportReply) Descriptor 

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

func (*OsdStatusReportReply) GetRetCode 

func (m *OsdStatusReportReply) GetRetCode() int32

func (*OsdStatusReportReply) Marshal 

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

func (*OsdStatusReportReply) MarshalTo 

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

func (*OsdStatusReportReply) ProtoMessage 

func (*OsdStatusReportReply) ProtoMessage()

func (*OsdStatusReportReply) Reset 

func (m *OsdStatusReportReply) Reset()

func (*OsdStatusReportReply) Size 

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

func (*OsdStatusReportReply) String 

func (m *OsdStatusReportReply) String() string

func (*OsdStatusReportReply) Unmarshal 

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

type OsdStatusReportRequest 

type OsdStatusReportRequest struct {
	LeaderPgsStatus map[string]PgStatus `` /* 172-byte string literal not displayed */
}

func (*OsdStatusReportRequest) Descriptor 

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

func (*OsdStatusReportRequest) GetLeaderPgsStatus 

func (m *OsdStatusReportRequest) GetLeaderPgsStatus() map[string]PgStatus

func (*OsdStatusReportRequest) Marshal 

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

func (*OsdStatusReportRequest) MarshalTo 

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

func (*OsdStatusReportRequest) ProtoMessage 

func (*OsdStatusReportRequest) ProtoMessage()

func (*OsdStatusReportRequest) Reset 

func (m *OsdStatusReportRequest) Reset()

func (*OsdStatusReportRequest) Size 

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

func (*OsdStatusReportRequest) String 

func (m *OsdStatusReportRequest) String() string

func (*OsdStatusReportRequest) Unmarshal 

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

type Payload 

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

func (*Payload) Descriptor 

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

func (*Payload) GetData 

func (m *Payload) GetData() []byte

func (*Payload) Marshal 

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

func (*Payload) MarshalTo 

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

func (*Payload) ProtoMessage 

func (*Payload) ProtoMessage()

func (*Payload) Reset 

func (m *Payload) Reset()

func (*Payload) Size 

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

func (*Payload) String 

func (m *Payload) String() string

func (*Payload) Unmarshal 

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

type Pg 

type Pg struct {
	Id                int32       `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	PrimaryId         int32       `protobuf:"varint,2,opt,name=primary_id,json=primaryId,proto3" json:"primary_id,omitempty"`
	ExpectedPrimaryId int32       `protobuf:"varint,3,opt,name=expected_primary_id,json=expectedPrimaryId,proto3" json:"expected_primary_id,omitempty"`
	Replicas          []PgReplica `protobuf:"bytes,4,rep,name=replicas" json:"replicas"`
	NextReplicaId     int32       `protobuf:"varint,5,opt,name=next_replica_id,json=nextReplicaId,proto3" json:"next_replica_id,omitempty"`
	ParentId          int32       `protobuf:"varint,6,opt,name=parent_id,json=parentId,proto3" json:"parent_id,omitempty"`
	Clildren          []int32     `protobuf:"varint,7,rep,packed,name=clildren" json:"clildren,omitempty"`
}

func (*Pg) Descriptor 

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

func (*Pg) GetClildren 

func (m *Pg) GetClildren() []int32

func (*Pg) GetExpectedPrimaryId 

func (m *Pg) GetExpectedPrimaryId() int32

func (*Pg) GetId 

func (m *Pg) GetId() int32

func (*Pg) GetNextReplicaId 

func (m *Pg) GetNextReplicaId() int32

func (*Pg) GetParentId 

func (m *Pg) GetParentId() int32

func (*Pg) GetPrimaryId 

func (m *Pg) GetPrimaryId() int32

func (*Pg) GetReplicas 

func (m *Pg) GetReplicas() []PgReplica

func (*Pg) Marshal 

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

func (*Pg) MarshalTo 

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

func (*Pg) ProtoMessage 

func (*Pg) ProtoMessage()

func (*Pg) Reset 

func (m *Pg) Reset()

func (*Pg) Size 

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

func (*Pg) String 

func (m *Pg) String() string

func (*Pg) Unmarshal 

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

type PgConfigReply 

type PgConfigReply struct {
	RetCode   int32              `protobuf:"varint,1,opt,name=ret_code,json=retCode,proto3" json:"ret_code,omitempty"`
	Epoch     uint64             `protobuf:"varint,2,opt,name=epoch,proto3" json:"epoch,omitempty"`
	Map       *PgMap             `protobuf:"bytes,3,opt,name=map" json:"map,omitempty"`
	Maps      *PgMaps            `protobuf:"bytes,4,opt,name=maps" json:"maps,omitempty"`
	StatusMap map[int32]PgStatus `` /* 153-byte string literal not displayed */
}

func (*PgConfigReply) Descriptor 

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

func (*PgConfigReply) GetEpoch 

func (m *PgConfigReply) GetEpoch() uint64

func (*PgConfigReply) GetMap 

func (m *PgConfigReply) GetMap() *PgMap

func (*PgConfigReply) GetMaps 

func (m *PgConfigReply) GetMaps() *PgMaps

func (*PgConfigReply) GetRetCode 

func (m *PgConfigReply) GetRetCode() int32

func (*PgConfigReply) GetStatusMap 

func (m *PgConfigReply) GetStatusMap() map[int32]PgStatus

func (*PgConfigReply) Marshal 

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

func (*PgConfigReply) MarshalTo 

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

func (*PgConfigReply) ProtoMessage 

func (*PgConfigReply) ProtoMessage()

func (*PgConfigReply) Reset 

func (m *PgConfigReply) Reset()

func (*PgConfigReply) Size 

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

func (*PgConfigReply) String 

func (m *PgConfigReply) String() string

func (*PgConfigReply) Unmarshal 

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

type PgConfigRequest 

type PgConfigRequest struct {
	KeyRing string                 `protobuf:"bytes,1,opt,name=keyRing,proto3" json:"keyRing,omitempty"`
	OpType  PgConfigRequest_OpType `protobuf:"varint,2,opt,name=op_type,json=opType,proto3,enum=protos.PgConfigRequest_OpType" json:"op_type,omitempty"`
	Pool    string                 `protobuf:"bytes,3,opt,name=pool,proto3" json:"pool,omitempty"`
	Id      int32                  `protobuf:"varint,4,opt,name=id,proto3" json:"id,omitempty"`
	Epoch   uint64                 `protobuf:"varint,5,opt,name=epoch,proto3" json:"epoch,omitempty"`
}

func (*PgConfigRequest) Descriptor 

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

func (*PgConfigRequest) GetEpoch 

func (m *PgConfigRequest) GetEpoch() uint64

func (*PgConfigRequest) GetId 

func (m *PgConfigRequest) GetId() int32

func (*PgConfigRequest) GetKeyRing 

func (m *PgConfigRequest) GetKeyRing() string

func (*PgConfigRequest) GetOpType 

func (m *PgConfigRequest) GetOpType() PgConfigRequest_OpType

func (*PgConfigRequest) GetPool 

func (m *PgConfigRequest) GetPool() string

func (*PgConfigRequest) Marshal 

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

func (*PgConfigRequest) MarshalTo 

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

func (*PgConfigRequest) ProtoMessage 

func (*PgConfigRequest) ProtoMessage()

func (*PgConfigRequest) Reset 

func (m *PgConfigRequest) Reset()

func (*PgConfigRequest) Size 

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

func (*PgConfigRequest) String 

func (m *PgConfigRequest) String() string

func (*PgConfigRequest) Unmarshal 

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

type PgConfigRequest_OpType 

type PgConfigRequest_OpType int32
const (
	PgConfigRequest_ADD  PgConfigRequest_OpType = 0
	PgConfigRequest_DEL  PgConfigRequest_OpType = 1
	PgConfigRequest_EDT  PgConfigRequest_OpType = 2
	PgConfigRequest_LIST PgConfigRequest_OpType = 3
)

func (PgConfigRequest_OpType) EnumDescriptor 

func (PgConfigRequest_OpType) EnumDescriptor() ([]byte, []int)

func (PgConfigRequest_OpType) String 

func (x PgConfigRequest_OpType) String() string

type PgMap 

type PgMap struct {
	PoolId int32         `protobuf:"varint,1,opt,name=pool_id,json=poolId,proto3" json:"pool_id,omitempty"`
	Pgmap  map[int32]*Pg `` /* 138-byte string literal not displayed */
}

func (*PgMap) Descriptor 

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

func (*PgMap) GetPgmap 

func (m *PgMap) GetPgmap() map[int32]*Pg

func (*PgMap) GetPoolId 

func (m *PgMap) GetPoolId() int32

func (*PgMap) Marshal 

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

func (*PgMap) MarshalTo 

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

func (*PgMap) ProtoMessage 

func (*PgMap) ProtoMessage()

func (*PgMap) Reset 

func (m *PgMap) Reset()

func (*PgMap) Size 

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

func (*PgMap) String 

func (m *PgMap) String() string

func (*PgMap) Unmarshal 

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

type PgMaps 

type PgMaps struct {
	Epoch  uint64           `protobuf:"varint,1,opt,name=epoch,proto3" json:"epoch,omitempty"`
	Pgmaps map[int32]*PgMap `` /* 140-byte string literal not displayed */
}

func (*PgMaps) Descriptor 

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

func (*PgMaps) GetEpoch 

func (m *PgMaps) GetEpoch() uint64

func (*PgMaps) GetPgExpectedId 

func (m *PgMaps) GetPgExpectedId(pgId string) (int32, error)

func (*PgMaps) GetPgParentId 

func (m *PgMaps) GetPgParentId(pgId string) (string, error)

func (*PgMaps) GetPgReplicas 

func (m *PgMaps) GetPgReplicas(pgId string) ([]PgReplica, error)

func (*PgMaps) GetPgmaps 

func (m *PgMaps) GetPgmaps() map[int32]*PgMap

func (*PgMaps) GetRepLenInPgMap 

func (m *PgMaps) GetRepLenInPgMap(pgId string) (int32, error)

func (*PgMaps) Marshal 

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

func (*PgMaps) MarshalTo 

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

func (*PgMaps) ProtoMessage 

func (*PgMaps) ProtoMessage()

func (*PgMaps) Reset 

func (m *PgMaps) Reset()

func (*PgMaps) Size 

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

func (*PgMaps) String 

func (m *PgMaps) String() string

func (*PgMaps) Unmarshal 

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

type PgMembers 

type PgMembers struct {
	Members []PgReplica `protobuf:"bytes,1,rep,name=members" json:"members"`
}

func (*PgMembers) Descriptor 

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

func (*PgMembers) GetMembers 

func (m *PgMembers) GetMembers() []PgReplica

func (*PgMembers) Marshal 

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

func (*PgMembers) MarshalTo 

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

func (*PgMembers) ProtoMessage 

func (*PgMembers) ProtoMessage()

func (*PgMembers) Reset 

func (m *PgMembers) Reset()

func (*PgMembers) Size 

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

func (*PgMembers) String 

func (m *PgMembers) String() string

func (*PgMembers) Unmarshal 

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

type PgReplica 

type PgReplica struct {
	OsdId        int32 `protobuf:"varint,1,opt,name=osd_id,json=osdId,proto3" json:"osd_id,omitempty"`
	ReplicaIndex int32 `protobuf:"varint,2,opt,name=replica_index,json=replicaIndex,proto3" json:"replica_index,omitempty"`
}

func (*PgReplica) Descriptor 

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

func (*PgReplica) GetOsdId 

func (m *PgReplica) GetOsdId() int32

func (*PgReplica) GetReplicaIndex 

func (m *PgReplica) GetReplicaIndex() int32

func (*PgReplica) Marshal 

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

func (*PgReplica) MarshalTo 

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

func (*PgReplica) ProtoMessage 

func (*PgReplica) ProtoMessage()

func (*PgReplica) Reset 

func (m *PgReplica) Reset()

func (*PgReplica) Size 

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

func (*PgReplica) String 

func (m *PgReplica) String() string

func (*PgReplica) Unmarshal 

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

type PgStatus 

type PgStatus struct {
	LeaderNodeId int32     `protobuf:"varint,1,opt,name=leader_node_id,json=leaderNodeId,proto3" json:"leader_node_id,omitempty"`
	Status       int32     `protobuf:"varint,2,opt,name=status,proto3" json:"status,omitempty"`
	MigratedCnt  int64     `protobuf:"varint,3,opt,name=migrated_cnt,json=migratedCnt,proto3" json:"migrated_cnt,omitempty"`
	Replicas     PgMembers `protobuf:"bytes,4,opt,name=replicas" json:"replicas"`
}

func (*PgStatus) Descriptor 

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

func (*PgStatus) GetLeaderNodeId 

func (m *PgStatus) GetLeaderNodeId() int32

func (*PgStatus) GetMigratedCnt 

func (m *PgStatus) GetMigratedCnt() int64

func (*PgStatus) GetReplicas 

func (m *PgStatus) GetReplicas() PgMembers

func (*PgStatus) GetStatus 

func (m *PgStatus) GetStatus() int32

func (*PgStatus) Marshal 

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

func (*PgStatus) MarshalTo 

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

func (*PgStatus) ProtoMessage 

func (*PgStatus) ProtoMessage()

func (*PgStatus) Reset 

func (m *PgStatus) Reset()

func (*PgStatus) Size 

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

func (*PgStatus) StatusClear 

func (ps *PgStatus) StatusClear(m int32)

func (*PgStatus) StatusSet 

func (ps *PgStatus) StatusSet(m int32)

func (*PgStatus) StatusTest 

func (ps *PgStatus) StatusTest(m int32) bool

func (*PgStatus) String 

func (m *PgStatus) String() string

func (*PgStatus) Unmarshal 

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

type Pool 

type Pool struct {
	Id        int32            `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Name      string           `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Size_     int32            `protobuf:"varint,3,opt,name=size,proto3" json:"size,omitempty"`
	PgNumbers int32            `protobuf:"varint,4,opt,name=pg_numbers,json=pgNumbers,proto3" json:"pg_numbers,omitempty"`
	Policy    DistributePolicy `protobuf:"varint,5,opt,name=policy,proto3,enum=protos.DistributePolicy" json:"policy,omitempty"`
}

func (*Pool) Descriptor 

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

func (*Pool) GetId 

func (m *Pool) GetId() int32

func (*Pool) GetName 

func (m *Pool) GetName() string

func (*Pool) GetPgNumbers 

func (m *Pool) GetPgNumbers() int32

func (*Pool) GetPolicy 

func (m *Pool) GetPolicy() DistributePolicy

func (*Pool) GetSize_ 

func (m *Pool) GetSize_() int32

func (*Pool) Marshal 

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

func (*Pool) MarshalTo 

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

func (*Pool) ProtoMessage 

func (*Pool) ProtoMessage()

func (*Pool) Reset 

func (m *Pool) Reset()

func (*Pool) Size 

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

func (*Pool) String 

func (m *Pool) String() string

func (*Pool) Unmarshal 

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

type PoolConfigReply 

type PoolConfigReply struct {
	RetCode int32    `protobuf:"varint,1,opt,name=ret_code,json=retCode,proto3" json:"ret_code,omitempty"`
	Map     *PoolMap `protobuf:"bytes,2,opt,name=map" json:"map,omitempty"`
}

func (*PoolConfigReply) Descriptor 

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

func (*PoolConfigReply) GetMap 

func (m *PoolConfigReply) GetMap() *PoolMap

func (*PoolConfigReply) GetRetCode 

func (m *PoolConfigReply) GetRetCode() int32

func (*PoolConfigReply) Marshal 

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

func (*PoolConfigReply) MarshalTo 

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

func (*PoolConfigReply) ProtoMessage 

func (*PoolConfigReply) ProtoMessage()

func (*PoolConfigReply) Reset 

func (m *PoolConfigReply) Reset()

func (*PoolConfigReply) Size 

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

func (*PoolConfigReply) String 

func (m *PoolConfigReply) String() string

func (*PoolConfigReply) Unmarshal 

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

type PoolConfigRequest 

type PoolConfigRequest struct {
	KeyRing   string                   `protobuf:"bytes,1,opt,name=keyRing,proto3" json:"keyRing,omitempty"`
	OpType    PoolConfigRequest_OpType `protobuf:"varint,2,opt,name=op_type,json=opType,proto3,enum=protos.PoolConfigRequest_OpType" json:"op_type,omitempty"`
	Name      string                   `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	Size_     int32                    `protobuf:"varint,4,opt,name=size,proto3" json:"size,omitempty"`
	PgNumbers int32                    `protobuf:"varint,5,opt,name=pg_numbers,json=pgNumbers,proto3" json:"pg_numbers,omitempty"`
	Policy    DistributePolicy         `protobuf:"varint,6,opt,name=policy,proto3,enum=protos.DistributePolicy" json:"policy,omitempty"`
}

func (*PoolConfigRequest) Descriptor 

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

func (*PoolConfigRequest) GetKeyRing 

func (m *PoolConfigRequest) GetKeyRing() string

func (*PoolConfigRequest) GetName 

func (m *PoolConfigRequest) GetName() string

func (*PoolConfigRequest) GetOpType 

func (m *PoolConfigRequest) GetOpType() PoolConfigRequest_OpType

func (*PoolConfigRequest) GetPgNumbers 

func (m *PoolConfigRequest) GetPgNumbers() int32

func (*PoolConfigRequest) GetPolicy 

func (m *PoolConfigRequest) GetPolicy() DistributePolicy

func (*PoolConfigRequest) GetSize_ 

func (m *PoolConfigRequest) GetSize_() int32

func (*PoolConfigRequest) Marshal 

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

func (*PoolConfigRequest) MarshalTo 

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

func (*PoolConfigRequest) ProtoMessage 

func (*PoolConfigRequest) ProtoMessage()

func (*PoolConfigRequest) Reset 

func (m *PoolConfigRequest) Reset()

func (*PoolConfigRequest) Size 

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

func (*PoolConfigRequest) String 

func (m *PoolConfigRequest) String() string

func (*PoolConfigRequest) Unmarshal 

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

type PoolConfigRequest_OpType 

type PoolConfigRequest_OpType int32
const (
	PoolConfigRequest_ADD      PoolConfigRequest_OpType = 0
	PoolConfigRequest_DEL      PoolConfigRequest_OpType = 1
	PoolConfigRequest_LIST     PoolConfigRequest_OpType = 2
	PoolConfigRequest_SET_SIZE PoolConfigRequest_OpType = 3
	PoolConfigRequest_SET_PGS  PoolConfigRequest_OpType = 4
)

func (PoolConfigRequest_OpType) EnumDescriptor 

func (PoolConfigRequest_OpType) EnumDescriptor() ([]byte, []int)

func (PoolConfigRequest_OpType) String 

func (x PoolConfigRequest_OpType) String() string

type PoolMap 

type PoolMap struct {
	Epoch uint64          `protobuf:"varint,1,opt,name=epoch,proto3" json:"epoch,omitempty"`
	Pools map[int32]*Pool `` /* 138-byte string literal not displayed */
}

func (*PoolMap) Descriptor 

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

func (*PoolMap) GetEpoch 

func (m *PoolMap) GetEpoch() uint64

func (*PoolMap) GetPoolSize 

func (m *PoolMap) GetPoolSize(pgId string) (int32, error)

func (*PoolMap) GetPools 

func (m *PoolMap) GetPools() map[int32]*Pool

func (*PoolMap) Marshal 

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

func (*PoolMap) MarshalTo 

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

func (*PoolMap) ProtoMessage 

func (*PoolMap) ProtoMessage()

func (*PoolMap) Reset 

func (m *PoolMap) Reset()

func (*PoolMap) Size 

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

func (*PoolMap) String 

func (m *PoolMap) String() string

func (*PoolMap) Unmarshal 

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

type Proposal 

type Proposal struct {
	Id   uint32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Data []byte `protobuf:"bytes,2,opt,name=Data,proto3" json:"Data,omitempty"`
}

func (*Proposal) Descriptor 

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

func (*Proposal) GetData 

func (m *Proposal) GetData() []byte

func (*Proposal) GetId 

func (m *Proposal) GetId() uint32

func (*Proposal) Marshal 

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

func (*Proposal) MarshalTo 

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

func (*Proposal) ProtoMessage 

func (*Proposal) ProtoMessage()

func (*Proposal) Reset 

func (m *Proposal) Reset()

func (*Proposal) Size 

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

func (*Proposal) String 

func (m *Proposal) String() string

func (*Proposal) Unmarshal 

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

type RaftContext 

type RaftContext struct {
	Id    uint64 `protobuf:"fixed64,1,opt,name=id,proto3" json:"id,omitempty"`
	Group uint32 `protobuf:"varint,2,opt,name=group,proto3" json:"group,omitempty"`
	Addr  string `protobuf:"bytes,3,opt,name=addr,proto3" json:"addr,omitempty"`
}

func (*RaftContext) Descriptor 

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

func (*RaftContext) GetAddr 

func (m *RaftContext) GetAddr() string

func (*RaftContext) GetGroup 

func (m *RaftContext) GetGroup() uint32

func (*RaftContext) GetId 

func (m *RaftContext) GetId() uint64

func (*RaftContext) Marshal 

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

func (*RaftContext) MarshalTo 

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

func (*RaftContext) ProtoMessage 

func (*RaftContext) ProtoMessage()

func (*RaftContext) Reset 

func (m *RaftContext) Reset()

func (*RaftContext) Size 

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

func (*RaftContext) String 

func (m *RaftContext) String() string

func (*RaftContext) Unmarshal 

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

type RaftNodeClient 

type RaftNodeClient interface {
	// Connection testing RPC.
	Echo(ctx context.Context, in *Payload, opts ...grpc.CallOption) (*Payload, error)
	// RAFT serving RPCs.
	RaftMessage(ctx context.Context, in *Payload, opts ...grpc.CallOption) (*Payload, error)
	JoinCluster(ctx context.Context, in *RaftContext, opts ...grpc.CallOption) (*Payload, error)
}

func NewRaftNodeClient 

func NewRaftNodeClient(cc *grpc.ClientConn) RaftNodeClient

type RaftNodeServer 

type RaftNodeServer interface {
	// Connection testing RPC.
	Echo(context.Context, *Payload) (*Payload, error)
	// RAFT serving RPCs.
	RaftMessage(context.Context, *Payload) (*Payload, error)
	JoinCluster(context.Context, *RaftContext) (*Payload, error)
}

type SyncMapReply 

type SyncMapReply struct {
	RetCode int32 `protobuf:"varint,1,opt,name=ret_code,json=retCode,proto3" json:"ret_code,omitempty"`
}

func (*SyncMapReply) Descriptor 

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

func (*SyncMapReply) GetRetCode 

func (m *SyncMapReply) GetRetCode() int32

func (*SyncMapReply) Marshal 

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

func (*SyncMapReply) MarshalTo 

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

func (*SyncMapReply) ProtoMessage 

func (*SyncMapReply) ProtoMessage()

func (*SyncMapReply) Reset 

func (m *SyncMapReply) Reset()

func (*SyncMapReply) Size 

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

func (*SyncMapReply) String 

func (m *SyncMapReply) String() string

func (*SyncMapReply) Unmarshal 

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

type SyncMapRequest 

type SyncMapRequest struct {
	MapType  SyncMapType `protobuf:"varint,1,opt,name=map_type,json=mapType,proto3,enum=protos.SyncMapType" json:"map_type,omitempty"`
	UnionMap UnionMap    `protobuf:"bytes,2,opt,name=union_map,json=unionMap" json:"union_map"`
}

func (*SyncMapRequest) Descriptor 

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

func (*SyncMapRequest) GetMapType 

func (m *SyncMapRequest) GetMapType() SyncMapType

func (*SyncMapRequest) GetUnionMap 

func (m *SyncMapRequest) GetUnionMap() UnionMap

func (*SyncMapRequest) Marshal 

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

func (*SyncMapRequest) MarshalTo 

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

func (*SyncMapRequest) ProtoMessage 

func (*SyncMapRequest) ProtoMessage()

func (*SyncMapRequest) Reset 

func (m *SyncMapRequest) Reset()

func (*SyncMapRequest) Size 

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

func (*SyncMapRequest) String 

func (m *SyncMapRequest) String() string

func (*SyncMapRequest) Unmarshal 

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

type SyncMapType 

type SyncMapType int32
const (
	// CONSISTENT reads are guaranteed to read committed data; the
	// mechanism relies on clocks to determine lease expirations.
	PGMAP SyncMapType = 0
	// CONSENSUS requires that reads must achieve consensus. This is a
	// stronger guarantee of consistency than CONSISTENT.
	//
	// TODO(spencer): current unimplemented.
	OSDMAP SyncMapType = 1
	// INCONSISTENT reads return the latest available, committed values.
	// They are more efficient, but may read stale values as pending
	// intents are ignored.
	POOLMAP SyncMapType = 2
)

func (SyncMapType) EnumDescriptor 

func (SyncMapType) EnumDescriptor() ([]byte, []int)

func (SyncMapType) String 

func (x SyncMapType) String() string

type Transaction 

type Transaction struct {
	Ops   []*Op  `protobuf:"bytes,1,rep,name=ops" json:"ops,omitempty"`
	Bytes uint64 `protobuf:"varint,2,opt,name=bytes,proto3" json:"bytes,omitempty"`
	Keys  uint64 `protobuf:"varint,3,opt,name=keys,proto3" json:"keys,omitempty"`
}

func (*Transaction) Descriptor 

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

func (*Transaction) GetBytes 

func (m *Transaction) GetBytes() uint64

func (*Transaction) GetKeys 

func (m *Transaction) GetKeys() uint64

func (*Transaction) GetOps 

func (m *Transaction) GetOps() []*Op

func (*Transaction) Marshal 

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

func (*Transaction) MarshalTo 

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

func (*Transaction) ProtoMessage 

func (*Transaction) ProtoMessage()

func (*Transaction) Reset 

func (m *Transaction) Reset()

func (*Transaction) Size 

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

func (*Transaction) String 

func (m *Transaction) String() string

func (*Transaction) Unmarshal 

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

type UnionMap 

type UnionMap struct {
	Pgmap   *PgMaps  `protobuf:"bytes,1,opt,name=pgmap" json:"pgmap,omitempty"`
	Poolmap *PoolMap `protobuf:"bytes,2,opt,name=poolmap" json:"poolmap,omitempty"`
	Osdmap  *OsdMap  `protobuf:"bytes,3,opt,name=osdmap" json:"osdmap,omitempty"`
}

func (*UnionMap) Descriptor 

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

func (*UnionMap) GetOsdmap 

func (m *UnionMap) GetOsdmap() *OsdMap

func (*UnionMap) GetPgmap 

func (m *UnionMap) GetPgmap() *PgMaps

func (*UnionMap) GetPoolmap 

func (m *UnionMap) GetPoolmap() *PoolMap

func (*UnionMap) GetValue 

func (this *UnionMap) GetValue() interface{}

func (*UnionMap) Marshal 

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

func (*UnionMap) MarshalTo 

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

func (*UnionMap) ProtoMessage 

func (*UnionMap) ProtoMessage()

func (*UnionMap) Reset 

func (m *UnionMap) Reset()

func (*UnionMap) SetValue 

func (this *UnionMap) SetValue(value interface{}) bool

func (*UnionMap) Size 

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

func (*UnionMap) String 

func (m *UnionMap) String() string

func (*UnionMap) Unmarshal 

func (m *UnionMap) Unmarshal(dAtA []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.