carbon

package
v0.0.0-...-432d548 Latest Latest
Warning

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

 Go to latest Published: Feb 27, 2024 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

View Source 
const Default_CarbonPriority_MajorPriority int32 = 32
View Source 
const Default_GlobalPlan_LatestVersionRatio int32 = 100
View Source 
const Default_ReplicaNodeStatus_ReadyForCurVersion bool = false
View Source 
const Default_ReplicaNodeStatus_TimeStamp int64 = 0
View Source 
const Default_Response_Code int32 = 0
View Source 
const Default_Response_SubCode int32 = 0
View Source 
const Default_RoleStatusValue_ReadyForCurVersion bool = false
View Source 
const Default_ServiceStatus_Score int64 = 0
View Source 
const Default_SlotInfo_NoLongerMatchQueue bool = false
View Source 
const Default_SlotInfo_NoLongerMatchResourceRequirement bool = false
View Source 
const Default_WorkerNodeStatus_IsBackup bool = false
View Source 
const Default_WorkerNodeStatus_LastNotMatchTime int64 = 0
View Source 
const Default_WorkerNodeStatus_LastNotReadyTime int64 = 0
View Source 
const Default_WorkerNodeStatus_Offline bool = false
View Source 
const Default_WorkerNodeStatus_ReadyForCurVersion bool = false
View Source 
const Default_WorkerNodeStatus_Reclaiming bool = false
View Source 
const Default_WorkerNodeStatus_Releasing bool = false

Variables

View Source 
var (
	ErrInvalidLengthStatus        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowStatus          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupStatus = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var HealthType_name = map[int32]string{
	0: "HT_UNKNOWN",
	1: "HT_LOST",
	2: "HT_ALIVE",
	3: "HT_DEAD",
}
View Source 
var HealthType_value = map[string]int32{
	"HT_UNKNOWN": 0,
	"HT_LOST":    1,
	"HT_ALIVE":   2,
	"HT_DEAD":    3,
}
View Source 
var ServiceType_name = map[int32]string{
	0: "SVT_UNKNOWN",
	1: "SVT_UNAVAILABLE",
	2: "SVT_PART_AVAILABLE",
	3: "SVT_AVAILABLE",
}
View Source 
var ServiceType_value = map[string]int32{
	"SVT_UNKNOWN":        0,
	"SVT_UNAVAILABLE":    1,
	"SVT_PART_AVAILABLE": 2,
	"SVT_AVAILABLE":      3,
}
View Source 
var SlotAllocStatus_name = map[int32]string{
	0: "SAS_UNASSIGNED",
	1: "SAS_ASSIGNED",
	2: "SAS_LOST",
	3: "SAS_OFFLINING",
	4: "SAS_RELEASING",
	5: "SAS_RELEASED",
}
View Source 
var SlotAllocStatus_value = map[string]int32{
	"SAS_UNASSIGNED": 0,
	"SAS_ASSIGNED":   1,
	"SAS_LOST":       2,
	"SAS_OFFLINING":  3,
	"SAS_RELEASING":  4,
	"SAS_RELEASED":   5,
}
View Source 
var SlotType_name = map[int32]string{
	0: "ST_PKG_FAILED",
	1: "ST_UNKNOWN",
	2: "ST_DEAD",
	3: "ST_PROC_FAILED",
	4: "ST_PROC_RESTARTING",
	5: "ST_PROC_RUNNING",
	6: "ST_PROC_TERMINATED",
}
View Source 
var SlotType_value = map[string]int32{
	"ST_PKG_FAILED":      0,
	"ST_UNKNOWN":         1,
	"ST_DEAD":            2,
	"ST_PROC_FAILED":     3,
	"ST_PROC_RESTARTING": 4,
	"ST_PROC_RUNNING":    5,
	"ST_PROC_TERMINATED": 6,
}
View Source 
var WorkerType_name = map[int32]string{
	0: "WT_UNKNOWN",
	1: "WT_NOT_READY",
	2: "WT_READY",
}
View Source 
var WorkerType_value = map[string]int32{
	"WT_UNKNOWN":   0,
	"WT_NOT_READY": 1,
	"WT_READY":     2,
}

Functions

This section is empty.

Types

type CarbonPriority 

type CarbonPriority struct {
	MajorPriority        *int32   `protobuf:"varint,1,opt,name=major_priority,json=majorPriority,def=32" json:"major_priority,omitempty"`
	MinorPriority        *int32   `protobuf:"varint,2,opt,name=minor_priority,json=minorPriority" json:"minor_priority,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CarbonPriority) DeepCopy 

func (in *CarbonPriority) DeepCopy() *CarbonPriority

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CarbonPriority. Required by controller-gen.

func (*CarbonPriority) DeepCopyInterface 

func (in *CarbonPriority) DeepCopyInterface() interface{}

DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new CarbonPriority. Required by controller-gen.

func (*CarbonPriority) DeepCopyInto 

func (in *CarbonPriority) DeepCopyInto(out *CarbonPriority)

DeepCopyInto supports using CarbonPriority within kubernetes types, where deepcopy-gen is used.

func (*CarbonPriority) Descriptor 

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

func (*CarbonPriority) GetMajorPriority 

func (m *CarbonPriority) GetMajorPriority() int32

func (*CarbonPriority) GetMinorPriority 

func (m *CarbonPriority) GetMinorPriority() int32

func (*CarbonPriority) Marshal 

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

func (*CarbonPriority) MarshalTo 

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

func (*CarbonPriority) MarshalToSizedBuffer 

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

func (*CarbonPriority) ProtoMessage 

func (*CarbonPriority) ProtoMessage()

func (*CarbonPriority) Reset 

func (m *CarbonPriority) Reset()

func (*CarbonPriority) Size 

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

func (*CarbonPriority) String 

func (m *CarbonPriority) String() string

func (*CarbonPriority) Unmarshal 

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

func (*CarbonPriority) XXX_DiscardUnknown 

func (m *CarbonPriority) XXX_DiscardUnknown()

func (*CarbonPriority) XXX_Marshal 

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

func (*CarbonPriority) XXX_Merge 

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

func (*CarbonPriority) XXX_Size 

func (m *CarbonPriority) XXX_Size() int

func (*CarbonPriority) XXX_Unmarshal 

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

type GlobalPlan 

type GlobalPlan struct {
	Count                *int32   `protobuf:"varint,1,opt,name=count" json:"count,omitempty"`
	LatestVersionRatio   *int32   `protobuf:"varint,2,opt,name=latestVersionRatio,def=100" json:"latestVersionRatio,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GlobalPlan) DeepCopy 

func (in *GlobalPlan) DeepCopy() *GlobalPlan

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new GlobalPlan. Required by controller-gen.

func (*GlobalPlan) DeepCopyInterface 

func (in *GlobalPlan) DeepCopyInterface() interface{}

DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new GlobalPlan. Required by controller-gen.

func (*GlobalPlan) DeepCopyInto 

func (in *GlobalPlan) DeepCopyInto(out *GlobalPlan)

DeepCopyInto supports using GlobalPlan within kubernetes types, where deepcopy-gen is used.

func (*GlobalPlan) Descriptor 

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

func (*GlobalPlan) GetCount 

func (m *GlobalPlan) GetCount() int32

func (*GlobalPlan) GetLatestVersionRatio 

func (m *GlobalPlan) GetLatestVersionRatio() int32

func (*GlobalPlan) Marshal 

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

func (*GlobalPlan) MarshalTo 

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

func (*GlobalPlan) MarshalToSizedBuffer 

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

func (*GlobalPlan) ProtoMessage 

func (*GlobalPlan) ProtoMessage()

func (*GlobalPlan) Reset 

func (m *GlobalPlan) Reset()

func (*GlobalPlan) Size 

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

func (*GlobalPlan) String 

func (m *GlobalPlan) String() string

func (*GlobalPlan) Unmarshal 

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

func (*GlobalPlan) XXX_DiscardUnknown 

func (m *GlobalPlan) XXX_DiscardUnknown()

func (*GlobalPlan) XXX_Marshal 

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

func (*GlobalPlan) XXX_Merge 

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

func (*GlobalPlan) XXX_Size 

func (m *GlobalPlan) XXX_Size() int

func (*GlobalPlan) XXX_Unmarshal 

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

type GroupStatus 

type GroupStatus struct {
	GroupId              *string                     `protobuf:"bytes,1,opt,name=groupId" json:"groupId,omitempty"`
	Roles                map[string]*RoleStatusValue `` /* 130-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_unrecognized     []byte                      `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}

func (*GroupStatus) DeepCopy 

func (in *GroupStatus) DeepCopy() *GroupStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new GroupStatus. Required by controller-gen.

func (*GroupStatus) DeepCopyInterface 

func (in *GroupStatus) DeepCopyInterface() interface{}

DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new GroupStatus. Required by controller-gen.

func (*GroupStatus) DeepCopyInto 

func (in *GroupStatus) DeepCopyInto(out *GroupStatus)

DeepCopyInto supports using GroupStatus within kubernetes types, where deepcopy-gen is used.

func (*GroupStatus) Descriptor 

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

func (*GroupStatus) GetGroupId 

func (m *GroupStatus) GetGroupId() string

func (*GroupStatus) GetRoles 

func (m *GroupStatus) GetRoles() map[string]*RoleStatusValue

func (*GroupStatus) Marshal 

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

func (*GroupStatus) MarshalTo 

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

func (*GroupStatus) MarshalToSizedBuffer 

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

func (*GroupStatus) ProtoMessage 

func (*GroupStatus) ProtoMessage()

func (*GroupStatus) Reset 

func (m *GroupStatus) Reset()

func (*GroupStatus) Size 

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

func (*GroupStatus) String 

func (m *GroupStatus) String() string

func (*GroupStatus) Unmarshal 

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

func (*GroupStatus) XXX_DiscardUnknown 

func (m *GroupStatus) XXX_DiscardUnknown()

func (*GroupStatus) XXX_Marshal 

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

func (*GroupStatus) XXX_Merge 

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

func (*GroupStatus) XXX_Size 

func (m *GroupStatus) XXX_Size() int

func (*GroupStatus) XXX_Unmarshal 

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

type HealthInfo 

type HealthInfo struct {
	HealthStatus         *HealthType       `protobuf:"varint,1,opt,name=healthStatus,enum=carbon.HealthType,def=0" json:"healthStatus,omitempty"`
	WorkerStatus         *WorkerType       `protobuf:"varint,2,opt,name=workerStatus,enum=carbon.WorkerType,def=0" json:"workerStatus,omitempty"`
	Metas                map[string]string `` /* 130-byte string literal not displayed */
	Version              *string           `protobuf:"bytes,4,opt,name=version" json:"version,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*HealthInfo) DeepCopy 

func (in *HealthInfo) DeepCopy() *HealthInfo

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new HealthInfo. Required by controller-gen.

func (*HealthInfo) DeepCopyInterface 

func (in *HealthInfo) DeepCopyInterface() interface{}

DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new HealthInfo. Required by controller-gen.

func (*HealthInfo) DeepCopyInto 

func (in *HealthInfo) DeepCopyInto(out *HealthInfo)

DeepCopyInto supports using HealthInfo within kubernetes types, where deepcopy-gen is used.

func (*HealthInfo) Descriptor 

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

func (*HealthInfo) GetHealthStatus 

func (m *HealthInfo) GetHealthStatus() HealthType

func (*HealthInfo) GetMetas 

func (m *HealthInfo) GetMetas() map[string]string

func (*HealthInfo) GetVersion 

func (m *HealthInfo) GetVersion() string

func (*HealthInfo) GetWorkerStatus 

func (m *HealthInfo) GetWorkerStatus() WorkerType

func (*HealthInfo) Marshal 

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

func (*HealthInfo) MarshalTo 

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

func (*HealthInfo) MarshalToSizedBuffer 

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

func (*HealthInfo) ProtoMessage 

func (*HealthInfo) ProtoMessage()

func (*HealthInfo) Reset 

func (m *HealthInfo) Reset()

func (*HealthInfo) Size 

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

func (*HealthInfo) String 

func (m *HealthInfo) String() string

func (*HealthInfo) Unmarshal 

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

func (*HealthInfo) XXX_DiscardUnknown 

func (m *HealthInfo) XXX_DiscardUnknown()

func (*HealthInfo) XXX_Marshal 

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

func (*HealthInfo) XXX_Merge 

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

func (*HealthInfo) XXX_Size 

func (m *HealthInfo) XXX_Size() int

func (*HealthInfo) XXX_Unmarshal 

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

type HealthType 

type HealthType int32
const (
	HealthType_HT_UNKNOWN HealthType = 0
	HealthType_HT_LOST    HealthType = 1
	HealthType_HT_ALIVE   HealthType = 2
	HealthType_HT_DEAD    HealthType = 3
)
const Default_HealthInfo_HealthStatus HealthType = HealthType_HT_UNKNOWN

func (HealthType) Enum 

func (x HealthType) Enum() *HealthType

func (HealthType) EnumDescriptor 

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

func (HealthType) String 

func (x HealthType) String() string

func (*HealthType) UnmarshalJSON 

func (x *HealthType) UnmarshalJSON(data []byte) error

type PackageStatus 

type PackageStatus hippo.PackageStatus_Status

PackageStatus PackageStatus_Status

func (*PackageStatus) MarshalJSON 

func (x *PackageStatus) MarshalJSON() ([]byte, error)

MarshalJSON MarshalJSON

func (*PackageStatus) UnmarshalJSON 

func (x *PackageStatus) UnmarshalJSON(data []byte) error

UnmarshalJSON UnmarshalJSON

type ProcessStatus 

type ProcessStatus hippo.ProcessStatus

ProcessStatus ProcessStatus

func (ProcessStatus) MarshalJSON 

func (a ProcessStatus) MarshalJSON() ([]byte, error)

MarshalJSON MarshalJSON

func (*ProcessStatus) UnmarshalJSON 

func (a *ProcessStatus) UnmarshalJSON(b []byte) error

UnmarshalJSON UnmarshalJSON

type ProcessStatusJSONMarshaler 

type ProcessStatusJSONMarshaler struct {
	TmpProcessStatus
	Status *ProcessStatusStatus `json:"status,omitempty"`
}

ProcessStatusJSONMarshaler ProcessStatusJSONMarshaler

type ProcessStatusStatus 

type ProcessStatusStatus hippo.ProcessStatus_Status

ProcessStatusStatus ProcessStatusStatus

func (*ProcessStatusStatus) MarshalJSON 

func (x *ProcessStatusStatus) MarshalJSON() ([]byte, error)

MarshalJSON MarshalJSON

func (*ProcessStatusStatus) UnmarshalJSON 

func (x *ProcessStatusStatus) UnmarshalJSON(data []byte) error

UnmarshalJSON UnmarshalJSON

type ReplicaNodeStatus 

type ReplicaNodeStatus struct {
	ReplicaNodeId          *string           `protobuf:"bytes,1,opt,name=replicaNodeId" json:"replicaNodeId,omitempty"`
	CurWorkerNodeStatus    *WorkerNodeStatus `protobuf:"bytes,2,opt,name=curWorkerNodeStatus" json:"curWorkerNodeStatus,omitempty"`
	BackupWorkerNodeStatus *WorkerNodeStatus `protobuf:"bytes,3,opt,name=backupWorkerNodeStatus" json:"backupWorkerNodeStatus,omitempty"`
	TimeStamp              *int64            `protobuf:"varint,4,opt,name=timeStamp,def=0" json:"timeStamp,omitempty"`
	UserDefVersion         *string           `protobuf:"bytes,5,opt,name=userDefVersion" json:"userDefVersion,omitempty"`
	ReadyForCurVersion     *bool             `protobuf:"varint,6,opt,name=readyForCurVersion,def=0" json:"readyForCurVersion,omitempty"`
	XXX_NoUnkeyedLiteral   struct{}          `json:"-"`
	XXX_unrecognized       []byte            `json:"-"`
	XXX_sizecache          int32             `json:"-"`
}

func (*ReplicaNodeStatus) DeepCopy 

func (in *ReplicaNodeStatus) DeepCopy() *ReplicaNodeStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ReplicaNodeStatus. Required by controller-gen.

func (*ReplicaNodeStatus) DeepCopyInterface 

func (in *ReplicaNodeStatus) DeepCopyInterface() interface{}

DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new ReplicaNodeStatus. Required by controller-gen.

func (*ReplicaNodeStatus) DeepCopyInto 

func (in *ReplicaNodeStatus) DeepCopyInto(out *ReplicaNodeStatus)

DeepCopyInto supports using ReplicaNodeStatus within kubernetes types, where deepcopy-gen is used.

func (*ReplicaNodeStatus) Descriptor 

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

func (*ReplicaNodeStatus) GetBackupWorkerNodeStatus 

func (m *ReplicaNodeStatus) GetBackupWorkerNodeStatus() *WorkerNodeStatus

func (*ReplicaNodeStatus) GetCurWorkerNodeStatus 

func (m *ReplicaNodeStatus) GetCurWorkerNodeStatus() *WorkerNodeStatus

func (*ReplicaNodeStatus) GetReadyForCurVersion 

func (m *ReplicaNodeStatus) GetReadyForCurVersion() bool

func (*ReplicaNodeStatus) GetReplicaNodeId 

func (m *ReplicaNodeStatus) GetReplicaNodeId() string

func (*ReplicaNodeStatus) GetTimeStamp 

func (m *ReplicaNodeStatus) GetTimeStamp() int64

func (*ReplicaNodeStatus) GetUserDefVersion 

func (m *ReplicaNodeStatus) GetUserDefVersion() string

func (*ReplicaNodeStatus) Marshal 

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

func (*ReplicaNodeStatus) MarshalTo 

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

func (*ReplicaNodeStatus) MarshalToSizedBuffer 

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

func (*ReplicaNodeStatus) ProtoMessage 

func (*ReplicaNodeStatus) ProtoMessage()

func (*ReplicaNodeStatus) Reset 

func (m *ReplicaNodeStatus) Reset()

func (*ReplicaNodeStatus) Size 

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

func (*ReplicaNodeStatus) String 

func (m *ReplicaNodeStatus) String() string

func (*ReplicaNodeStatus) Unmarshal 

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

func (*ReplicaNodeStatus) XXX_DiscardUnknown 

func (m *ReplicaNodeStatus) XXX_DiscardUnknown()

func (*ReplicaNodeStatus) XXX_Marshal 

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

func (*ReplicaNodeStatus) XXX_Merge 

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

func (*ReplicaNodeStatus) XXX_Size 

func (m *ReplicaNodeStatus) XXX_Size() int

func (*ReplicaNodeStatus) XXX_Unmarshal 

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

type ResourcePlan 

type ResourcePlan struct {
	Resources            []*SlotResource `protobuf:"bytes,1,rep,name=resources" json:"resources,omitempty"`
	Group                *string         `protobuf:"bytes,2,opt,name=group" json:"group,omitempty"`
	Priority             *CarbonPriority `protobuf:"bytes,3,opt,name=priority" json:"priority,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*ResourcePlan) DeepCopy 

func (in *ResourcePlan) DeepCopy() *ResourcePlan

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ResourcePlan. Required by controller-gen.

func (*ResourcePlan) DeepCopyInterface 

func (in *ResourcePlan) DeepCopyInterface() interface{}

DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new ResourcePlan. Required by controller-gen.

func (*ResourcePlan) DeepCopyInto 

func (in *ResourcePlan) DeepCopyInto(out *ResourcePlan)

DeepCopyInto supports using ResourcePlan within kubernetes types, where deepcopy-gen is used.

func (*ResourcePlan) Descriptor 

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

func (*ResourcePlan) GetGroup 

func (m *ResourcePlan) GetGroup() string

func (*ResourcePlan) GetPriority 

func (m *ResourcePlan) GetPriority() *CarbonPriority

func (*ResourcePlan) GetResources 

func (m *ResourcePlan) GetResources() []*SlotResource

func (*ResourcePlan) Marshal 

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

func (*ResourcePlan) MarshalTo 

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

func (*ResourcePlan) MarshalToSizedBuffer 

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

func (*ResourcePlan) ProtoMessage 

func (*ResourcePlan) ProtoMessage()

func (*ResourcePlan) Reset 

func (m *ResourcePlan) Reset()

func (*ResourcePlan) Size 

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

func (*ResourcePlan) String 

func (m *ResourcePlan) String() string

func (*ResourcePlan) Unmarshal 

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

func (*ResourcePlan) XXX_DiscardUnknown 

func (m *ResourcePlan) XXX_DiscardUnknown()

func (*ResourcePlan) XXX_Marshal 

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

func (*ResourcePlan) XXX_Merge 

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

func (*ResourcePlan) XXX_Size 

func (m *ResourcePlan) XXX_Size() int

func (*ResourcePlan) XXX_Unmarshal 

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

type Response 

type Response struct {
	Code                 *int32         `protobuf:"varint,1,opt,name=code,def=0" json:"code,omitempty"`
	SubCode              *int32         `protobuf:"varint,2,opt,name=subCode,def=0" json:"subCode,omitempty"`
	Msg                  *string        `protobuf:"bytes,3,opt,name=msg" json:"msg,omitempty"`
	Data                 []*GroupStatus `protobuf:"bytes,4,rep,name=data" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*Response) DeepCopy 

func (in *Response) DeepCopy() *Response

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Response. Required by controller-gen.

func (*Response) DeepCopyInterface 

func (in *Response) DeepCopyInterface() interface{}

DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new Response. Required by controller-gen.

func (*Response) DeepCopyInto 

func (in *Response) DeepCopyInto(out *Response)

DeepCopyInto supports using Response within kubernetes types, where deepcopy-gen is used.

func (*Response) Descriptor 

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

func (*Response) GetCode 

func (m *Response) GetCode() int32

func (*Response) GetData 

func (m *Response) GetData() []*GroupStatus

func (*Response) GetMsg 

func (m *Response) GetMsg() string

func (*Response) GetSubCode 

func (m *Response) GetSubCode() int32

func (*Response) HasError 

func (r *Response) HasError() bool

HasError HasError

func (*Response) Marshal 

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

func (*Response) MarshalTo 

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

func (*Response) MarshalToSizedBuffer 

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

func (*Response) ProtoMessage 

func (*Response) ProtoMessage()

func (*Response) Reset 

func (m *Response) Reset()

func (*Response) Size 

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

func (*Response) String 

func (m *Response) String() string

func (*Response) Unmarshal 

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

func (*Response) XXX_DiscardUnknown 

func (m *Response) XXX_DiscardUnknown()

func (*Response) XXX_Marshal 

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

func (*Response) XXX_Merge 

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

func (*Response) XXX_Size 

func (m *Response) XXX_Size() int

func (*Response) XXX_Unmarshal 

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

type RoleStatusValue 

type RoleStatusValue struct {
	RoleId                    *string                   `protobuf:"bytes,1,opt,name=roleId" json:"roleId,omitempty"`
	GlobalPlan                *GlobalPlan               `protobuf:"bytes,2,opt,name=globalPlan" json:"globalPlan,omitempty"`
	VersionedPlans            map[string]*VersionedPlan `` /* 148-byte string literal not displayed */
	LatestVersion             *string                   `protobuf:"bytes,4,opt,name=latestVersion" json:"latestVersion,omitempty"`
	Nodes                     []*ReplicaNodeStatus      `protobuf:"bytes,5,rep,name=nodes" json:"nodes,omitempty"`
	UserDefVersion            *string                   `protobuf:"bytes,6,opt,name=userDefVersion" json:"userDefVersion,omitempty"`
	ReadyForCurVersion        *bool                     `protobuf:"varint,7,opt,name=readyForCurVersion,def=0" json:"readyForCurVersion,omitempty"`
	MinHealthCapacity         *int32                    `protobuf:"varint,8,opt,name=minHealthCapacity" json:"minHealthCapacity,omitempty"`
	AdjustedCount             *int32                    `protobuf:"varint,9,opt,name=adjustedCount" json:"adjustedCount,omitempty"`
	AdjustedMinHealthCapacity *int32                    `protobuf:"varint,10,opt,name=adjustedMinHealthCapacity" json:"adjustedMinHealthCapacity,omitempty"`
	XXX_NoUnkeyedLiteral      struct{}                  `json:"-"`
	XXX_unrecognized          []byte                    `json:"-"`
	XXX_sizecache             int32                     `json:"-"`
}

func (*RoleStatusValue) DeepCopy 

func (in *RoleStatusValue) DeepCopy() *RoleStatusValue

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RoleStatusValue. Required by controller-gen.

func (*RoleStatusValue) DeepCopyInterface 

func (in *RoleStatusValue) DeepCopyInterface() interface{}

DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new RoleStatusValue. Required by controller-gen.

func (*RoleStatusValue) DeepCopyInto 

func (in *RoleStatusValue) DeepCopyInto(out *RoleStatusValue)

DeepCopyInto supports using RoleStatusValue within kubernetes types, where deepcopy-gen is used.

func (*RoleStatusValue) Descriptor 

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

func (*RoleStatusValue) GetAdjustedCount 

func (m *RoleStatusValue) GetAdjustedCount() int32

func (*RoleStatusValue) GetAdjustedMinHealthCapacity 

func (m *RoleStatusValue) GetAdjustedMinHealthCapacity() int32

func (*RoleStatusValue) GetGlobalPlan 

func (m *RoleStatusValue) GetGlobalPlan() *GlobalPlan

func (*RoleStatusValue) GetLatestVersion 

func (m *RoleStatusValue) GetLatestVersion() string

func (*RoleStatusValue) GetMinHealthCapacity 

func (m *RoleStatusValue) GetMinHealthCapacity() int32

func (*RoleStatusValue) GetNodes 

func (m *RoleStatusValue) GetNodes() []*ReplicaNodeStatus

func (*RoleStatusValue) GetReadyForCurVersion 

func (m *RoleStatusValue) GetReadyForCurVersion() bool

func (*RoleStatusValue) GetRoleId 

func (m *RoleStatusValue) GetRoleId() string

func (*RoleStatusValue) GetUserDefVersion 

func (m *RoleStatusValue) GetUserDefVersion() string

func (*RoleStatusValue) GetVersionedPlans 

func (m *RoleStatusValue) GetVersionedPlans() map[string]*VersionedPlan

func (*RoleStatusValue) Marshal 

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

func (*RoleStatusValue) MarshalTo 

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

func (*RoleStatusValue) MarshalToSizedBuffer 

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

func (*RoleStatusValue) ProtoMessage 

func (*RoleStatusValue) ProtoMessage()

func (*RoleStatusValue) Reset 

func (m *RoleStatusValue) Reset()

func (*RoleStatusValue) Size 

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

func (*RoleStatusValue) String 

func (m *RoleStatusValue) String() string

func (*RoleStatusValue) Unmarshal 

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

func (*RoleStatusValue) XXX_DiscardUnknown 

func (m *RoleStatusValue) XXX_DiscardUnknown()

func (*RoleStatusValue) XXX_Marshal 

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

func (*RoleStatusValue) XXX_Merge 

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

func (*RoleStatusValue) XXX_Size 

func (m *RoleStatusValue) XXX_Size() int

func (*RoleStatusValue) XXX_Unmarshal 

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

type ServiceStatus 

type ServiceStatus struct {
	Status               *ServiceType      `protobuf:"varint,1,opt,name=status,enum=carbon.ServiceType,def=0" json:"status,omitempty"`
	Metas                map[string]string `` /* 130-byte string literal not displayed */
	Score                *int64            `protobuf:"varint,3,opt,name=score,def=0" json:"score,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*ServiceStatus) DeepCopy 

func (in *ServiceStatus) DeepCopy() *ServiceStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ServiceStatus. Required by controller-gen.

func (*ServiceStatus) DeepCopyInterface 

func (in *ServiceStatus) DeepCopyInterface() interface{}

DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new ServiceStatus. Required by controller-gen.

func (*ServiceStatus) DeepCopyInto 

func (in *ServiceStatus) DeepCopyInto(out *ServiceStatus)

DeepCopyInto supports using ServiceStatus within kubernetes types, where deepcopy-gen is used.

func (*ServiceStatus) Descriptor 

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

func (*ServiceStatus) GetMetas 

func (m *ServiceStatus) GetMetas() map[string]string

func (*ServiceStatus) GetScore 

func (m *ServiceStatus) GetScore() int64

func (*ServiceStatus) GetStatus 

func (m *ServiceStatus) GetStatus() ServiceType

func (*ServiceStatus) Marshal 

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

func (*ServiceStatus) MarshalTo 

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

func (*ServiceStatus) MarshalToSizedBuffer 

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

func (*ServiceStatus) ProtoMessage 

func (*ServiceStatus) ProtoMessage()

func (*ServiceStatus) Reset 

func (m *ServiceStatus) Reset()

func (*ServiceStatus) Size 

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

func (*ServiceStatus) String 

func (m *ServiceStatus) String() string

func (*ServiceStatus) Unmarshal 

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

func (*ServiceStatus) XXX_DiscardUnknown 

func (m *ServiceStatus) XXX_DiscardUnknown()

func (*ServiceStatus) XXX_Marshal 

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

func (*ServiceStatus) XXX_Merge 

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

func (*ServiceStatus) XXX_Size 

func (m *ServiceStatus) XXX_Size() int

func (*ServiceStatus) XXX_Unmarshal 

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

type ServiceType 

type ServiceType int32
const (
	ServiceType_SVT_UNKNOWN        ServiceType = 0
	ServiceType_SVT_UNAVAILABLE    ServiceType = 1
	ServiceType_SVT_PART_AVAILABLE ServiceType = 2
	ServiceType_SVT_AVAILABLE      ServiceType = 3
)
const Default_ServiceStatus_Status ServiceType = ServiceType_SVT_UNKNOWN

func (ServiceType) Enum 

func (x ServiceType) Enum() *ServiceType

func (ServiceType) EnumDescriptor 

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

func (ServiceType) String 

func (x ServiceType) String() string

func (*ServiceType) UnmarshalJSON 

func (x *ServiceType) UnmarshalJSON(data []byte) error

type SlaveStatus 

type SlaveStatus hippo.SlaveStatus_Status

SlaveStatus SlaveStatus_Status

func (*SlaveStatus) MarshalJSON 

func (x *SlaveStatus) MarshalJSON() ([]byte, error)

MarshalJSON MarshalJSON

func (*SlaveStatus) UnmarshalJSON 

func (x *SlaveStatus) UnmarshalJSON(data []byte) error

UnmarshalJSON UnmarshalJSON

type SlotAllocStatus 

type SlotAllocStatus int32
const (
	SlotAllocStatus_SAS_UNASSIGNED SlotAllocStatus = 0
	SlotAllocStatus_SAS_ASSIGNED   SlotAllocStatus = 1
	SlotAllocStatus_SAS_LOST       SlotAllocStatus = 2
	SlotAllocStatus_SAS_OFFLINING  SlotAllocStatus = 3
	SlotAllocStatus_SAS_RELEASING  SlotAllocStatus = 4
	SlotAllocStatus_SAS_RELEASED   SlotAllocStatus = 5
)
const Default_WorkerNodeStatus_SlotAllocStatus SlotAllocStatus = SlotAllocStatus_SAS_UNASSIGNED

func (SlotAllocStatus) Enum 

func (x SlotAllocStatus) Enum() *SlotAllocStatus

func (SlotAllocStatus) EnumDescriptor 

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

func (SlotAllocStatus) String 

func (x SlotAllocStatus) String() string

func (*SlotAllocStatus) UnmarshalJSON 

func (x *SlotAllocStatus) UnmarshalJSON(data []byte) error

type SlotInfo 

type SlotInfo struct {
	Role                             *string                `protobuf:"bytes,1,opt,name=role" json:"role,omitempty"`
	SlotId                           *hippo.SlotId          `protobuf:"bytes,2,opt,name=slotId" json:"slotId,omitempty"`
	Reclaiming                       *bool                  `protobuf:"varint,3,opt,name=reclaiming" json:"reclaiming,omitempty"`
	SlotResource                     *SlotResource          `protobuf:"bytes,4,opt,name=slotResource" json:"slotResource,omitempty"`
	ProcessStatus                    []*hippo.ProcessStatus `protobuf:"bytes,5,rep,name=processStatus" json:"processStatus,omitempty"`
	SlaveStatus                      *hippo.SlaveStatus     `protobuf:"bytes,6,opt,name=slaveStatus" json:"slaveStatus,omitempty"`
	LaunchSignature                  *int64                 `protobuf:"varint,8,opt,name=launchSignature" json:"launchSignature,omitempty"`
	PackageChecksum                  *string                `protobuf:"bytes,9,opt,name=packageChecksum" json:"packageChecksum,omitempty"`
	PackageStatus                    *hippo.PackageStatus   `protobuf:"bytes,10,opt,name=packageStatus" json:"packageStatus,omitempty"`
	NoLongerMatchQueue               *bool                  `protobuf:"varint,13,opt,name=noLongerMatchQueue,def=0" json:"noLongerMatchQueue,omitempty"`
	NoLongerMatchResourceRequirement *bool                  `protobuf:"varint,14,opt,name=noLongerMatchResourceRequirement,def=0" json:"noLongerMatchResourceRequirement,omitempty"`
	PreDeployPackageChecksum         *string                `protobuf:"bytes,18,opt,name=preDeployPackageChecksum" json:"preDeployPackageChecksum,omitempty"`
	PreDeployPackageStatus           *hippo.PackageStatus   `protobuf:"bytes,19,opt,name=preDeployPackageStatus" json:"preDeployPackageStatus,omitempty"`
	RequirementId                    *string                `protobuf:"bytes,23,opt,name=requirementId" json:"requirementId,omitempty"`
	Priority                         *hippo.Priority        `protobuf:"bytes,24,opt,name=priority" json:"priority,omitempty"`
	XXX_NoUnkeyedLiteral             struct{}               `json:"-"`
	XXX_unrecognized                 []byte                 `json:"-"`
	XXX_sizecache                    int32                  `json:"-"`
}

func (*SlotInfo) DeepCopy 

func (in *SlotInfo) DeepCopy() *SlotInfo

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SlotInfo. Required by controller-gen.

func (*SlotInfo) DeepCopyInterface 

func (in *SlotInfo) DeepCopyInterface() interface{}

DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new SlotInfo. Required by controller-gen.

func (*SlotInfo) DeepCopyInto 

func (in *SlotInfo) DeepCopyInto(out *SlotInfo)

DeepCopyInto supports using SlotInfo within kubernetes types, where deepcopy-gen is used.

func (*SlotInfo) Descriptor 

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

func (*SlotInfo) GetLaunchSignature 

func (m *SlotInfo) GetLaunchSignature() int64

func (*SlotInfo) GetNoLongerMatchQueue 

func (m *SlotInfo) GetNoLongerMatchQueue() bool

func (*SlotInfo) GetNoLongerMatchResourceRequirement 

func (m *SlotInfo) GetNoLongerMatchResourceRequirement() bool

func (*SlotInfo) GetPackageChecksum 

func (m *SlotInfo) GetPackageChecksum() string

func (*SlotInfo) GetPackageStatus 

func (m *SlotInfo) GetPackageStatus() *hippo.PackageStatus

func (*SlotInfo) GetPreDeployPackageChecksum 

func (m *SlotInfo) GetPreDeployPackageChecksum() string

func (*SlotInfo) GetPreDeployPackageStatus 

func (m *SlotInfo) GetPreDeployPackageStatus() *hippo.PackageStatus

func (*SlotInfo) GetPriority 

func (m *SlotInfo) GetPriority() *hippo.Priority

func (*SlotInfo) GetProcessStatus 

func (m *SlotInfo) GetProcessStatus() []*hippo.ProcessStatus

func (*SlotInfo) GetReclaiming 

func (m *SlotInfo) GetReclaiming() bool

func (*SlotInfo) GetRequirementId 

func (m *SlotInfo) GetRequirementId() string

func (*SlotInfo) GetRole 

func (m *SlotInfo) GetRole() string

func (*SlotInfo) GetSlaveStatus 

func (m *SlotInfo) GetSlaveStatus() *hippo.SlaveStatus

func (*SlotInfo) GetSlotId 

func (m *SlotInfo) GetSlotId() *hippo.SlotId

func (*SlotInfo) GetSlotResource 

func (m *SlotInfo) GetSlotResource() *SlotResource

func (*SlotInfo) Marshal 

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

func (SlotInfo) MarshalJSON 

func (a SlotInfo) MarshalJSON() ([]byte, error)

MarshalJSON MarshalJSON

func (*SlotInfo) MarshalTo 

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

func (*SlotInfo) MarshalToSizedBuffer 

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

func (*SlotInfo) ProtoMessage 

func (*SlotInfo) ProtoMessage()

func (*SlotInfo) Reset 

func (m *SlotInfo) Reset()

func (*SlotInfo) Size 

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

func (*SlotInfo) String 

func (m *SlotInfo) String() string

func (*SlotInfo) Unmarshal 

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

func (*SlotInfo) UnmarshalJSON 

func (a *SlotInfo) UnmarshalJSON(b []byte) error

UnmarshalJSON UnmarshalJSON

func (*SlotInfo) XXX_DiscardUnknown 

func (m *SlotInfo) XXX_DiscardUnknown()

func (*SlotInfo) XXX_Marshal 

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

func (*SlotInfo) XXX_Merge 

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

func (*SlotInfo) XXX_Size 

func (m *SlotInfo) XXX_Size() int

func (*SlotInfo) XXX_Unmarshal 

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

type SlotInfoJSONMarshaler 

type SlotInfoJSONMarshaler struct {
	TmpSlotInfo            `json:",inline"`
	PackageStatus          *PackageStatus   `json:"packageStatus,omitempty"`
	PreDeployPackageStatus *PackageStatus   `json:"preDeployPackageStatus,omitempty"`
	SlaveStatus            *SlaveStatus     `json:"slaveStatus,omitempty"`
	ProcessStatus          []*ProcessStatus `json:"processStatus,omitempty"`
}

SlotInfoJSONMarshaler SlotInfoJSONMarshaler

type SlotResource 

type SlotResource struct {
	SlotResources        []*hippo.Resource `protobuf:"bytes,1,rep,name=slotResources" json:"slotResources,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*SlotResource) DeepCopy 

func (in *SlotResource) DeepCopy() *SlotResource

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SlotResource. Required by controller-gen.

func (*SlotResource) DeepCopyInterface 

func (in *SlotResource) DeepCopyInterface() interface{}

DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new SlotResource. Required by controller-gen.

func (*SlotResource) DeepCopyInto 

func (in *SlotResource) DeepCopyInto(out *SlotResource)

DeepCopyInto supports using SlotResource within kubernetes types, where deepcopy-gen is used.

func (*SlotResource) Descriptor 

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

func (*SlotResource) GetSlotResources 

func (m *SlotResource) GetSlotResources() []*hippo.Resource

func (*SlotResource) Marshal 

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

func (*SlotResource) MarshalTo 

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

func (*SlotResource) MarshalToSizedBuffer 

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

func (*SlotResource) ProtoMessage 

func (*SlotResource) ProtoMessage()

func (*SlotResource) Reset 

func (m *SlotResource) Reset()

func (*SlotResource) Size 

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

func (*SlotResource) String 

func (m *SlotResource) String() string

func (*SlotResource) Unmarshal 

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

func (*SlotResource) XXX_DiscardUnknown 

func (m *SlotResource) XXX_DiscardUnknown()

func (*SlotResource) XXX_Marshal 

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

func (*SlotResource) XXX_Merge 

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

func (*SlotResource) XXX_Size 

func (m *SlotResource) XXX_Size() int

func (*SlotResource) XXX_Unmarshal 

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

type SlotStatus 

type SlotStatus struct {
	Status               *SlotType     `protobuf:"varint,1,opt,name=status,enum=carbon.SlotType,def=1" json:"status,omitempty"`
	SlotId               *hippo.SlotId `protobuf:"bytes,2,opt,name=slotId" json:"slotId,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*SlotStatus) DeepCopy 

func (in *SlotStatus) DeepCopy() *SlotStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SlotStatus. Required by controller-gen.

func (*SlotStatus) DeepCopyInterface 

func (in *SlotStatus) DeepCopyInterface() interface{}

DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new SlotStatus. Required by controller-gen.

func (*SlotStatus) DeepCopyInto 

func (in *SlotStatus) DeepCopyInto(out *SlotStatus)

DeepCopyInto supports using SlotStatus within kubernetes types, where deepcopy-gen is used.

func (*SlotStatus) Descriptor 

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

func (*SlotStatus) GetSlotId 

func (m *SlotStatus) GetSlotId() *hippo.SlotId

func (*SlotStatus) GetStatus 

func (m *SlotStatus) GetStatus() SlotType

func (*SlotStatus) Marshal 

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

func (*SlotStatus) MarshalTo 

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

func (*SlotStatus) MarshalToSizedBuffer 

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

func (*SlotStatus) ProtoMessage 

func (*SlotStatus) ProtoMessage()

func (*SlotStatus) Reset 

func (m *SlotStatus) Reset()

func (*SlotStatus) Size 

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

func (*SlotStatus) String 

func (m *SlotStatus) String() string

func (*SlotStatus) Unmarshal 

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

func (*SlotStatus) XXX_DiscardUnknown 

func (m *SlotStatus) XXX_DiscardUnknown()

func (*SlotStatus) XXX_Marshal 

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

func (*SlotStatus) XXX_Merge 

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

func (*SlotStatus) XXX_Size 

func (m *SlotStatus) XXX_Size() int

func (*SlotStatus) XXX_Unmarshal 

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

type SlotType 

type SlotType int32
const (
	SlotType_ST_PKG_FAILED      SlotType = 0
	SlotType_ST_UNKNOWN         SlotType = 1
	SlotType_ST_DEAD            SlotType = 2
	SlotType_ST_PROC_FAILED     SlotType = 3
	SlotType_ST_PROC_RESTARTING SlotType = 4
	SlotType_ST_PROC_RUNNING    SlotType = 5
	SlotType_ST_PROC_TERMINATED SlotType = 6
)
const Default_SlotStatus_Status SlotType = SlotType_ST_UNKNOWN

func (SlotType) Enum 

func (x SlotType) Enum() *SlotType

func (SlotType) EnumDescriptor 

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

func (SlotType) String 

func (x SlotType) String() string

func (*SlotType) UnmarshalJSON 

func (x *SlotType) UnmarshalJSON(data []byte) error

type TmpProcessStatus 

type TmpProcessStatus ProcessStatus

TmpProcessStatus TmpProcessStatus

type TmpSlotInfo 

type TmpSlotInfo SlotInfo

TmpSlotInfo TmpSlotInfo

type VersionedPlan 

type VersionedPlan struct {
	ResourcePlan         *ResourcePlan `protobuf:"bytes,1,opt,name=resourcePlan" json:"resourcePlan,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*VersionedPlan) DeepCopy 

func (in *VersionedPlan) DeepCopy() *VersionedPlan

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VersionedPlan. Required by controller-gen.

func (*VersionedPlan) DeepCopyInterface 

func (in *VersionedPlan) DeepCopyInterface() interface{}

DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new VersionedPlan. Required by controller-gen.

func (*VersionedPlan) DeepCopyInto 

func (in *VersionedPlan) DeepCopyInto(out *VersionedPlan)

DeepCopyInto supports using VersionedPlan within kubernetes types, where deepcopy-gen is used.

func (*VersionedPlan) Descriptor 

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

func (*VersionedPlan) GetResourcePlan 

func (m *VersionedPlan) GetResourcePlan() *ResourcePlan

func (*VersionedPlan) Marshal 

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

func (*VersionedPlan) MarshalTo 

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

func (*VersionedPlan) MarshalToSizedBuffer 

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

func (*VersionedPlan) ProtoMessage 

func (*VersionedPlan) ProtoMessage()

func (*VersionedPlan) Reset 

func (m *VersionedPlan) Reset()

func (*VersionedPlan) Size 

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

func (*VersionedPlan) String 

func (m *VersionedPlan) String() string

func (*VersionedPlan) Unmarshal 

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

func (*VersionedPlan) XXX_DiscardUnknown 

func (m *VersionedPlan) XXX_DiscardUnknown()

func (*VersionedPlan) XXX_Marshal 

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

func (*VersionedPlan) XXX_Merge 

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

func (*VersionedPlan) XXX_Size 

func (m *VersionedPlan) XXX_Size() int

func (*VersionedPlan) XXX_Unmarshal 

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

type WorkerNodeStatus 

type WorkerNodeStatus struct {
	ReplicaNodeId        *string           `protobuf:"bytes,1,opt,name=replicaNodeId" json:"replicaNodeId,omitempty"`
	WorkerNodeId         *string           `protobuf:"bytes,2,opt,name=workerNodeId" json:"workerNodeId,omitempty"`
	CurVersion           *string           `protobuf:"bytes,3,opt,name=curVersion" json:"curVersion,omitempty"`
	NextVersion          *string           `protobuf:"bytes,4,opt,name=nextVersion" json:"nextVersion,omitempty"`
	FinalVersion         *string           `protobuf:"bytes,5,opt,name=finalVersion" json:"finalVersion,omitempty"`
	Offline              *bool             `protobuf:"varint,6,opt,name=offline,def=0" json:"offline,omitempty"`
	Releasing            *bool             `protobuf:"varint,7,opt,name=releasing,def=0" json:"releasing,omitempty"`
	Reclaiming           *bool             `protobuf:"varint,8,opt,name=reclaiming,def=0" json:"reclaiming,omitempty"`
	ReadyForCurVersion   *bool             `protobuf:"varint,9,opt,name=readyForCurVersion,def=0" json:"readyForCurVersion,omitempty"`
	IsBackup             *bool             `protobuf:"varint,10,opt,name=isBackup,def=0" json:"isBackup,omitempty"`
	LastNotMatchTime     *int64            `protobuf:"varint,11,opt,name=lastNotMatchTime,def=0" json:"lastNotMatchTime,omitempty"`
	LastNotReadyTime     *int64            `protobuf:"varint,12,opt,name=lastNotReadyTime,def=0" json:"lastNotReadyTime,omitempty"`
	SlotAllocStatus      *SlotAllocStatus  `protobuf:"varint,13,opt,name=slotAllocStatus,enum=carbon.SlotAllocStatus,def=0" json:"slotAllocStatus,omitempty"`
	SlotInfo             *SlotInfo         `protobuf:"bytes,14,opt,name=slotInfo" json:"slotInfo,omitempty"`
	HealthInfo           *HealthInfo       `protobuf:"bytes,15,opt,name=healthInfo" json:"healthInfo,omitempty"`
	ServiceInfo          *ServiceStatus    `protobuf:"bytes,16,opt,name=serviceInfo" json:"serviceInfo,omitempty"`
	SlotStatus           *SlotStatus       `protobuf:"bytes,17,opt,name=slotStatus" json:"slotStatus,omitempty"`
	Ip                   *string           `protobuf:"bytes,18,opt,name=ip" json:"ip,omitempty"`
	UserDefVersion       *string           `protobuf:"bytes,19,opt,name=userDefVersion" json:"userDefVersion,omitempty"`
	TargetSignature      *string           `protobuf:"bytes,20,opt,name=targetSignature" json:"targetSignature,omitempty"`
	TargetCustomInfo     *string           `protobuf:"bytes,21,opt,name=targetCustomInfo" json:"targetCustomInfo,omitempty"`
	WorkerMode           *string           `protobuf:"bytes,22,opt,name=workerMode" json:"workerMode,omitempty"`
	Labels               map[string]string `` /* 133-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*WorkerNodeStatus) DeepCopy 

func (in *WorkerNodeStatus) DeepCopy() *WorkerNodeStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new WorkerNodeStatus. Required by controller-gen.

func (*WorkerNodeStatus) DeepCopyInterface 

func (in *WorkerNodeStatus) DeepCopyInterface() interface{}

DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new WorkerNodeStatus. Required by controller-gen.

func (*WorkerNodeStatus) DeepCopyInto 

func (in *WorkerNodeStatus) DeepCopyInto(out *WorkerNodeStatus)

DeepCopyInto supports using WorkerNodeStatus within kubernetes types, where deepcopy-gen is used.

func (*WorkerNodeStatus) Descriptor 

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

func (*WorkerNodeStatus) GetCurVersion 

func (m *WorkerNodeStatus) GetCurVersion() string

func (*WorkerNodeStatus) GetFinalVersion 

func (m *WorkerNodeStatus) GetFinalVersion() string

func (*WorkerNodeStatus) GetHealthInfo 

func (m *WorkerNodeStatus) GetHealthInfo() *HealthInfo

func (*WorkerNodeStatus) GetIp 

func (m *WorkerNodeStatus) GetIp() string

func (*WorkerNodeStatus) GetIsBackup 

func (m *WorkerNodeStatus) GetIsBackup() bool

func (*WorkerNodeStatus) GetLabels 

func (m *WorkerNodeStatus) GetLabels() map[string]string

func (*WorkerNodeStatus) GetLastNotMatchTime 

func (m *WorkerNodeStatus) GetLastNotMatchTime() int64

func (*WorkerNodeStatus) GetLastNotReadyTime 

func (m *WorkerNodeStatus) GetLastNotReadyTime() int64

func (*WorkerNodeStatus) GetNextVersion 

func (m *WorkerNodeStatus) GetNextVersion() string

func (*WorkerNodeStatus) GetOffline 

func (m *WorkerNodeStatus) GetOffline() bool

func (*WorkerNodeStatus) GetReadyForCurVersion 

func (m *WorkerNodeStatus) GetReadyForCurVersion() bool

func (*WorkerNodeStatus) GetReclaiming 

func (m *WorkerNodeStatus) GetReclaiming() bool

func (*WorkerNodeStatus) GetReleasing 

func (m *WorkerNodeStatus) GetReleasing() bool

func (*WorkerNodeStatus) GetReplicaNodeId 

func (m *WorkerNodeStatus) GetReplicaNodeId() string

func (*WorkerNodeStatus) GetServiceInfo 

func (m *WorkerNodeStatus) GetServiceInfo() *ServiceStatus

func (*WorkerNodeStatus) GetSlotAllocStatus 

func (m *WorkerNodeStatus) GetSlotAllocStatus() SlotAllocStatus

func (*WorkerNodeStatus) GetSlotInfo 

func (m *WorkerNodeStatus) GetSlotInfo() *SlotInfo

func (*WorkerNodeStatus) GetSlotStatus 

func (m *WorkerNodeStatus) GetSlotStatus() *SlotStatus

func (*WorkerNodeStatus) GetTargetCustomInfo 

func (m *WorkerNodeStatus) GetTargetCustomInfo() string

func (*WorkerNodeStatus) GetTargetSignature 

func (m *WorkerNodeStatus) GetTargetSignature() string

func (*WorkerNodeStatus) GetUserDefVersion 

func (m *WorkerNodeStatus) GetUserDefVersion() string

func (*WorkerNodeStatus) GetWorkerMode 

func (m *WorkerNodeStatus) GetWorkerMode() string

func (*WorkerNodeStatus) GetWorkerNodeId 

func (m *WorkerNodeStatus) GetWorkerNodeId() string

func (*WorkerNodeStatus) Marshal 

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

func (*WorkerNodeStatus) MarshalTo 

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

func (*WorkerNodeStatus) MarshalToSizedBuffer 

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

func (*WorkerNodeStatus) ProtoMessage 

func (*WorkerNodeStatus) ProtoMessage()

func (*WorkerNodeStatus) Reset 

func (m *WorkerNodeStatus) Reset()

func (*WorkerNodeStatus) Size 

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

func (*WorkerNodeStatus) String 

func (m *WorkerNodeStatus) String() string

func (*WorkerNodeStatus) Unmarshal 

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

func (*WorkerNodeStatus) XXX_DiscardUnknown 

func (m *WorkerNodeStatus) XXX_DiscardUnknown()

func (*WorkerNodeStatus) XXX_Marshal 

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

func (*WorkerNodeStatus) XXX_Merge 

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

func (*WorkerNodeStatus) XXX_Size 

func (m *WorkerNodeStatus) XXX_Size() int

func (*WorkerNodeStatus) XXX_Unmarshal 

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

type WorkerType 

type WorkerType int32
const (
	WorkerType_WT_UNKNOWN   WorkerType = 0
	WorkerType_WT_NOT_READY WorkerType = 1
	WorkerType_WT_READY     WorkerType = 2
)
const Default_HealthInfo_WorkerStatus WorkerType = WorkerType_WT_UNKNOWN

func (WorkerType) Enum 

func (x WorkerType) Enum() *WorkerType

func (WorkerType) EnumDescriptor 

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

func (WorkerType) String 

func (x WorkerType) String() string

func (*WorkerType) UnmarshalJSON 

func (x *WorkerType) UnmarshalJSON(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.