proto

package
v0.1.4 Latest Latest
Warning

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

 Go to latest Published: Oct 19, 2018 License: Apache-2.0 Imports: 4 Imported by: 6

Documentation

Index

Constants

View Source 
const (
	ActionLeaderNotify byte = 0xa1 // 通知Leader服务地址
	ActionRecycle      byte = 0xa2 // 通知所有结点进行资源清理与重用
	ActionRegistQuota  byte = 0x01 // 在所有结点注册资源配额
	ActionDeleteQuota  byte = 0x02 // 在锁哟结点删除资源配额
	ActionBorrow       byte = 0x03 // 在所有结点进行借资源的操作
	ActionReturn       byte = 0x04 // 在所有结点进行归还资源的操作
	ActionReturnAll    byte = 0x05 // 归还client申请的所有资源
)

Raft结点间通信的动作类型

View Source 
const (
	RaftStorageMemory = "memory"
	RaftStorageBoltDB = "boltdb"
)

Raft数据存储介质

View Source 
const (
	RegistQuotaURI  = "/v1/registQuota"
	DeleteQuotaURI  = "/v1/deleteQuota"
	BorrowURI       = "/v1/borrow"
	ReturnURI       = "/v1/return"
	ReturnAllURI    = "/v1/returnAll"
	ResourceListURI = "/v1/rc"
)

HTTP请求URI

Variables

View Source 
var (
	ErrTooBusy             = errors.New("Too busy")
	ErrLeaderNotFound      = errors.New("Leader not found")
	ErrQuotaNotEnough      = errors.New("Quota is not enough")
	ErrExisted             = errors.New("Had been existed")
	ErrResourceNotRegisted = errors.New("Resource didn't regist")
	ErrNoBorrowRecordFound = errors.New("No borrow record found")
	ErrQuotaOverflow       = errors.New("Quota overflow")
)
View Source 
var MagicNumber byte = 0x66

魔数

View Source 
var ProtocolVersion byte = 0x01

快照协议版本

Functions

This section is empty.

Types

type APIBorrowReq 

type APIBorrowReq struct {
	RCType   []byte `protobuf:"bytes,1,opt,name=RCType,proto3" json:"RCType,omitempty"`
	ClientID []byte `protobuf:"bytes,2,opt,name=ClientID,proto3" json:"ClientID,omitempty"`
	Expire   int64  `protobuf:"varint,3,opt,name=Expire,proto3" json:"Expire,omitempty"`
	// 以下字段仅内部使用
	Timestamp            int64    `protobuf:"varint,4,opt,name=Timestamp,proto3" json:"Timestamp,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

APIBorrowReq 借用资源请求格式

func (*APIBorrowReq) Descriptor 

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

func (*APIBorrowReq) GetClientID 

func (m *APIBorrowReq) GetClientID() []byte

func (*APIBorrowReq) GetExpire 

func (m *APIBorrowReq) GetExpire() int64

func (*APIBorrowReq) GetRCType 

func (m *APIBorrowReq) GetRCType() []byte

func (*APIBorrowReq) GetTimestamp 

func (m *APIBorrowReq) GetTimestamp() int64

func (*APIBorrowReq) ProtoMessage 

func (*APIBorrowReq) ProtoMessage()

func (*APIBorrowReq) Reset 

func (m *APIBorrowReq) Reset()

func (*APIBorrowReq) String 

func (m *APIBorrowReq) String() string

func (*APIBorrowReq) XXX_DiscardUnknown 

func (m *APIBorrowReq) XXX_DiscardUnknown()

func (*APIBorrowReq) XXX_Marshal 

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

func (*APIBorrowReq) XXX_Merge 

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

func (*APIBorrowReq) XXX_Size 

func (m *APIBorrowReq) XXX_Size() int

func (*APIBorrowReq) XXX_Unmarshal 

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

type APIBorrowResp 

type APIBorrowResp struct {
	Code                 uint32   `protobuf:"varint,1,opt,name=Code,proto3" json:"Code,omitempty"`
	Msg                  string   `protobuf:"bytes,2,opt,name=Msg,proto3" json:"Msg,omitempty"`
	RCID                 string   `protobuf:"bytes,3,opt,name=RCID,proto3" json:"RCID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

APIBorrowResp 借用资源响应格式

func (*APIBorrowResp) Descriptor 

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

func (*APIBorrowResp) GetCode 

func (m *APIBorrowResp) GetCode() uint32

func (*APIBorrowResp) GetMsg 

func (m *APIBorrowResp) GetMsg() string

func (*APIBorrowResp) GetRCID 

func (m *APIBorrowResp) GetRCID() string

func (*APIBorrowResp) ProtoMessage 

func (*APIBorrowResp) ProtoMessage()

func (*APIBorrowResp) Reset 

func (m *APIBorrowResp) Reset()

func (*APIBorrowResp) String 

func (m *APIBorrowResp) String() string

func (*APIBorrowResp) XXX_DiscardUnknown 

func (m *APIBorrowResp) XXX_DiscardUnknown()

func (*APIBorrowResp) XXX_Marshal 

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

func (*APIBorrowResp) XXX_Merge 

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

func (*APIBorrowResp) XXX_Size 

func (m *APIBorrowResp) XXX_Size() int

func (*APIBorrowResp) XXX_Unmarshal 

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

type APIDeleteQuotaReq 

type APIDeleteQuotaReq struct {
	RCType               []byte   `protobuf:"bytes,1,opt,name=RCType,proto3" json:"RCType,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

APIDeleteQuotaReq 删除资源配额请求格式

func (*APIDeleteQuotaReq) Descriptor 

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

func (*APIDeleteQuotaReq) GetRCType 

func (m *APIDeleteQuotaReq) GetRCType() []byte

func (*APIDeleteQuotaReq) ProtoMessage 

func (*APIDeleteQuotaReq) ProtoMessage()

func (*APIDeleteQuotaReq) Reset 

func (m *APIDeleteQuotaReq) Reset()

func (*APIDeleteQuotaReq) String 

func (m *APIDeleteQuotaReq) String() string

func (*APIDeleteQuotaReq) XXX_DiscardUnknown 

func (m *APIDeleteQuotaReq) XXX_DiscardUnknown()

func (*APIDeleteQuotaReq) XXX_Marshal 

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

func (*APIDeleteQuotaReq) XXX_Merge 

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

func (*APIDeleteQuotaReq) XXX_Size 

func (m *APIDeleteQuotaReq) XXX_Size() int

func (*APIDeleteQuotaReq) XXX_Unmarshal 

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

type APIDeleteQuotaResp 

type APIDeleteQuotaResp struct {
	Code                 uint32   `protobuf:"varint,1,opt,name=Code,proto3" json:"Code,omitempty"`
	Msg                  string   `protobuf:"bytes,2,opt,name=Msg,proto3" json:"Msg,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

APIDeleteQuotaResp 删除资源配额响应格式

func (*APIDeleteQuotaResp) Descriptor 

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

func (*APIDeleteQuotaResp) GetCode 

func (m *APIDeleteQuotaResp) GetCode() uint32

func (*APIDeleteQuotaResp) GetMsg 

func (m *APIDeleteQuotaResp) GetMsg() string

func (*APIDeleteQuotaResp) ProtoMessage 

func (*APIDeleteQuotaResp) ProtoMessage()

func (*APIDeleteQuotaResp) Reset 

func (m *APIDeleteQuotaResp) Reset()

func (*APIDeleteQuotaResp) String 

func (m *APIDeleteQuotaResp) String() string

func (*APIDeleteQuotaResp) XXX_DiscardUnknown 

func (m *APIDeleteQuotaResp) XXX_DiscardUnknown()

func (*APIDeleteQuotaResp) XXX_Marshal 

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

func (*APIDeleteQuotaResp) XXX_Merge 

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

func (*APIDeleteQuotaResp) XXX_Size 

func (m *APIDeleteQuotaResp) XXX_Size() int

func (*APIDeleteQuotaResp) XXX_Unmarshal 

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

type APIRegistQuotaReq 

type APIRegistQuotaReq struct {
	RCType        []byte `protobuf:"bytes,1,opt,name=RCType,proto3" json:"RCType,omitempty"`
	Quota         uint32 `protobuf:"varint,2,opt,name=Quota,proto3" json:"Quota,omitempty"`
	ResetInterval int64  `protobuf:"varint,3,opt,name=ResetInterval,proto3" json:"ResetInterval,omitempty"`
	// 以下字段仅内部使用
	Timestamp            int64    `protobuf:"varint,4,opt,name=Timestamp,proto3" json:"Timestamp,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

APIRegistQuotaReq 注册资源请求格式

func (*APIRegistQuotaReq) Descriptor 

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

func (*APIRegistQuotaReq) GetQuota 

func (m *APIRegistQuotaReq) GetQuota() uint32

func (*APIRegistQuotaReq) GetRCType 

func (m *APIRegistQuotaReq) GetRCType() []byte

func (*APIRegistQuotaReq) GetResetInterval 

func (m *APIRegistQuotaReq) GetResetInterval() int64

func (*APIRegistQuotaReq) GetTimestamp 

func (m *APIRegistQuotaReq) GetTimestamp() int64

func (*APIRegistQuotaReq) ProtoMessage 

func (*APIRegistQuotaReq) ProtoMessage()

func (*APIRegistQuotaReq) Reset 

func (m *APIRegistQuotaReq) Reset()

func (*APIRegistQuotaReq) String 

func (m *APIRegistQuotaReq) String() string

func (*APIRegistQuotaReq) XXX_DiscardUnknown 

func (m *APIRegistQuotaReq) XXX_DiscardUnknown()

func (*APIRegistQuotaReq) XXX_Marshal 

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

func (*APIRegistQuotaReq) XXX_Merge 

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

func (*APIRegistQuotaReq) XXX_Size 

func (m *APIRegistQuotaReq) XXX_Size() int

func (*APIRegistQuotaReq) XXX_Unmarshal 

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

type APIRegistQuotaResp 

type APIRegistQuotaResp struct {
	Code                 uint32   `protobuf:"varint,1,opt,name=Code,proto3" json:"Code,omitempty"`
	Msg                  string   `protobuf:"bytes,2,opt,name=Msg,proto3" json:"Msg,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

APIRegistQuotaResp 注册资源响应格式

func (*APIRegistQuotaResp) Descriptor 

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

func (*APIRegistQuotaResp) GetCode 

func (m *APIRegistQuotaResp) GetCode() uint32

func (*APIRegistQuotaResp) GetMsg 

func (m *APIRegistQuotaResp) GetMsg() string

func (*APIRegistQuotaResp) ProtoMessage 

func (*APIRegistQuotaResp) ProtoMessage()

func (*APIRegistQuotaResp) Reset 

func (m *APIRegistQuotaResp) Reset()

func (*APIRegistQuotaResp) String 

func (m *APIRegistQuotaResp) String() string

func (*APIRegistQuotaResp) XXX_DiscardUnknown 

func (m *APIRegistQuotaResp) XXX_DiscardUnknown()

func (*APIRegistQuotaResp) XXX_Marshal 

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

func (*APIRegistQuotaResp) XXX_Merge 

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

func (*APIRegistQuotaResp) XXX_Size 

func (m *APIRegistQuotaResp) XXX_Size() int

func (*APIRegistQuotaResp) XXX_Unmarshal 

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

type APIResourceDetail 

type APIResourceDetail struct {
	RCType               []byte   `protobuf:"bytes,1,opt,name=RCType,proto3" json:"RCType,omitempty"`
	Quota                uint32   `protobuf:"varint,2,opt,name=Quota,proto3" json:"Quota,omitempty"`
	ResetInterval        int64    `protobuf:"varint,3,opt,name=ResetInterval,proto3" json:"ResetInterval,omitempty"`
	CanBorrowCount       uint32   `protobuf:"varint,4,opt,name=CanBorrowCount,proto3" json:"CanBorrowCount,omitempty"`
	RecycledCount        uint32   `protobuf:"varint,5,opt,name=RecycledCount,proto3" json:"RecycledCount,omitempty"`
	UsedCount            uint32   `protobuf:"varint,6,opt,name=UsedCount,proto3" json:"UsedCount,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

APIResourceDetail 某资源详情信息

func (*APIResourceDetail) Descriptor 

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

func (*APIResourceDetail) GetCanBorrowCount 

func (m *APIResourceDetail) GetCanBorrowCount() uint32

func (*APIResourceDetail) GetQuota 

func (m *APIResourceDetail) GetQuota() uint32

func (*APIResourceDetail) GetRCType 

func (m *APIResourceDetail) GetRCType() []byte

func (*APIResourceDetail) GetRecycledCount 

func (m *APIResourceDetail) GetRecycledCount() uint32

func (*APIResourceDetail) GetResetInterval 

func (m *APIResourceDetail) GetResetInterval() int64

func (*APIResourceDetail) GetUsedCount 

func (m *APIResourceDetail) GetUsedCount() uint32

func (*APIResourceDetail) ProtoMessage 

func (*APIResourceDetail) ProtoMessage()

func (*APIResourceDetail) Reset 

func (m *APIResourceDetail) Reset()

func (*APIResourceDetail) String 

func (m *APIResourceDetail) String() string

func (*APIResourceDetail) XXX_DiscardUnknown 

func (m *APIResourceDetail) XXX_DiscardUnknown()

func (*APIResourceDetail) XXX_Marshal 

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

func (*APIResourceDetail) XXX_Merge 

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

func (*APIResourceDetail) XXX_Size 

func (m *APIResourceDetail) XXX_Size() int

func (*APIResourceDetail) XXX_Unmarshal 

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

type APIResourceListReq 

type APIResourceListReq struct {
	RCType               []byte   `protobuf:"bytes,1,opt,name=RCType,proto3" json:"RCType,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

APIResourceListReq 查询资源列表的请求格式

func (*APIResourceListReq) Descriptor 

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

func (*APIResourceListReq) GetRCType 

func (m *APIResourceListReq) GetRCType() []byte

func (*APIResourceListReq) ProtoMessage 

func (*APIResourceListReq) ProtoMessage()

func (*APIResourceListReq) Reset 

func (m *APIResourceListReq) Reset()

func (*APIResourceListReq) String 

func (m *APIResourceListReq) String() string

func (*APIResourceListReq) XXX_DiscardUnknown 

func (m *APIResourceListReq) XXX_DiscardUnknown()

func (*APIResourceListReq) XXX_Marshal 

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

func (*APIResourceListReq) XXX_Merge 

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

func (*APIResourceListReq) XXX_Size 

func (m *APIResourceListReq) XXX_Size() int

func (*APIResourceListReq) XXX_Unmarshal 

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

type APIResourceListResp 

type APIResourceListResp struct {
	Code                 uint32               `protobuf:"varint,1,opt,name=Code,proto3" json:"Code,omitempty"`
	Msg                  string               `protobuf:"bytes,2,opt,name=Msg,proto3" json:"Msg,omitempty"`
	RCList               []*APIResourceDetail `protobuf:"bytes,3,rep,name=RCList,proto3" json:"RCList,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

APIResourceListResp 查询资源列表的响应格式

func (*APIResourceListResp) Descriptor 

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

func (*APIResourceListResp) GetCode 

func (m *APIResourceListResp) GetCode() uint32

func (*APIResourceListResp) GetMsg 

func (m *APIResourceListResp) GetMsg() string

func (*APIResourceListResp) GetRCList 

func (m *APIResourceListResp) GetRCList() []*APIResourceDetail

func (*APIResourceListResp) ProtoMessage 

func (*APIResourceListResp) ProtoMessage()

func (*APIResourceListResp) Reset 

func (m *APIResourceListResp) Reset()

func (*APIResourceListResp) String 

func (m *APIResourceListResp) String() string

func (*APIResourceListResp) XXX_DiscardUnknown 

func (m *APIResourceListResp) XXX_DiscardUnknown()

func (*APIResourceListResp) XXX_Marshal 

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

func (*APIResourceListResp) XXX_Merge 

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

func (*APIResourceListResp) XXX_Size 

func (m *APIResourceListResp) XXX_Size() int

func (*APIResourceListResp) XXX_Unmarshal 

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

type APIReturnAllReq 

type APIReturnAllReq struct {
	ClientID             []byte   `protobuf:"bytes,1,opt,name=ClientID,proto3" json:"ClientID,omitempty"`
	RCType               []byte   `protobuf:"bytes,2,opt,name=RCType,proto3" json:"RCType,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

APIReturnAllReq 客户端释放对某资源占用的请求格式

func (*APIReturnAllReq) Descriptor 

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

func (*APIReturnAllReq) GetClientID 

func (m *APIReturnAllReq) GetClientID() []byte

func (*APIReturnAllReq) GetRCType 

func (m *APIReturnAllReq) GetRCType() []byte

func (*APIReturnAllReq) ProtoMessage 

func (*APIReturnAllReq) ProtoMessage()

func (*APIReturnAllReq) Reset 

func (m *APIReturnAllReq) Reset()

func (*APIReturnAllReq) String 

func (m *APIReturnAllReq) String() string

func (*APIReturnAllReq) XXX_DiscardUnknown 

func (m *APIReturnAllReq) XXX_DiscardUnknown()

func (*APIReturnAllReq) XXX_Marshal 

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

func (*APIReturnAllReq) XXX_Merge 

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

func (*APIReturnAllReq) XXX_Size 

func (m *APIReturnAllReq) XXX_Size() int

func (*APIReturnAllReq) XXX_Unmarshal 

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

type APIReturnAllResp 

type APIReturnAllResp struct {
	Code                 uint32   `protobuf:"varint,1,opt,name=Code,proto3" json:"Code,omitempty"`
	Msg                  string   `protobuf:"bytes,2,opt,name=Msg,proto3" json:"Msg,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

APIReturnAllResp 客户端释放对某资源占用的响应格式

func (*APIReturnAllResp) Descriptor 

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

func (*APIReturnAllResp) GetCode 

func (m *APIReturnAllResp) GetCode() uint32

func (*APIReturnAllResp) GetMsg 

func (m *APIReturnAllResp) GetMsg() string

func (*APIReturnAllResp) ProtoMessage 

func (*APIReturnAllResp) ProtoMessage()

func (*APIReturnAllResp) Reset 

func (m *APIReturnAllResp) Reset()

func (*APIReturnAllResp) String 

func (m *APIReturnAllResp) String() string

func (*APIReturnAllResp) XXX_DiscardUnknown 

func (m *APIReturnAllResp) XXX_DiscardUnknown()

func (*APIReturnAllResp) XXX_Marshal 

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

func (*APIReturnAllResp) XXX_Merge 

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

func (*APIReturnAllResp) XXX_Size 

func (m *APIReturnAllResp) XXX_Size() int

func (*APIReturnAllResp) XXX_Unmarshal 

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

type APIReturnReq 

type APIReturnReq struct {
	ClientID             []byte   `protobuf:"bytes,1,opt,name=ClientID,proto3" json:"ClientID,omitempty"`
	RCID                 string   `protobuf:"bytes,2,opt,name=RCID,proto3" json:"RCID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

APIReturnReq 客户端归还单个资源请求格式

func (*APIReturnReq) Descriptor 

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

func (*APIReturnReq) GetClientID 

func (m *APIReturnReq) GetClientID() []byte

func (*APIReturnReq) GetRCID 

func (m *APIReturnReq) GetRCID() string

func (*APIReturnReq) ProtoMessage 

func (*APIReturnReq) ProtoMessage()

func (*APIReturnReq) Reset 

func (m *APIReturnReq) Reset()

func (*APIReturnReq) String 

func (m *APIReturnReq) String() string

func (*APIReturnReq) XXX_DiscardUnknown 

func (m *APIReturnReq) XXX_DiscardUnknown()

func (*APIReturnReq) XXX_Marshal 

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

func (*APIReturnReq) XXX_Merge 

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

func (*APIReturnReq) XXX_Size 

func (m *APIReturnReq) XXX_Size() int

func (*APIReturnReq) XXX_Unmarshal 

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

type APIReturnResp 

type APIReturnResp struct {
	Code                 uint32   `protobuf:"varint,1,opt,name=Code,proto3" json:"Code,omitempty"`
	Msg                  string   `protobuf:"bytes,2,opt,name=Msg,proto3" json:"Msg,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

APIReturnResp 客户端归还单个资源响应格式

func (*APIReturnResp) Descriptor 

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

func (*APIReturnResp) GetCode 

func (m *APIReturnResp) GetCode() uint32

func (*APIReturnResp) GetMsg 

func (m *APIReturnResp) GetMsg() string

func (*APIReturnResp) ProtoMessage 

func (*APIReturnResp) ProtoMessage()

func (*APIReturnResp) Reset 

func (m *APIReturnResp) Reset()

func (*APIReturnResp) String 

func (m *APIReturnResp) String() string

func (*APIReturnResp) XXX_DiscardUnknown 

func (m *APIReturnResp) XXX_DiscardUnknown()

func (*APIReturnResp) XXX_Marshal 

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

func (*APIReturnResp) XXX_Merge 

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

func (*APIReturnResp) XXX_Size 

func (m *APIReturnResp) XXX_Size() int

func (*APIReturnResp) XXX_Unmarshal 

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

type CMDLeaderNotify 

type CMDLeaderNotify struct {
	RaftAddr             string   `protobuf:"bytes,1,opt,name=RaftAddr,proto3" json:"RaftAddr,omitempty"`
	HttpAddr             string   `protobuf:"bytes,2,opt,name=HttpAddr,proto3" json:"HttpAddr,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

CMDLeaderNotify 下发通知所有结点Leader结点的HTTP服务地址的命令

func (*CMDLeaderNotify) Descriptor 

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

func (*CMDLeaderNotify) GetHttpAddr 

func (m *CMDLeaderNotify) GetHttpAddr() string

func (*CMDLeaderNotify) GetRaftAddr 

func (m *CMDLeaderNotify) GetRaftAddr() string

func (*CMDLeaderNotify) ProtoMessage 

func (*CMDLeaderNotify) ProtoMessage()

func (*CMDLeaderNotify) Reset 

func (m *CMDLeaderNotify) Reset()

func (*CMDLeaderNotify) String 

func (m *CMDLeaderNotify) String() string

func (*CMDLeaderNotify) XXX_DiscardUnknown 

func (m *CMDLeaderNotify) XXX_DiscardUnknown()

func (*CMDLeaderNotify) XXX_Marshal 

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

func (*CMDLeaderNotify) XXX_Merge 

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

func (*CMDLeaderNotify) XXX_Size 

func (m *CMDLeaderNotify) XXX_Size() int

func (*CMDLeaderNotify) XXX_Unmarshal 

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

type CMDRecycle 

type CMDRecycle struct {
	Timestamp            int64    `protobuf:"varint,1,opt,name=Timestamp,proto3" json:"Timestamp,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

CMDRecycle 下发通知所有结点进行资源清理与回收的命令

func (*CMDRecycle) Descriptor 

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

func (*CMDRecycle) GetTimestamp 

func (m *CMDRecycle) GetTimestamp() int64

func (*CMDRecycle) ProtoMessage 

func (*CMDRecycle) ProtoMessage()

func (*CMDRecycle) Reset 

func (m *CMDRecycle) Reset()

func (*CMDRecycle) String 

func (m *CMDRecycle) String() string

func (*CMDRecycle) XXX_DiscardUnknown 

func (m *CMDRecycle) XXX_DiscardUnknown()

func (*CMDRecycle) XXX_Marshal 

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

func (*CMDRecycle) XXX_Merge 

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

func (*CMDRecycle) XXX_Size 

func (m *CMDRecycle) XXX_Size() int

func (*CMDRecycle) XXX_Unmarshal 

func (m *CMDRecycle) XXX_Unmarshal(b []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.