inapi

package
v0.10.2 Latest Latest
Warning

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

 Go to latest Published: May 12, 2024 License: Apache-2.0 Imports: 28 Imported by: 4

Documentation

Index

Constants

View Source 
const (
	RoleMaster = "master"
	RoleMember = "member"
)
View Source 
const (
	ErrCodeServerError           = "ServerError"
	ErrCodeClientError           = "ClientError"
	ErrCodeAccessDenied          = "AccessDenied"
	ErrCodeUnauthorized          = "Unauthorized"
	ErrCodeBadArgument           = "BadArgument"
	ErrCodeObjectPending         = "ObjectPending"
	ErrCodeObjectNotFound        = "ObjectNotFound"
	ErrCodeObjectExists          = "ObjectAlreadyExists"
	ErrCodeObjectPathConflict    = "ObjectPathConflict"
	ErrCodeObjectVersionConflict = "ObjectVersionConflict" // test and set object
)
View Source 
const (
	GeneralPhaseActive  = "Active"
	GeneralPhaseSuspend = "Suspend"
	GeneralPhaseOffline = "Offline"
)
View Source 
const (
	AppSpecExpDeployRepNumMin         int32 = 1 // default
	AppSpecExpDeployRepNumMax         int32 = 32
	AppSpecExpDeploySysStateful       int32 = 1 // default
	AppSpecExpDeploySysStateless      int32 = 2
	AppSpecExpDeployNetworkVpcNameV1        = "v1"
	AppSpecExpDeployNetworkModeBridge int32 = 1 // default
	AppSpecExpDeployNetworkModeHost   int32 = 2
)
View Source 
const (
	AppConfigFieldTypeString uint16 = 1
	AppConfigFieldTypeSelect uint16 = 2

	AppConfigFieldTypeText               uint16 = 300
	AppConfigFieldTypeTextJSON           uint16 = 301
	AppConfigFieldTypeTextTOML           uint16 = 302
	AppConfigFieldTypeTextYAML           uint16 = 303
	AppConfigFieldTypeTextINI            uint16 = 304
	AppConfigFieldTypeTextJavaProperties uint16 = 305

	AppConfigFieldTypeAuthCert uint16 = 900

	AppConfigFieldAutoFillDefaultValue = "defval"
	AppConfigFieldAutoFillHexString_32 = "hexstr_32"
	AppConfigFieldAutoFillBase64_48    = "base64_48"
)
View Source 
const (
	ApiZoneMaster_HostConfig_FullMethodName     = "/inapi.ApiZoneMaster/HostConfig"
	ApiZoneMaster_HostStatusSync_FullMethodName = "/inapi.ApiZoneMaster/HostStatusSync"
)
View Source 
const (
	SpecExecutorPriorityDefault uint8 = 8
	SpecExecutorPriorityMax     uint8 = 15
)
View Source 
const (
	HealthStatusActionActive uint32 = 1 << 1
	HealthStatusActionSetup  uint32 = 1 << 2

	HealthFailoverActiveTimeDef   int32 = 7200
	HealthFailoverActiveTimeMin   int32 = 300
	HealthFailoverScheduleTimeMin int32 = 36000

	HealthFailoverMsgSent uint32 = 1 << 16
)
View Source 
const (
	ByteKB int64 = 1024
	ByteMB       = 1024 * ByteKB
	ByteGB       = 1024 * ByteMB
	ByteTB       = 1024 * ByteGB
	BytePB       = 1024 * ByteTB
	ByteEB       = 1024 * BytePB
)
View Source 
const (
	PbOpLogOK    = "ok"
	PbOpLogInfo  = "info"
	PbOpLogWarn  = "warn"
	PbOpLogError = "error"

	NsOpLogZoneRepMigrateAlloc       = "zm/rep-migrate/alloc"
	NsOpLogZoneRepMigratePrevStop    = "zm/rep-migrate/stop"
	NsOpLogZoneRepMigratePrevDestory = "zm/rep-migrate/destroy"
	NsOpLogZoneRepMigrateNextData    = "zm/rep-migrate/data"
	NsOpLogZoneRepMigrateDone        = "zm/rep-migrate/done"
)
View Source 
const (
	OpLogNsZoneMasterPodScheduleCharge  = "zm/ps/charge"
	OpLogNsZoneMasterPodScheduleAlloc   = "zm/ps/alloc"
	OpLogNsZoneMasterPodScheduleResFree = "zm/ps/resfree"
)
View Source 
const (
	PodSpecBoxImageDocker = "docker"
	PodSpecBoxImageRkt    = "rkt"
	PodSpecBoxImagePouch  = "pouch"
)
View Source 
const (
	PodSpecBoxImageActionEnable  uint32 = 1 << 1
	PodSpecBoxImageActionDisable uint32 = 1 << 3
)
View Source 
const (
	SpecStatusActive  = "active"
	SpecStatusSuspend = "suspend"
)
View Source 
const (
	OpStatusPending   = "pending"
	OpStatusRunning   = "running"
	OpStatusStopped   = "stopped"
	OpStatusFailed    = "failed"
	OpStatusDestroyed = "destroyed"
	OpStatusUnknown   = "unknown"
)
View Source 
const (
	HostSetupStart   uint32 = 1 << 1  // OpActionStart
	HostSetupStop    uint32 = 1 << 3  // OpActionStop
	HostSetupDestroy uint32 = 1 << 5  // OpActionDestroy
	HostSetupForce   uint32 = 1 << 27 // OpActionForce
)
View Source 
const (
	ZoneGroupSetupIn  uint64 = 1 << 1
	ZoneGroupSetupOut uint64 = 1 << 2
)
View Source 
const (
	ResHostCloudProviderSyncBound  uint64 = 1 << 1
	ResHostCloudProviderSyncCreate uint64 = 1 << 2
	ResHostCloudProviderSyncBind   uint64 = 1 << 3
)
View Source 
const (
	ResourceTypeDomain = "domain"
	ResourceActionOK   = "ok"
)
View Source 
const (
	VcsActionOK     uint32 = 1 << 1
	VcsActionER     uint32 = 1 << 2
	VcsActionUnAuth uint32 = 1 << 3
	VcsActionPull   uint32 = 1 << 4
)
View Source 
const (
	ApiHostMember_HostJoin_FullMethodName = "/inapi.ApiHostMember/HostJoin"
)
View Source 
const (
	BoxImageRepoDefault = "sysinner"
)
View Source 
const (
	SpecCpuArchAmd64 = "x64"
)

Variables

View Source 
var (
	AppIdRe2            = regexp.MustCompile("^[a-f0-9]{16,24}$")
	AppSpecIdReg        = regexp.MustCompile("^[a-z]{1}[a-z0-9_-]{2,39}$")
	AppSpecVcsGitUrlReg = regexp.MustCompile(`^(https?:\/\/)([\w\-_\.\/]+)(\.git)$`)
	AppSpecVcsDirReg    = regexp.MustCompile(`^[a-zA-Z0-9\.\/\-_]{1,50}$`)
	AppSpecUrlNameRE    = regexp.MustCompile("^[a-z]{1}[a-z0-9_]{1,30}$")
	AppSpecImageNameRE  = regexp.MustCompile("^[a-z0-9\\-\\_]{1,50}\\/[a-z0-9\\-\\_]{1,50}\\:[a-z0-9\\.\\-\\_]{1,50}$")
)
View Source 
var (
	ConfigFieldType_name = map[int32]string{
		0:   "UnSpec",
		1:   "String",
		2:   "Select",
		300: "Text",
		301: "TextJSON",
		302: "TextTOML",
		303: "TextYAML",
		304: "TextINI",
		305: "TextJavaProperties",
		306: "TextMarkdown",
		900: "AuthCert",
	}
	ConfigFieldType_value = map[string]int32{
		"UnSpec":             0,
		"String":             1,
		"Select":             2,
		"Text":               300,
		"TextJSON":           301,
		"TextTOML":           302,
		"TextYAML":           303,
		"TextINI":            304,
		"TextJavaProperties": 305,
		"TextMarkdown":       306,
		"AuthCert":           900,
	}
)

Enum value maps for ConfigFieldType.

View Source 
var (
	OpActionStart     uint32 = 1 << 1
	OpActionRunning   uint32 = 1 << 2
	OpActionStop      uint32 = 1 << 3
	OpActionStopped   uint32 = 1 << 4
	OpActionDestroy   uint32 = 1 << 5
	OpActionDestroyed uint32 = 1 << 6
	OpActionMigrate   uint32 = 1 << 7
	OpActionMigrated  uint32 = 1 << 8
	OpActionFailover  uint32 = 1 << 9
	OpActionPending   uint32 = 1 << 11
	OpActionWarning   uint32 = 1 << 12
	OpActionRestart   uint32 = 1 << 23
	OpActionResFree   uint32 = 1 << 24
	OpActionHang      uint32 = 1 << 25
	OpActionUnbound   uint32 = 1 << 26
	OpActionForce     uint32 = 1 << 27

	OpActionDesires = []uint32{
		OpActionStart, OpActionRunning,
		OpActionStop, OpActionStopped,
		OpActionDestroy, OpActionDestroyed,
		OpActionMigrate, OpActionMigrated,
	}
)
View Source 
var (
	PodIdReg            = regexp.MustCompile("^[a-f0-9]{16,24}$")
	PodSpecPlanIdReg    = regexp.MustCompile("^[a-z]{1}[a-z0-9]{1,9}$")
	PodSpecImageNameReg = regexp.MustCompile("^[a-z]{1}[a-z0-9\\-\\_\\/]{1,50}$")
	PodSpecImageTagReg  = regexp.MustCompile("^[a-z0-9\\.\\-\\_]{1,50}$")
	PodDestroyTTL       = int64(86400)
	PodPlanChargeCycle  = uint64(3600)
	OCINameRE           = regexp.MustCompile("^[a-zA-Z0-9\\.\\-\\_\\/\\:]{1,50}:[a-zA-Z0-9\\.\\-\\_\\:]{1,50}$")
	PodSpecMountPathRE  = regexp.MustCompile("^[a-zA-Z0-9\\.\\-\\_\\/\\{\\\\}]{1,100}$")
)
View Source 
var (
	SpecOsDistRE  = regexp.MustCompile(`el7|el8|linux|all`)
	SpecCpuArchRE = regexp.MustCompile(`x64|src`)
)
View Source 
var (
	PodOpRepActStart          = OpActionStart
	PodOpRepActStop           = OpActionStop
	PodOpRepActFree           = OpActionDestroy
	PodOpRepActMigrate        = OpActionMigrate
	PodOpRepActWait    uint32 = 1 << 16
)
View Source 
var (
	PbPodSpecBoxImageDriver_name = map[int32]string{
		0: "Unknown",
		1: "Docker",
		2: "Rkt",
		3: "Pouch",
	}
	PbPodSpecBoxImageDriver_value = map[string]int32{
		"Unknown": 0,
		"Docker":  1,
		"Rkt":     2,
		"Pouch":   3,
	}
)

Enum value maps for PbPodSpecBoxImageDriver.

View Source 
var (
	ResSysZoneIdReg        = regexp.MustCompile("^[a-z]{1}[a-z0-9\\-]{1,15}$")
	ResSysCellIdReg        = regexp.MustCompile("^[a-z]{1}[a-z0-9\\-]{1,15}$")
	ResSysHostIdReg        = regexp.MustCompile("^[0-9a-f]{12,16}$")
	ResSysHostSecretKeyReg = regexp.MustCompile("^[0-9a-zA-Z\\+\\/]{20,40}$")
	ResSysNodeNameReg      = regexp.MustCompile("^[0-9a-zA-Z._\\-]{1,30}$")

	ResSysHostPriorityLength  uint32 = 6
	ResSysHostPriorityMin     uint32 = 1
	ResSysHostPriorityMax     uint32 = ResSysHostPriorityLength - 2
	ResSysHostPriorityDefault uint32 = ResSysHostPriorityLength / 2
	ResNetworkDomainNameRE           = regexp.MustCompile("^[0-9a-z._\\-]{1,100}$")

	ZoneGroupIdRX = regexp.MustCompile("^[a-z]{1}[a-z0-9\\-]{1,7}$")
)
View Source 
var (
	ResVolValueAttrOut     uint32 = 1 << 4
	ResVolValueAttrTypeSSD uint32 = 1 << 5
	ResVolValueAttrTypeStd uint32 = 1 << 6
)
View Source 
var (
	VcsRepoGitUrlReg = regexp.MustCompile(`^(https?:\/\/)([\w\-_\.\/]+)(\.git)$`)
	VcsCloneDirReg   = regexp.MustCompile(`^[a-zA-Z0-9\.\/\-_]{1,100}$`)
	VcsGitVerReg     = regexp.MustCompile(`^[a-f0-9]{30,50}$`)
)
View Source 
var ApiHostMember_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "inapi.ApiHostMember",
	HandlerType: (*ApiHostMemberServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "HostJoin",
			Handler:    _ApiHostMember_HostJoin_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "cluster.proto",
}

ApiHostMember_ServiceDesc is the grpc.ServiceDesc for ApiHostMember service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var ApiZoneMaster_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "inapi.ApiZoneMaster",
	HandlerType: (*ApiZoneMasterServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "HostConfig",
			Handler:    _ApiZoneMaster_HostConfig_Handler,
		},
		{
			MethodName: "HostStatusSync",
			Handler:    _ApiZoneMaster_HostStatusSync_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "cluster.proto",
}

ApiZoneMaster_ServiceDesc is the grpc.ServiceDesc for ApiZoneMaster service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var (
	AppSpecTypeTagDicts = []*AppSpecTagEntry{
		{Name: "devops", Value: "DevOps"},
		{Name: "enterprise", Value: "Enterprise"},
		{Name: "database", Value: "Database"},
		{Name: "storage", Value: "Storage"},
		{Name: "runtime", Value: "Runtime"},
		{Name: "bigdata", Value: "BigData"},
		{Name: "net", Value: "Network"},
		{Name: "security", Value: "Security"},
		{Name: "ai", Value: "AI"},
		{Name: "iot", Value: "IoT"},
	}
)
View Source 
var File_app_proto protoreflect.FileDescriptor
View Source 
var File_cluster_proto protoreflect.FileDescriptor
View Source 
var File_config_proto protoreflect.FileDescriptor
View Source 
var File_inapi_proto protoreflect.FileDescriptor
View Source 
var File_mail_proto protoreflect.FileDescriptor
View Source 
var File_operator_proto protoreflect.FileDescriptor
View Source 
var File_pod_proto protoreflect.FileDescriptor
View Source 
var File_stats_proto protoreflect.FileDescriptor
View Source 
var (
	OpLogNsZoneMasterPodScheduleRep = func(repId uint32) string {
		if repId > 65535 {
			repId = 65535
		}
		return fmt.Sprintf("zm/ps/rep/%d", repId)
	}
)

Functions

func AppConfigFieldAutoFillValid 

func AppConfigFieldAutoFillValid(v string) bool

func AppServicePodSliceEqual 

func AppServicePodSliceEqual(ls, ls2 []*AppServicePod) bool

func AppServicePortPodBindSliceEqual 

func AppServicePortPodBindSliceEqual(ls, ls2 []*AppServicePortPodBind) bool

func AppServicePortSliceEqual 

func AppServicePortSliceEqual(ls, ls2 []*AppServicePort) bool

func AppServiceReplicaSliceEqual 

func AppServiceReplicaSliceEqual(ls, ls2 []*AppServiceReplica) bool

func AppSpecDependSliceEqual 

func AppSpecDependSliceEqual(ls, ls2 []*AppSpecDepend) bool

func ArrayStringEqual 

func ArrayStringEqual(ls1, ls2 []string) bool

func ArrayStringHas 

func ArrayStringHas(ls []string, s string) bool

func ArrayStringUniJoin 

func ArrayStringUniJoin(ls []string, s string) []string

func AttrAllow 

func AttrAllow(opbase, op uint64) bool

func AttrAppend 

func AttrAppend(opbase, op uint64) uint64

func AttrRemove 

func AttrRemove(opbase, op uint64) uint64

func ConfigInstanceApply 

func ConfigInstanceApply(inst *ConfigInstance, spec *ConfigSpec) error

func DataAppSpecVersionKey 

func DataAppSpecVersionKey(version string) string

func HealthStatusSliceEqual 

func HealthStatusSliceEqual(ls, ls2 []*HealthStatus) bool

func JsonEncode 

func JsonEncode(v interface{}) []byte

func LabelSliceEqual 

func LabelSliceEqual(ls, ls2 []*Label) bool

func NsGlobalAppInstance 

func NsGlobalAppInstance(appId string) []byte

t3

func NsGlobalAppSpec 

func NsGlobalAppSpec(specId string) []byte

t2

func NsGlobalBoxImage 

func NsGlobalBoxImage(name, tag string) []byte

t2

func NsGlobalPodInstance 

func NsGlobalPodInstance(podId string) []byte

t2

func NsGlobalPodSpec 

func NsGlobalPodSpec(stype, id string) []byte

t2

func NsGlobalResInstance 

func NsGlobalResInstance(subPath string) []byte

t2

func NsGlobalSysCell 

func NsGlobalSysCell(zoneId, cellId string) []byte

t2

func NsGlobalSysConfig 

func NsGlobalSysConfig(name string) []byte

t

func NsGlobalSysHost 

func NsGlobalSysHost(zoneId, hostId string) []byte

t2

func NsGlobalSysZone 

func NsGlobalSysZone(name string) []byte

t2

func NsKeyPathFilter 

func NsKeyPathFilter(path string) []byte

func NsKeyPathLastName 

func NsKeyPathLastName(key []byte) string

func NsKvGlobalAppInstanceDestroyed 

func NsKvGlobalAppInstanceDestroyed(appId string) []byte

t2

func NsKvGlobalAppSpecVersion 

func NsKvGlobalAppSpecVersion(specId, version string) []byte

t2

func NsKvGlobalPodInstanceDestroyed 

func NsKvGlobalPodInstanceDestroyed(podId string) []byte

t2

func NsKvGlobalPodStatus 

func NsKvGlobalPodStatus(zoneId, podId string) []byte

t2

func NsKvGlobalPodUserTransfer 

func NsKvGlobalPodUserTransfer(podId string) []byte

t

func NsKvGlobalSetQueuePod 

func NsKvGlobalSetQueuePod(zoneId, cellId, podId string) []byte

t

func NsKvGlobalSysCellDestroyed 

func NsKvGlobalSysCellDestroyed(zoneId, cellId string) []byte

func NsKvGlobalSysHostDestroyed 

func NsKvGlobalSysHostDestroyed(zoneId, hostId string) []byte

t2

func NsKvGlobalSysZoneDestroyed 

func NsKvGlobalSysZoneDestroyed(name string) []byte

func NsKvLocalCacheBoundPod 

func NsKvLocalCacheBoundPod(podId string, repId uint32) []byte

t2

func NsKvZonePodInstanceDestroy 

func NsKvZonePodInstanceDestroy(zoneId, podId string) []byte

t2

func NsKvZonePodRepStats 

func NsKvZonePodRepStats(zoneId, podId string, repId uint32, name string, timo uint32) []byte

t2

func NsKvZonePodStatus 

func NsKvZonePodStatus(zoneId, podId string) []byte

t2

func NsKvZoneSysCellDestroyed 

func NsKvZoneSysCellDestroyed(zoneId, cellId string) []byte

func NsKvZoneSysHostDestroyed 

func NsKvZoneSysHostDestroyed(zoneId, hostId string) []byte

t2

func NsKvZoneSysHostStats 

func NsKvZoneSysHostStats(zoneId, hostId string, timo uint32) []byte

t2

func NsKvZoneSysMasterLeader 

func NsKvZoneSysMasterLeader(zoneId string) []byte

func NsKvZoneSysZoneDestroyed 

func NsKvZoneSysZoneDestroyed(zoneId string) []byte

func NsZoneMailQueue 

func NsZoneMailQueue(key string) []byte

func NsZonePodInstance 

func NsZonePodInstance(zoneId, podId string) []byte

t2

func NsZonePodOpRepKey 

func NsZonePodOpRepKey(podId string, repId uint32) string

func NsZonePodOpRepKeyValid 

func NsZonePodOpRepKeyValid(key string) bool

func NsZoneSysCell 

func NsZoneSysCell(zoneId, cellId string) []byte

t2

func NsZoneSysHost 

func NsZoneSysHost(zoneId, hostId string) []byte

t2

func NsZoneSysHostSecretKey 

func NsZoneSysHostSecretKey(zoneId, hostId string) []byte

t2

func NsZoneSysMasterNode 

func NsZoneSysMasterNode(zoneId, nodeId string) []byte

t2

func NsZoneSysZone 

func NsZoneSysZone(zoneId string) []byte

t2

func ObjPrint 

func ObjPrint(name string, v interface{})

func ObjSprint 

func ObjSprint(v interface{}, idx string) string

func OpActionAllow 

func OpActionAllow(opbase, op uint32) bool

func OpActionAppend 

func OpActionAppend(opbase, op uint32) uint32

func OpActionControlFilter 

func OpActionControlFilter(opbase uint32) uint32

func OpActionDesire 

func OpActionDesire(opbase, op uint32) uint32

func OpActionRemove 

func OpActionRemove(opbase, op uint32) uint32

func OpActionStatusClean 

func OpActionStatusClean(opCtr, opStatus uint32) uint32

func OpActionStrings 

func OpActionStrings(action uint32) []string

func OpActionValid 

func OpActionValid(op uint32) bool

func PbArrayBytesSliceEqual 

func PbArrayBytesSliceEqual(ls, ls2 [][]byte) bool

func PbBytesSliceEqual 

func PbBytesSliceEqual(ls, ls2 []byte) bool

func PbInt32SliceEqual 

func PbInt32SliceEqual(ls, ls2 []int32) bool

func PbInt32SliceSyncSlice 

func PbInt32SliceSyncSlice(ls, ls2 []int32) ([]int32, bool)

func PbOpLogEntrySliceEqual 

func PbOpLogEntrySliceEqual(ls, ls2 []*PbOpLogEntry) bool

func PbOpLogSetsSliceEqual 

func PbOpLogSetsSliceEqual(ls, ls2 []*PbOpLogSets) bool

func PbPodBoxStatusExecutorSliceEqual 

func PbPodBoxStatusExecutorSliceEqual(ls, ls2 []*PbPodBoxStatusExecutor) bool

func PbPodBoxStatusSliceEqual 

func PbPodBoxStatusSliceEqual(ls, ls2 []*PbPodBoxStatus) bool

func PbPodRepStatusSliceEqual 

func PbPodRepStatusSliceEqual(ls, ls2 []*PbPodRepStatus) bool

func PbServicePortSliceEqual 

func PbServicePortSliceEqual(ls, ls2 []*PbServicePort) bool

func PbStatsSampleEntrySliceEqual 

func PbStatsSampleEntrySliceEqual(ls, ls2 []*PbStatsSampleEntry) bool

func PbStatsSampleFeedSliceEqual 

func PbStatsSampleFeedSliceEqual(ls, ls2 []*PbStatsSampleFeed) bool

func PbStatsSampleValueSliceEqual 

func PbStatsSampleValueSliceEqual(ls, ls2 []*PbStatsSampleValue) bool

func PbStringSliceEqual 

func PbStringSliceEqual(ls, ls2 []string) bool

func PbStringSliceSyncSlice 

func PbStringSliceSyncSlice(ls, ls2 []string) ([]string, bool)

func PbUint32SliceEqual 

func PbUint32SliceEqual(ls, ls2 []uint32) bool

func PbUint32SliceSyncSlice 

func PbUint32SliceSyncSlice(ls, ls2 []uint32) ([]uint32, bool)

func PbVolumeMountSliceEqual 

func PbVolumeMountSliceEqual(ls, ls2 []*PbVolumeMount) bool

func PbVolumeStatusSliceEqual 

func PbVolumeStatusSliceEqual(ls, ls2 []*PbVolumeStatus) bool

func PodOperateFailoverReplicaSliceEqual 

func PodOperateFailoverReplicaSliceEqual(ls, ls2 []*PodOperateFailoverReplica) bool

func PodRepInstanceName 

func PodRepInstanceName(podId string, repId uint32) string

func PodSpecBoxImageDriverName 

func PodSpecBoxImageDriverName(v PbPodSpecBoxImageDriver) string

func PodUserTransferSliceEqual 

func PodUserTransferSliceEqual(ls, ls2 []*PodUserTransfer) bool

func PrivateIPValid 

func PrivateIPValid(ipAddr string) error

func RegisterApiHostMemberServer 

func RegisterApiHostMemberServer(s grpc.ServiceRegistrar, srv ApiHostMemberServer)

func RegisterApiZoneMasterServer 

func RegisterApiZoneMasterServer(s grpc.ServiceRegistrar, srv ApiZoneMasterServer)

func ResImageServiceSliceEqual 

func ResImageServiceSliceEqual(ls, ls2 []*ResImageService) bool

func ResVolValueSliceEqual 

func ResVolValueSliceEqual(ls, ls2 []*ResVolValue) bool

func SliceFind 

func SliceFind(ar interface{}, equal func(i int) bool) interface{}

func SliceMerge 

func SliceMerge(ar interface{}, v interface{}, equal func(i int) bool) (interface{}, bool)

func SysHostActionFilter 

func SysHostActionFilter(op uint32) uint32

func TimeNowMs 

func TimeNowMs() int64

func ValidUtf8String 

func ValidUtf8String(s string, min, max int) error

func ValueEqual 

func ValueEqual(v1, v2 interface{}) bool

Types

type ApiHostMemberClient 

type ApiHostMemberClient interface {
	HostJoin(ctx context.Context, in *ResHostNew, opts ...grpc.CallOption) (*ResHost, error)
}

ApiHostMemberClient is the client API for ApiHostMember service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewApiHostMemberClient 

func NewApiHostMemberClient(cc grpc.ClientConnInterface) ApiHostMemberClient

type ApiHostMemberServer 

type ApiHostMemberServer interface {
	HostJoin(context.Context, *ResHostNew) (*ResHost, error)
	// contains filtered or unexported methods
}

ApiHostMemberServer is the server API for ApiHostMember service. All implementations must embed UnimplementedApiHostMemberServer for forward compatibility

type ApiZoneMasterClient 

type ApiZoneMasterClient interface {
	HostConfig(ctx context.Context, in *ZoneHostConfigRequest, opts ...grpc.CallOption) (*ZoneHostConfigReply, error)
	HostStatusSync(ctx context.Context, in *ResHost, opts ...grpc.CallOption) (*ResHostBound, error)
}

ApiZoneMasterClient is the client API for ApiZoneMaster service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewApiZoneMasterClient 

func NewApiZoneMasterClient(cc grpc.ClientConnInterface) ApiZoneMasterClient

type ApiZoneMasterServer 

type ApiZoneMasterServer interface {
	HostConfig(context.Context, *ZoneHostConfigRequest) (*ZoneHostConfigReply, error)
	HostStatusSync(context.Context, *ResHost) (*ResHostBound, error)
	// contains filtered or unexported methods
}

ApiZoneMasterServer is the server API for ApiZoneMaster service. All implementations must embed UnimplementedApiZoneMasterServer for forward compatibility

type AppConfigDepend 

type AppConfigDepend struct {
	Name  types.NameIdentifier `json:"name" toml:"name"`
	Title string               `json:"title,omitempty" toml:"title,omitempty"`
}

type AppConfigDepends 

type AppConfigDepends []*AppConfigDepend

type AppConfigField 

type AppConfigField struct {
	Name        string        `json:"name" toml:"name"`
	Title       string        `json:"title,omitempty" toml:"title,omitempty"`
	Prompt      string        `json:"prompt,omitempty" toml:"prompt,omitempty"`
	Type        uint16        `json:"type,omitempty" toml:"type,omitempty"`
	Default     string        `json:"default,omitempty" toml:"default,omitempty"`
	AutoFill    string        `json:"auto_fill,omitempty" toml:"auto_fill,omitempty"`
	Enums       types.Labels  `json:"enums,omitempty" toml:"enums,omitempty"`
	Validates   types.KvPairs `json:"validates,omitempty" toml:"validates,omitempty"`
	Description string        `json:"description,omitempty" toml:"description,omitempty"`
}

type AppConfigFieldHelper 

type AppConfigFieldHelper interface {
	Valid(field *AppConfigField) error
}

type AppConfigFieldTypeCA 

type AppConfigFieldTypeCA struct {
}

func (*AppConfigFieldTypeCA) Valid 

func (it *AppConfigFieldTypeCA) Valid(field *AppConfigField) error

type AppConfigFields 

type AppConfigFields []*AppConfigField

func (*AppConfigFields) Del 

func (ls *AppConfigFields) Del(name string)

func (*AppConfigFields) Sync 

func (ls *AppConfigFields) Sync(item AppConfigField)

type AppConfigSet 

type AppConfigSet struct {
	Id         string                           `json:"id" toml:"id"`
	SpecId     string                           `json:"spec_id" toml:"spec_id"`
	Option     AppOption                        `json:"option" toml:"option"`
	DepRemotes []*AppConfigSetAppSpecRemoteBind `json:"dep_remotes,omitempty" toml:"dep_remotes,omitempty"`
}

type AppConfigSetAppSpecRemoteBind 

type AppConfigSetAppSpecRemoteBind struct {
	SpecId  string   `json:"spec_id" toml:"spec_id"`
	AppId   string   `json:"app_id" toml:"app_id"`
	Configs []string `json:"configs" toml:"configs"`
	Delete  bool     `json:"delete,omitempty" toml:"delete,omitempty"`
}

type AppConfigurator 

type AppConfigurator struct {
	Name   types.NameIdentifier `json:"name" toml:"name"`
	Fields AppConfigFields      `json:"fields,omitempty" toml:"fields,omitempty"`
}

func (*AppConfigurator) Valid 

func (it *AppConfigurator) Valid() error

type AppInstance 

type AppInstance struct {
	types.TypeMeta `json:",inline" toml:",inline"`
	Meta           types.InnerObjectMeta `json:"meta,omitempty" toml:"meta,omitempty"`

	// Spec defines the behavior of a app.
	Spec AppSpec `json:"spec,omitempty" toml:"spec,omitempty"`

	//
	Operate AppOperate `json:"operate,omitempty" toml:"operate,omitempty"`

	// Status represents the current information about a app. This data may not be up
	// to date.
	Status *AppStatus `json:"status,omitempty" toml:"status,omitempty"`
}

type AppInstanceList 

type AppInstanceList struct {
	types.TypeMeta `json:",inline" toml:",inline"`
	Items          AppInstances `json:"items,omitempty" toml:"items,omitempty"`
}

type AppInstances 

type AppInstances []*AppInstance

func (*AppInstances) ExecutorSync 

func (ls *AppInstances) ExecutorSync(executor Executor, app_id string)

func (*AppInstances) NetworkModeHost 

func (ls *AppInstances) NetworkModeHost() bool

func (*AppInstances) SpecExpDeployFailoverEnable 

func (ls *AppInstances) SpecExpDeployFailoverEnable() bool

func (*AppInstances) SpecExpDeployFailoverLimits 

func (ls *AppInstances) SpecExpDeployFailoverLimits() (delaySeconds, numMax, rateMax int32)

func (*AppInstances) SpecExpDeployStateless 

func (ls *AppInstances) SpecExpDeployStateless() bool

func (*AppInstances) Sync 

func (ls *AppInstances) Sync(app *AppInstance)

type AppOperate 

type AppOperate struct {
	Action        uint32            `json:"action,omitempty" toml:"action,omitempty"`
	Zone          string            `json:"zone,omitempty" toml:"zone,omitempty"`
	PodId         string            `json:"pod_id,omitempty" toml:"pod_id,omitempty"`
	Options       AppOptions        `json:"options,omitempty" toml:"options,omitempty"`
	Services      []*AppServicePort `json:"services,omitempty" toml:"services,omitempty"`
	BindServices  []*AppServicePort `json:"bind_services,omitempty" toml:"bind_services,omitempty"`
	ResBoundRoles types.ArrayUint32 `json:"res_bound_roles,omitempty" toml:"res_bound_roles,omitempty"`
}

func (*AppOperate) Service 

func (it *AppOperate) Service(spec string, port uint32, pod_id string) *AppServicePort

type AppOption 

type AppOption struct {
	Name    types.NameIdentifier `json:"name" toml:"name"`
	Items   []*AppOptionField    `json:"items,omitempty" toml:"items,omitempty"`
	Subs    types.ArrayString    `json:"subs,omitempty" toml:"subs,omitempty"`
	Ref     *AppOptionRef        `json:"ref,omitempty" toml:"ref,omitempty"`
	User    string               `json:"user,omitempty" toml:"user,omitempty"`
	Updated types.MetaTime       `json:"updated,omitempty" toml:"updated,omitempty"`
}

func (*AppOption) Field 

func (it *AppOption) Field(name string) *AppOptionField

func (*AppOption) Value 

func (it *AppOption) Value(name string) types.Bytex

func (*AppOption) ValueOK 

func (it *AppOption) ValueOK(name string) (types.Bytex, bool)

type AppOptionField 

type AppOptionField struct {
	Type  uint16 `json:"type,omitempty" toml:"type,omitempty"`
	Name  string `json:"name" toml:"name"`
	Value string `json:"value" toml:"value"`
}

type AppOptionRef 

type AppOptionRef struct {
	SpecId  string       `json:"spec_id" toml:"spec_id"`
	AppId   string       `json:"app_id" toml:"app_id"`
	PodId   string       `json:"pod_id" toml:"pod_id"`
	Ports   ServicePorts `json:"ports,omitempty" toml:"ports,omitempty"`
	Updated int64        `json:"updated,omitempty" toml:"updated,omitempty"`
}

func (*AppOptionRef) Equal 

func (it *AppOptionRef) Equal(item *AppOptionRef) bool

type AppOptionRefs 

type AppOptionRefs []*AppOptionRef

func (*AppOptionRefs) Del 

func (ls *AppOptionRefs) Del(app_id string)

func (*AppOptionRefs) Equal 

func (ls *AppOptionRefs) Equal(items AppOptionRefs) bool

func (*AppOptionRefs) Get 

func (ls *AppOptionRefs) Get(app_id string) *AppOptionRef

func (*AppOptionRefs) Sync 

func (ls *AppOptionRefs) Sync(item AppOptionRef) (changed bool)

type AppOptions 

type AppOptions []*AppOption

func (*AppOptions) Del 

func (ls *AppOptions) Del(name string)

func (*AppOptions) Get 

func (ls *AppOptions) Get(name string) *AppOption

func (*AppOptions) Set 

func (ls *AppOptions) Set(item AppOption) (changed bool)

func (*AppOptions) Sync 

func (ls *AppOptions) Sync(item AppOption) (changed bool)

type AppPackages 

type AppPackages []VolumePackage

func (*AppPackages) Insert 

func (ls *AppPackages) Insert(vol VolumePackage)

func (*AppPackages) Remove 

func (ls *AppPackages) Remove(name string)

type AppPhase 

type AppPhase string
const (
	AppPending   AppPhase = "Pending"
	AppRunning   AppPhase = "Running"
	AppSucceeded AppPhase = "Succeeded"
	AppFailed    AppPhase = "Failed"
)

type AppServicePod 

type AppServicePod struct {
	PodId   string            `protobuf:"bytes,1,opt,name=pod_id,json=podId,proto3" json:"pod_id,omitempty" toml:"pod_id,omitempty"` // struct:object_slice_key
	Ports   []*AppServicePort `protobuf:"bytes,4,rep,name=ports,proto3" json:"ports,omitempty" toml:"ports,omitempty"`
	Updated int64             `protobuf:"varint,5,opt,name=updated,proto3" json:"updated,omitempty" toml:"updated,omitempty"` // struct:object_slice_equal_skip
	// contains filtered or unexported fields
}

func AppServicePodSliceDel 

func AppServicePodSliceDel(ls []*AppServicePod, arg_podid string) ([]*AppServicePod, bool)

func AppServicePodSliceGet 

func AppServicePodSliceGet(ls []*AppServicePod, arg_podid string) *AppServicePod

func AppServicePodSliceSync 

func AppServicePodSliceSync(ls []*AppServicePod, it2 *AppServicePod) ([]*AppServicePod, bool)

func AppServicePodSliceSyncSlice 

func AppServicePodSliceSyncSlice(ls, ls2 []*AppServicePod) ([]*AppServicePod, bool)

func (*AppServicePod) Descriptor deprecated 

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

Deprecated: Use AppServicePod.ProtoReflect.Descriptor instead.

func (*AppServicePod) Equal 

func (it *AppServicePod) Equal(it2 *AppServicePod) bool

func (*AppServicePod) GetPodId 

func (x *AppServicePod) GetPodId() string

func (*AppServicePod) GetPorts 

func (x *AppServicePod) GetPorts() []*AppServicePort

func (*AppServicePod) GetUpdated 

func (x *AppServicePod) GetUpdated() int64

func (*AppServicePod) ProtoMessage 

func (*AppServicePod) ProtoMessage()

func (*AppServicePod) ProtoReflect 

func (x *AppServicePod) ProtoReflect() protoreflect.Message

func (*AppServicePod) Reset 

func (x *AppServicePod) Reset()

func (*AppServicePod) String 

func (x *AppServicePod) String() string

func (*AppServicePod) Sync 

func (it *AppServicePod) Sync(it2 *AppServicePod) bool

type AppServicePort 

type AppServicePort struct {
	Port      uint32               `protobuf:"varint,1,opt,name=port,proto3" json:"port,omitempty" toml:"port,omitempty"` // struct:object_slice_key
	Endpoints []*AppServiceReplica `protobuf:"bytes,2,rep,name=endpoints,proto3" json:"endpoints,omitempty" toml:"endpoints,omitempty"`
	Updated   int64                `protobuf:"varint,3,opt,name=updated,proto3" json:"updated,omitempty" toml:"updated,omitempty"` // struct:object_slice_equal_skip
	Name      string               `protobuf:"bytes,5,opt,name=name,proto3" json:"name,omitempty" toml:"name,omitempty"`
	Spec      string               `protobuf:"bytes,6,opt,name=spec,proto3" json:"spec,omitempty" toml:"spec,omitempty"`
	PodId     string               `protobuf:"bytes,7,opt,name=pod_id,json=podId,proto3" json:"pod_id,omitempty" toml:"pod_id,omitempty"` // struct:object_slice_key
	AppId     string               `protobuf:"bytes,8,opt,name=app_id,json=appId,proto3" json:"app_id,omitempty" toml:"app_id,omitempty"`
	// contains filtered or unexported fields
}

func AppServicePortSliceDel 

func AppServicePortSliceDel(ls []*AppServicePort, arg_port uint32, arg_podid string) ([]*AppServicePort, bool)

func AppServicePortSliceGet 

func AppServicePortSliceGet(ls []*AppServicePort, arg_port uint32, arg_podid string) *AppServicePort

func AppServicePortSliceSync 

func AppServicePortSliceSync(ls []*AppServicePort, it2 *AppServicePort) ([]*AppServicePort, bool)

func AppServicePortSliceSyncSlice 

func AppServicePortSliceSyncSlice(ls, ls2 []*AppServicePort) ([]*AppServicePort, bool)

func (*AppServicePort) Descriptor deprecated 

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

Deprecated: Use AppServicePort.ProtoReflect.Descriptor instead.

func (*AppServicePort) Equal 

func (it *AppServicePort) Equal(it2 *AppServicePort) bool

func (*AppServicePort) GetAppId 

func (x *AppServicePort) GetAppId() string

func (*AppServicePort) GetEndpoints 

func (x *AppServicePort) GetEndpoints() []*AppServiceReplica

func (*AppServicePort) GetName 

func (x *AppServicePort) GetName() string

func (*AppServicePort) GetPodId 

func (x *AppServicePort) GetPodId() string

func (*AppServicePort) GetPort 

func (x *AppServicePort) GetPort() uint32

func (*AppServicePort) GetSpec 

func (x *AppServicePort) GetSpec() string

func (*AppServicePort) GetUpdated 

func (x *AppServicePort) GetUpdated() int64

func (*AppServicePort) ProtoMessage 

func (*AppServicePort) ProtoMessage()

func (*AppServicePort) ProtoReflect 

func (x *AppServicePort) ProtoReflect() protoreflect.Message

func (*AppServicePort) Reset 

func (x *AppServicePort) Reset()

func (*AppServicePort) String 

func (x *AppServicePort) String() string

func (*AppServicePort) Sync 

func (it *AppServicePort) Sync(it2 *AppServicePort) bool

type AppServicePortPodBind 

type AppServicePortPodBind struct {
	Port      uint32               `protobuf:"varint,1,opt,name=port,proto3" json:"port,omitempty" toml:"port,omitempty"`                 // struct:object_slice_key
	PodId     string               `protobuf:"bytes,2,opt,name=pod_id,json=podId,proto3" json:"pod_id,omitempty" toml:"pod_id,omitempty"` // struct:object_slice_key
	Endpoints []*AppServiceReplica `protobuf:"bytes,3,rep,name=endpoints,proto3" json:"endpoints,omitempty" toml:"endpoints,omitempty"`
	Updated   int64                `protobuf:"varint,4,opt,name=updated,proto3" json:"updated,omitempty" toml:"updated,omitempty"` // struct:object_slice_equal_skip
	// contains filtered or unexported fields
}

func AppServicePortPodBindSliceDel 

func AppServicePortPodBindSliceDel(ls []*AppServicePortPodBind, arg_port uint32, arg_podid string) ([]*AppServicePortPodBind, bool)

func AppServicePortPodBindSliceGet 

func AppServicePortPodBindSliceGet(ls []*AppServicePortPodBind, arg_port uint32, arg_podid string) *AppServicePortPodBind

func AppServicePortPodBindSliceSync 

func AppServicePortPodBindSliceSync(ls []*AppServicePortPodBind, it2 *AppServicePortPodBind) ([]*AppServicePortPodBind, bool)

func AppServicePortPodBindSliceSyncSlice 

func AppServicePortPodBindSliceSyncSlice(ls, ls2 []*AppServicePortPodBind) ([]*AppServicePortPodBind, bool)

func (*AppServicePortPodBind) Descriptor deprecated 

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

Deprecated: Use AppServicePortPodBind.ProtoReflect.Descriptor instead.

func (*AppServicePortPodBind) Equal 

func (it *AppServicePortPodBind) Equal(it2 *AppServicePortPodBind) bool

func (*AppServicePortPodBind) GetEndpoints 

func (x *AppServicePortPodBind) GetEndpoints() []*AppServiceReplica

func (*AppServicePortPodBind) GetPodId 

func (x *AppServicePortPodBind) GetPodId() string

func (*AppServicePortPodBind) GetPort 

func (x *AppServicePortPodBind) GetPort() uint32

func (*AppServicePortPodBind) GetUpdated 

func (x *AppServicePortPodBind) GetUpdated() int64

func (*AppServicePortPodBind) ProtoMessage 

func (*AppServicePortPodBind) ProtoMessage()

func (*AppServicePortPodBind) ProtoReflect 

func (x *AppServicePortPodBind) ProtoReflect() protoreflect.Message

func (*AppServicePortPodBind) Reset 

func (x *AppServicePortPodBind) Reset()

func (*AppServicePortPodBind) String 

func (x *AppServicePortPodBind) String() string

func (*AppServicePortPodBind) Sync 

func (it *AppServicePortPodBind) Sync(it2 *AppServicePortPodBind) bool

type AppServiceReplica 

type AppServiceReplica struct {
	Rep     uint32 `protobuf:"varint,1,opt,name=rep,proto3" json:"rep,omitempty" toml:"rep,omitempty"` // struct:object_slice_key
	Ip      string `protobuf:"bytes,2,opt,name=ip,proto3" json:"ip,omitempty" toml:"ip,omitempty"`
	Port    uint32 `protobuf:"varint,3,opt,name=port,proto3" json:"port,omitempty" toml:"port,omitempty"`
	VpcIpv4 string `protobuf:"bytes,4,opt,name=vpc_ipv4,json=vpcIpv4,proto3" json:"vpc_ipv4,omitempty" toml:"vpc_ipv4,omitempty"`
	// contains filtered or unexported fields
}

func AppServiceReplicaSliceDel 

func AppServiceReplicaSliceDel(ls []*AppServiceReplica, arg_rep uint32) ([]*AppServiceReplica, bool)

func AppServiceReplicaSliceGet 

func AppServiceReplicaSliceGet(ls []*AppServiceReplica, arg_rep uint32) *AppServiceReplica

func AppServiceReplicaSliceSync 

func AppServiceReplicaSliceSync(ls []*AppServiceReplica, it2 *AppServiceReplica) ([]*AppServiceReplica, bool)

func AppServiceReplicaSliceSyncSlice 

func AppServiceReplicaSliceSyncSlice(ls, ls2 []*AppServiceReplica) ([]*AppServiceReplica, bool)

func (*AppServiceReplica) Descriptor deprecated 

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

Deprecated: Use AppServiceReplica.ProtoReflect.Descriptor instead.

func (*AppServiceReplica) Equal 

func (it *AppServiceReplica) Equal(it2 *AppServiceReplica) bool

func (*AppServiceReplica) GetIp 

func (x *AppServiceReplica) GetIp() string

func (*AppServiceReplica) GetPort 

func (x *AppServiceReplica) GetPort() uint32

func (*AppServiceReplica) GetRep 

func (x *AppServiceReplica) GetRep() uint32

func (*AppServiceReplica) GetVpcIpv4 

func (x *AppServiceReplica) GetVpcIpv4() string

func (*AppServiceReplica) ProtoMessage 

func (*AppServiceReplica) ProtoMessage()

func (*AppServiceReplica) ProtoReflect 

func (x *AppServiceReplica) ProtoReflect() protoreflect.Message

func (*AppServiceReplica) Reset 

func (x *AppServiceReplica) Reset()

func (*AppServiceReplica) String 

func (x *AppServiceReplica) String() string

func (*AppServiceReplica) Sync 

func (it *AppServiceReplica) Sync(it2 *AppServiceReplica) bool

type AppSpec 

type AppSpec struct {
	types.TypeMeta `json:",inline" toml:",inline"`
	Meta           types.InnerObjectMeta         `json:"meta" toml:"meta"`
	LastVersion    string                        `json:"last_version,omitempty" toml:"last_version,omitempty"`
	Roles          types.ArrayUint32             `json:"roles,omitempty" toml:"roles,omitempty"`
	Vendor         string                        `json:"vendor,omitempty" toml:"vendor,omitempty"`
	RuntimeImages  []string                      `json:"runtime_images,omitempty" toml:"runtime_images,omitempty"`
	Depends        []*AppSpecDepend              `json:"depends,omitempty" toml:"depends,omitempty"`
	DepRemotes     []*AppSpecDepend              `json:"dep_remotes,omitempty" toml:"dep_remotes,omitempty"`
	Packages       AppPackages                   `json:"packages,omitempty" toml:"packages,omitempty"`
	VcsRepos       VcsRepoItems                  `json:"vcs_repos,omitempty" toml:"vcs_repos,omitempty"`
	Executors      Executors                     `json:"executors,omitempty" toml:"executors,omitempty"`
	VolumeMounts   AppVolumeMounts               `json:"volume_mounts,omitempty" toml:"volume_mounts,omitempty"`
	ServicePorts   ServicePorts                  `json:"service_ports,omitempty" toml:"service_ports,omitempty"`
	Configurator   *AppConfigurator              `json:"configurator,omitempty" toml:"configurator,omitempty"`
	ExpRes         *AppSpecResRequirements       `json:"exp_res,omitempty" toml:"exp_res,omitempty"`
	ExpDeploy      *AppSpecExpDeployRequirements `json:"exp_deploy,omitempty" toml:"exp_deploy,omitempty"`
	Comment        string                        `json:"comment,omitempty" toml:"comment,omitempty"`
	TypeTags       []string                      `json:"type_tags,omitempty" toml:"type_tags,omitempty"`
	Description    string                        `json:"description,omitempty" toml:"description,omitempty"`
	Urls           []*AppSpecUrlEntry            `json:"urls,omitempty" toml:"urls,omitempty"`
}

func (*AppSpec) Fix 

func (it *AppSpec) Fix() *AppSpec

func (*AppSpec) Reset 

func (it *AppSpec) Reset() *AppSpec

func (*AppSpec) UnmarshalJSON 

func (it *AppSpec) UnmarshalJSON(b []byte) error

type AppSpecDepend 

type AppSpecDepend struct {
	Id       string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty" toml:"id,omitempty"` // struct:object_slice_key
	Name     string   `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty" toml:"name,omitempty"`
	Version  string   `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty" toml:"version,omitempty"`
	Priority int32    `protobuf:"varint,4,opt,name=priority,proto3" json:"priority,omitempty" toml:"priority,omitempty"`
	Configs  []string `protobuf:"bytes,5,rep,name=configs,proto3" json:"configs,omitempty" toml:"configs,omitempty"`
	// contains filtered or unexported fields
}

host

func AppSpecDependSliceDel 

func AppSpecDependSliceDel(ls []*AppSpecDepend, arg_id string) ([]*AppSpecDepend, bool)

func AppSpecDependSliceGet 

func AppSpecDependSliceGet(ls []*AppSpecDepend, arg_id string) *AppSpecDepend

func AppSpecDependSliceSync 

func AppSpecDependSliceSync(ls []*AppSpecDepend, it2 *AppSpecDepend) ([]*AppSpecDepend, bool)

func AppSpecDependSliceSyncSlice 

func AppSpecDependSliceSyncSlice(ls, ls2 []*AppSpecDepend) ([]*AppSpecDepend, bool)

func (*AppSpecDepend) Descriptor deprecated 

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

Deprecated: Use AppSpecDepend.ProtoReflect.Descriptor instead.

func (*AppSpecDepend) Equal 

func (it *AppSpecDepend) Equal(it2 *AppSpecDepend) bool

func (*AppSpecDepend) GetConfigs 

func (x *AppSpecDepend) GetConfigs() []string

func (*AppSpecDepend) GetId 

func (x *AppSpecDepend) GetId() string

func (*AppSpecDepend) GetName 

func (x *AppSpecDepend) GetName() string

func (*AppSpecDepend) GetPriority 

func (x *AppSpecDepend) GetPriority() int32

func (*AppSpecDepend) GetVersion 

func (x *AppSpecDepend) GetVersion() string

func (*AppSpecDepend) ProtoMessage 

func (*AppSpecDepend) ProtoMessage()

func (*AppSpecDepend) ProtoReflect 

func (x *AppSpecDepend) ProtoReflect() protoreflect.Message

func (*AppSpecDepend) Reset 

func (x *AppSpecDepend) Reset()

func (*AppSpecDepend) String 

func (x *AppSpecDepend) String() string

func (*AppSpecDepend) Sync 

func (it *AppSpecDepend) Sync(it2 *AppSpecDepend) bool

func (*AppSpecDepend) UnmarshalJSON 

func (it *AppSpecDepend) UnmarshalJSON(b []byte) error

func (*AppSpecDepend) Valid 

func (it *AppSpecDepend) Valid() error

type AppSpecDependPrev 

type AppSpecDependPrev AppSpecDepend

type AppSpecExpDeployRequirements 

type AppSpecExpDeployRequirements struct {
	RepMin   int32 `json:"rep_min,omitempty" toml:"rep_min,omitempty"`
	RepMax   int32 `json:"rep_max,omitempty" toml:"rep_max,omitempty"`
	SysState int32 `json:"sys_state,omitempty" toml:"sys_state,omitempty"`
	// High-Availability
	FailoverTime    int32  `json:"failover_time,omitempty" toml:"failover_time,omitempty"`         // in seconds
	FailoverNumMax  int32  `json:"failover_num_max,omitempty" toml:"failover_num_max,omitempty"`   // [0, RepMax)
	FailoverRateMax int32  `json:"failover_rate_max,omitempty" toml:"failover_rate_max,omitempty"` // [0, 100) in %
	NetworkMode     int32  `json:"network_mode" toml:"network_mode"`
	NetworkVpcName  string `json:"network_vpc_name,omitempty" toml:"network_vpc_name,omitempty"`
}

func (*AppSpecExpDeployRequirements) FailoverEnable 

func (it *AppSpecExpDeployRequirements) FailoverEnable() bool

func (*AppSpecExpDeployRequirements) Stateless 

func (it *AppSpecExpDeployRequirements) Stateless() bool

type AppSpecList 

type AppSpecList struct {
	types.TypeMeta `json:",inline" toml:",inline"`
	Items          []*AppSpec         `json:"items,omitempty" toml:"items,omitempty"`
	TypeTagDicts   []*AppSpecTagEntry `json:"type_tag_dicts,omitempty" toml:"type_tag_dicts,omitempty"`
}

type AppSpecPrev 

type AppSpecPrev AppSpec

type AppSpecResRequirements 

type AppSpecResRequirements struct {
	CpuMin int32 `json:"cpu_min,omitempty" toml:"cpu_min,omitempty"`
	MemMin int32 `json:"mem_min,omitempty" toml:"mem_min,omitempty"`
	VolMin int32 `json:"vol_min,omitempty" toml:"vol_min,omitempty"`
}

type AppSpecTagEntry 

type AppSpecTagEntry struct {
	Name  string `json:"name" toml:"name"`
	Value string `json:"value" toml:"value"`
}

type AppSpecUrlEntry 

type AppSpecUrlEntry struct {
	Name string `json:"name" toml:"name"`
	Url  string `json:"url,omitempty" toml:"url,omitempty"`
}

type AppSpecVersion 

type AppSpecVersion struct {
	Major uint32
	Minor uint32
	Patch uint32
	// contains filtered or unexported fields
}

func NewAppSpecVersion 

func NewAppSpecVersion(vstr string) *AppSpecVersion

func (*AppSpecVersion) Add 

func (v *AppSpecVersion) Add(Major, Minor, Patch bool) *AppSpecVersion

func (*AppSpecVersion) Compare 

func (va *AppSpecVersion) Compare(vb *AppSpecVersion) int

Compare compares this version to another version. This returns -1, 0, or 1 if this version is smaller, equal, or larger than the compared version, respectively.

func (*AppSpecVersion) FullHexString 

func (v *AppSpecVersion) FullHexString() string

func (*AppSpecVersion) FullVersion 

func (v *AppSpecVersion) FullVersion() string

func (*AppSpecVersion) HexString 

func (v *AppSpecVersion) HexString() string

func (*AppSpecVersion) IndexId 

func (v *AppSpecVersion) IndexId() int64

func (*AppSpecVersion) MajorMinorVersion 

func (v *AppSpecVersion) MajorMinorVersion() string

func (*AppSpecVersion) PrefixString 

func (v *AppSpecVersion) PrefixString() string

func (*AppSpecVersion) Valid 

func (v *AppSpecVersion) Valid() bool

type AppSpecVersionEntry 

type AppSpecVersionEntry struct {
	Version string `json:"version" toml:"version"`
	Created uint64 `json:"created" toml:"created"`
	Comment string `json:"comment" toml:"comment"`
}

type AppSpecVersionList 

type AppSpecVersionList struct {
	types.TypeMeta `json:",inline" toml:",inline"`
	Items          []AppSpecVersionEntry `json:"items,omitempty" toml:"items,omitempty"`
}

type AppStatus 

type AppStatus struct {
	Phase AppPhase `json:"phase,omitempty" toml:"phase,omitempty"`
}

type AppVolumeMount 

type AppVolumeMount struct {
	Name     string `json:"name" toml:"name"`
	Path     string `json:"path" toml:"path"`
	BoxBound string `json:"box_bound,omitempty" toml:"box_bound,omitempty"`
}

type AppVolumeMounts 

type AppVolumeMounts []AppVolumeMount

type BaseCommand 

type BaseCommand = cobra.Command

type ConfigFieldSpec 

type ConfigFieldSpec struct {
	Name         string                      `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty" toml:"name,omitempty"`
	Type         ConfigFieldType             `protobuf:"varint,2,opt,name=type,proto3,enum=inapi.ConfigFieldType" json:"type,omitempty" toml:"type,omitempty"`
	Title        string                      `protobuf:"bytes,3,opt,name=title,proto3" json:"title,omitempty" toml:"title,omitempty"`
	Prompt       string                      `protobuf:"bytes,4,opt,name=prompt,proto3" json:"prompt,omitempty" toml:"prompt,omitempty"`
	DefaultValue string                      `` /* 128-byte string literal not displayed */
	AutoFill     string                      `protobuf:"bytes,6,opt,name=auto_fill,json=autoFill,proto3" json:"auto_fill,omitempty" toml:"auto_fill,omitempty"`
	Attrs        uint64                      `protobuf:"varint,7,opt,name=attrs,proto3" json:"attrs,omitempty" toml:"attrs,omitempty"`
	Enums        []*ConfigFieldSpec_KeyValue `protobuf:"bytes,13,rep,name=enums,proto3" json:"enums,omitempty" toml:"enums,omitempty"`
	Validates    []*ConfigFieldSpec_Validate `protobuf:"bytes,14,rep,name=validates,proto3" json:"validates,omitempty" toml:"validates,omitempty"`
	Description  string                      `protobuf:"bytes,15,opt,name=description,proto3" json:"description,omitempty" toml:"description,omitempty"`
	// contains filtered or unexported fields
}

func (*ConfigFieldSpec) Descriptor deprecated 

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

Deprecated: Use ConfigFieldSpec.ProtoReflect.Descriptor instead.

func (*ConfigFieldSpec) GetAttrs 

func (x *ConfigFieldSpec) GetAttrs() uint64

func (*ConfigFieldSpec) GetAutoFill 

func (x *ConfigFieldSpec) GetAutoFill() string

func (*ConfigFieldSpec) GetDefaultValue 

func (x *ConfigFieldSpec) GetDefaultValue() string

func (*ConfigFieldSpec) GetDescription 

func (x *ConfigFieldSpec) GetDescription() string

func (*ConfigFieldSpec) GetEnums 

func (x *ConfigFieldSpec) GetEnums() []*ConfigFieldSpec_KeyValue

func (*ConfigFieldSpec) GetName 

func (x *ConfigFieldSpec) GetName() string

func (*ConfigFieldSpec) GetPrompt 

func (x *ConfigFieldSpec) GetPrompt() string

func (*ConfigFieldSpec) GetTitle 

func (x *ConfigFieldSpec) GetTitle() string

func (*ConfigFieldSpec) GetType 

func (x *ConfigFieldSpec) GetType() ConfigFieldType

func (*ConfigFieldSpec) GetValidates 

func (x *ConfigFieldSpec) GetValidates() []*ConfigFieldSpec_Validate

func (*ConfigFieldSpec) ProtoMessage 

func (*ConfigFieldSpec) ProtoMessage()

func (*ConfigFieldSpec) ProtoReflect 

func (x *ConfigFieldSpec) ProtoReflect() protoreflect.Message

func (*ConfigFieldSpec) Reset 

func (x *ConfigFieldSpec) Reset()

func (*ConfigFieldSpec) String 

func (x *ConfigFieldSpec) String() string

type ConfigFieldSpec_KeyValue 

type ConfigFieldSpec_KeyValue struct {
	Key   string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty" toml:"key,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty" toml:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*ConfigFieldSpec_KeyValue) Descriptor deprecated 

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

Deprecated: Use ConfigFieldSpec_KeyValue.ProtoReflect.Descriptor instead.

func (*ConfigFieldSpec_KeyValue) GetKey 

func (x *ConfigFieldSpec_KeyValue) GetKey() string

func (*ConfigFieldSpec_KeyValue) GetValue 

func (x *ConfigFieldSpec_KeyValue) GetValue() string

func (*ConfigFieldSpec_KeyValue) ProtoMessage 

func (*ConfigFieldSpec_KeyValue) ProtoMessage()

func (*ConfigFieldSpec_KeyValue) ProtoReflect 

func (x *ConfigFieldSpec_KeyValue) ProtoReflect() protoreflect.Message

func (*ConfigFieldSpec_KeyValue) Reset 

func (x *ConfigFieldSpec_KeyValue) Reset()

func (*ConfigFieldSpec_KeyValue) String 

func (x *ConfigFieldSpec_KeyValue) String() string

type ConfigFieldSpec_Validate 

type ConfigFieldSpec_Validate struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty" toml:"name,omitempty"`
	Expr string `protobuf:"bytes,2,opt,name=expr,proto3" json:"expr,omitempty" toml:"expr,omitempty"`
	Hint string `protobuf:"bytes,3,opt,name=hint,proto3" json:"hint,omitempty" toml:"hint,omitempty"`
	// contains filtered or unexported fields
}

func (*ConfigFieldSpec_Validate) Descriptor deprecated 

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

Deprecated: Use ConfigFieldSpec_Validate.ProtoReflect.Descriptor instead.

func (*ConfigFieldSpec_Validate) GetExpr 

func (x *ConfigFieldSpec_Validate) GetExpr() string

func (*ConfigFieldSpec_Validate) GetHint 

func (x *ConfigFieldSpec_Validate) GetHint() string

func (*ConfigFieldSpec_Validate) GetName 

func (x *ConfigFieldSpec_Validate) GetName() string

func (*ConfigFieldSpec_Validate) ProtoMessage 

func (*ConfigFieldSpec_Validate) ProtoMessage()

func (*ConfigFieldSpec_Validate) ProtoReflect 

func (x *ConfigFieldSpec_Validate) ProtoReflect() protoreflect.Message

func (*ConfigFieldSpec_Validate) Reset 

func (x *ConfigFieldSpec_Validate) Reset()

func (*ConfigFieldSpec_Validate) String 

func (x *ConfigFieldSpec_Validate) String() string

type ConfigFieldType 

type ConfigFieldType int32
const (
	ConfigFieldType_UnSpec             ConfigFieldType = 0
	ConfigFieldType_String             ConfigFieldType = 1
	ConfigFieldType_Select             ConfigFieldType = 2
	ConfigFieldType_Text               ConfigFieldType = 300
	ConfigFieldType_TextJSON           ConfigFieldType = 301
	ConfigFieldType_TextTOML           ConfigFieldType = 302
	ConfigFieldType_TextYAML           ConfigFieldType = 303
	ConfigFieldType_TextINI            ConfigFieldType = 304
	ConfigFieldType_TextJavaProperties ConfigFieldType = 305
	ConfigFieldType_TextMarkdown       ConfigFieldType = 306
	ConfigFieldType_AuthCert           ConfigFieldType = 900
)

func (ConfigFieldType) Descriptor 

func (ConfigFieldType) Descriptor() protoreflect.EnumDescriptor

func (ConfigFieldType) Enum 

func (x ConfigFieldType) Enum() *ConfigFieldType

func (ConfigFieldType) EnumDescriptor deprecated 

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

Deprecated: Use ConfigFieldType.Descriptor instead.

func (ConfigFieldType) Number 

func (x ConfigFieldType) Number() protoreflect.EnumNumber

func (ConfigFieldType) String 

func (x ConfigFieldType) String() string

func (ConfigFieldType) Type 

func (ConfigFieldType) Type() protoreflect.EnumType

type ConfigFieldValue 

type ConfigFieldValue struct {
	Name  string          `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty" toml:"name,omitempty"`
	Type  ConfigFieldType `protobuf:"varint,2,opt,name=type,proto3,enum=inapi.ConfigFieldType" json:"type,omitempty" toml:"type,omitempty"`
	Value string          `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty" toml:"value,omitempty"`
	Attrs uint64          `protobuf:"varint,7,opt,name=attrs,proto3" json:"attrs,omitempty" toml:"attrs,omitempty"`
	// contains filtered or unexported fields
}

func (*ConfigFieldValue) Descriptor deprecated 

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

Deprecated: Use ConfigFieldValue.ProtoReflect.Descriptor instead.

func (*ConfigFieldValue) GetAttrs 

func (x *ConfigFieldValue) GetAttrs() uint64

func (*ConfigFieldValue) GetName 

func (x *ConfigFieldValue) GetName() string

func (*ConfigFieldValue) GetType 

func (x *ConfigFieldValue) GetType() ConfigFieldType

func (*ConfigFieldValue) GetValue 

func (x *ConfigFieldValue) GetValue() string

func (*ConfigFieldValue) ProtoMessage 

func (*ConfigFieldValue) ProtoMessage()

func (*ConfigFieldValue) ProtoReflect 

func (x *ConfigFieldValue) ProtoReflect() protoreflect.Message

func (*ConfigFieldValue) Reset 

func (x *ConfigFieldValue) Reset()

func (*ConfigFieldValue) String 

func (x *ConfigFieldValue) String() string

type ConfigInstance 

type ConfigInstance struct {
	Name    string              `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty" toml:"name,omitempty"`
	Version string              `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty" toml:"version,omitempty"`
	Fields  []*ConfigFieldValue `protobuf:"bytes,3,rep,name=fields,proto3" json:"fields,omitempty" toml:"fields,omitempty"`
	Created int64               `protobuf:"varint,4,opt,name=created,proto3" json:"created,omitempty" toml:"created,omitempty"`
	Updated int64               `protobuf:"varint,5,opt,name=updated,proto3" json:"updated,omitempty" toml:"updated,omitempty"`
	// contains filtered or unexported fields
}

func (*ConfigInstance) Descriptor deprecated 

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

Deprecated: Use ConfigInstance.ProtoReflect.Descriptor instead.

func (*ConfigInstance) FieldValue 

func (it *ConfigInstance) FieldValue(name string) string

func (*ConfigInstance) GetCreated 

func (x *ConfigInstance) GetCreated() int64

func (*ConfigInstance) GetFields 

func (x *ConfigInstance) GetFields() []*ConfigFieldValue

func (*ConfigInstance) GetName 

func (x *ConfigInstance) GetName() string

func (*ConfigInstance) GetUpdated 

func (x *ConfigInstance) GetUpdated() int64

func (*ConfigInstance) GetVersion 

func (x *ConfigInstance) GetVersion() string

func (*ConfigInstance) ProtoMessage 

func (*ConfigInstance) ProtoMessage()

func (*ConfigInstance) ProtoReflect 

func (x *ConfigInstance) ProtoReflect() protoreflect.Message

func (*ConfigInstance) Reset 

func (x *ConfigInstance) Reset()

func (*ConfigInstance) String 

func (x *ConfigInstance) String() string

type ConfigSpec 

type ConfigSpec struct {
	Name    string             `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty" toml:"name,omitempty"`
	Version string             `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty" toml:"version,omitempty"`
	Fields  []*ConfigFieldSpec `protobuf:"bytes,3,rep,name=fields,proto3" json:"fields,omitempty" toml:"fields,omitempty"`
	// contains filtered or unexported fields
}

func (*ConfigSpec) Descriptor deprecated 

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

Deprecated: Use ConfigSpec.ProtoReflect.Descriptor instead.

func (*ConfigSpec) GetFields 

func (x *ConfigSpec) GetFields() []*ConfigFieldSpec

func (*ConfigSpec) GetName 

func (x *ConfigSpec) GetName() string

func (*ConfigSpec) GetVersion 

func (x *ConfigSpec) GetVersion() string

func (*ConfigSpec) ProtoMessage 

func (*ConfigSpec) ProtoMessage()

func (*ConfigSpec) ProtoReflect 

func (x *ConfigSpec) ProtoReflect() protoreflect.Message

func (*ConfigSpec) Reset 

func (x *ConfigSpec) Reset()

func (*ConfigSpec) String 

func (x *ConfigSpec) String() string

type EnvVar 

type EnvVar struct {
	Name  string `json:"name" toml:"name"`
	Value string `json:"value,omitempty" toml:"value,omitempty"`
}

EnvVar represents an environment variable present in a Box.

type ErrorMeta 

type ErrorMeta struct {
	Code    string `protobuf:"bytes,1,opt,name=code,proto3" json:"code,omitempty" toml:"code,omitempty"`
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty" toml:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*ErrorMeta) Descriptor deprecated 

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

Deprecated: Use ErrorMeta.ProtoReflect.Descriptor instead.

func (*ErrorMeta) GetCode 

func (x *ErrorMeta) GetCode() string

func (*ErrorMeta) GetMessage 

func (x *ErrorMeta) GetMessage() string

func (*ErrorMeta) ProtoMessage 

func (*ErrorMeta) ProtoMessage()

func (*ErrorMeta) ProtoReflect 

func (x *ErrorMeta) ProtoReflect() protoreflect.Message

func (*ErrorMeta) Reset 

func (x *ErrorMeta) Reset()

func (*ErrorMeta) String 

func (x *ErrorMeta) String() string

type ExecPlanOnFailed 

type ExecPlanOnFailed struct {
	RetrySec ExecPlanTimer `json:"retry_sec,omitempty" toml:"retry_sec,omitempty"`
	RetryMax int           `json:"retry_max,omitempty" toml:"retry_max,omitempty"`
}

ExecPlanOnFailed describes how the executor should be re-executed.

type ExecPlanTimer 

type ExecPlanTimer string

func (ExecPlanTimer) Seconds 

func (pt ExecPlanTimer) Seconds() int64

type ExecPlanner 

type ExecPlanner struct {
	OnBoot     bool              `json:"on_boot,omitempty" toml:"on_boot,omitempty"`
	OnTick     uint32            `json:"on_tick,omitempty" toml:"on_tick,omitempty"`
	OnCalendar *ExecPlanTimer    `json:"on_calendar,omitempty" toml:"on_calendar,omitempty"`
	OnFailed   *ExecPlanOnFailed `json:"on_failed,omitempty" toml:"on_failed,omitempty"`
}

type Executor 

type Executor struct {
	Name      types.NameIdentifier `json:"name" toml:"name"`
	Updated   types.MetaTime       `json:"updated,omitempty" toml:"updated,omitempty"`
	Vendor    string               `json:"vendor,omitempty" toml:"vendor,omitempty"`
	Dir       string               `json:"dir,omitempty" toml:"dir,omitempty"`     // /home/action/apps/demo
	User      string               `json:"user,omitempty" toml:"user,omitempty"`   // default: action
	Group     string               `json:"group,omitempty" toml:"group,omitempty"` // default: action
	ExecStart string               `json:"exec_start,omitempty" toml:"exec_start,omitempty"`
	ExecStop  string               `json:"exec_stop,omitempty" toml:"exec_stop,omitempty"`
	Priority  uint8                `json:"priority,omitempty" toml:"priority,omitempty"`
	Plan      ExecPlanner          `json:"plan,omitempty" toml:"plan,omitempty"`
	Options   types.Labels         `json:"options,omitempty" toml:"options,omitempty"`
	Status    *ExecutorStatus      `json:"status,omitempty" toml:"status,omitempty"`
}

func (*Executor) IterKey 

func (it *Executor) IterKey() string

type ExecutorAction 

type ExecutorAction uint64
const (
	ExecutorActionStart   ExecutorAction = 1 << 1
	ExecutorActionStarted ExecutorAction = 1 << 2
	ExecutorActionStop    ExecutorAction = 1 << 3
	ExecutorActionStopped ExecutorAction = 1 << 4
	ExecutorActionRestart ExecutorAction = 1 << 5
	ExecutorActionPending ExecutorAction = 1 << 10
	ExecutorActionFailed  ExecutorAction = 1 << 11
)

func (ExecutorAction) Allow 

func (a ExecutorAction) Allow(as ExecutorAction) bool

func (*ExecutorAction) Append 

func (a *ExecutorAction) Append(as ExecutorAction)

func (*ExecutorAction) Remove 

func (a *ExecutorAction) Remove(as ExecutorAction)

func (ExecutorAction) String 

func (a ExecutorAction) String() string

type ExecutorList 

type ExecutorList struct {
	types.TypeMeta `json:",inline" toml:",inline"`
	Items          Executors `json:"items,omitempty" toml:"items,omitempty"`
}

type ExecutorSetup 

type ExecutorSetup struct {
	types.TypeMeta `json:",inline" toml:",inline"`
	Spec           types.NameIdentifier `json:"spec,omitempty" toml:"spec,omitempty"`
	PodId          string               `json:"pod_id,omitempty" toml:"pod_id,omitempty"`
	AppId          string               `json:"app_id,omitempty" toml:"app_id,omitempty"`
	Executor       Executor             `json:"executor,omitempty" toml:"executor,omitempty"`
}

type ExecutorStatus 

type ExecutorStatus struct {
	Name    types.NameIdentifier  `json:"name" toml:"name"`
	Created types.MetaTime        `json:"created,omitempty" toml:"created,omitempty"`
	Updated types.MetaTime        `json:"updated,omitempty" toml:"updated,omitempty"`
	Vendor  string                `json:"vendor,omitempty" toml:"vendor,omitempty"`
	Action  ExecutorAction        `json:"action,omitempty" toml:"action,omitempty"`
	Plan    ExecutorStatusPlanner `json:"plan,omitempty" toml:"plan,omitempty"`
	Cmd     *exec.Cmd             `json:"-" toml:"-"`
}

type ExecutorStatusPlanner 

type ExecutorStatusPlanner struct {
	Updated          types.MetaTime `json:"updated,omitempty" toml:"updated,omitempty"`
	OnFailedRetryNum int            `json:"on_failed_retry_num,omitempty" toml:"on_failed_retry_num,omitempty"`
}

type ExecutorStatuses 

type ExecutorStatuses []*ExecutorStatus

func (*ExecutorStatuses) Get 

func (es *ExecutorStatuses) Get(name types.NameIdentifier) *ExecutorStatus

func (*ExecutorStatuses) Sync 

func (es *ExecutorStatuses) Sync(item *ExecutorStatus)

type Executors 

type Executors []Executor

func (*Executors) Remove 

func (ls *Executors) Remove(name types.NameIdentifier)

func (*Executors) Sync 

func (ls *Executors) Sync(item2 Executor)

type FsFile 

type FsFile struct {
	types.TypeMeta `json:",inline" toml:",inline"`
	Path           string `json:"path,omitempty" toml:"path,omitempty"`
	PathSet        string `json:"pathset,omitempty" toml:"pathset,omitempty"`
	Name           string `json:"name,omitempty" toml:"name,omitempty"`
	Size           int64  `json:"size,omitempty" toml:"size,omitempty"`
	Mime           string `json:"mime,omitempty" toml:"mime,omitempty"`
	Body           string `json:"body,omitempty" toml:"body,omitempty"`
	SumCheck       string `json:"sumcheck,omitempty" toml:"sumcheck,omitempty"`
	IsDir          bool   `json:"isdir,omitempty" toml:"isdir,omitempty"`
	ModTime        string `json:"modtime,omitempty" toml:"modtime,omitempty"`
	Encode         string `json:"encode,omitempty" toml:"encode,omitempty"`
}

type FsFileList 

type FsFileList struct {
	types.TypeMeta `json:",inline" toml:",inline"`
	Path           string   `json:"path,omitempty" toml:"path,omitempty"`
	Items          []FsFile `json:"items,omitempty" toml:"items,omitempty"`
}

type GeneralObject 

type GeneralObject struct {
	Kind  string           `json:"kind,omitempty" toml:"kind,omitempty"`
	Error *types.ErrorMeta `json:"error,omitempty" toml:"error,omitempty"`
}

type GeneralObjectList 

type GeneralObjectList struct {
	Kind  string           `json:"kind,omitempty" toml:"kind,omitempty"`
	Error *types.ErrorMeta `json:"error,omitempty" toml:"error,omitempty"`
	Items []interface{}    `json:"items,omitempty" toml:"items,omitempty"`
}

type HealthStatus 

type HealthStatus struct {
	PartId  uint32 `protobuf:"varint,1,opt,name=part_id,json=partId,proto3" json:"part_id,omitempty" toml:"part_id,omitempty"` // struct:object_slice_key
	Action  uint32 `protobuf:"varint,2,opt,name=action,proto3" json:"action,omitempty" toml:"action,omitempty"`
	Updated uint32 `protobuf:"varint,5,opt,name=updated,proto3" json:"updated,omitempty" toml:"updated,omitempty"`
	Message uint32 `protobuf:"varint,6,opt,name=message,proto3" json:"message,omitempty" toml:"message,omitempty"`
	// contains filtered or unexported fields
}

func HealthStatusSliceDel 

func HealthStatusSliceDel(ls []*HealthStatus, arg_partid uint32) ([]*HealthStatus, bool)

func HealthStatusSliceGet 

func HealthStatusSliceGet(ls []*HealthStatus, arg_partid uint32) *HealthStatus

func HealthStatusSliceSync 

func HealthStatusSliceSync(ls []*HealthStatus, it2 *HealthStatus) ([]*HealthStatus, bool)

func HealthStatusSliceSyncSlice 

func HealthStatusSliceSyncSlice(ls, ls2 []*HealthStatus) ([]*HealthStatus, bool)

func (*HealthStatus) Descriptor deprecated 

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

Deprecated: Use HealthStatus.ProtoReflect.Descriptor instead.

func (*HealthStatus) Equal 

func (it *HealthStatus) Equal(it2 *HealthStatus) bool

func (*HealthStatus) GetAction 

func (x *HealthStatus) GetAction() uint32

func (*HealthStatus) GetMessage 

func (x *HealthStatus) GetMessage() uint32

func (*HealthStatus) GetPartId 

func (x *HealthStatus) GetPartId() uint32

func (*HealthStatus) GetUpdated 

func (x *HealthStatus) GetUpdated() uint32

func (*HealthStatus) ProtoMessage 

func (*HealthStatus) ProtoMessage()

func (*HealthStatus) ProtoReflect 

func (x *HealthStatus) ProtoReflect() protoreflect.Message

func (*HealthStatus) Reset 

func (x *HealthStatus) Reset()

func (*HealthStatus) String 

func (x *HealthStatus) String() string

func (*HealthStatus) Sync 

func (it *HealthStatus) Sync(it2 *HealthStatus) bool

type HostNodeAddress 

type HostNodeAddress string

default: 127.0.0.1:9529

func (HostNodeAddress) IP 

func (addr HostNodeAddress) IP() string

func (HostNodeAddress) Port 

func (addr HostNodeAddress) Port() uint16

func (*HostNodeAddress) SetIP 

func (addr *HostNodeAddress) SetIP(ip string) error

func (*HostNodeAddress) SetPort 

func (addr *HostNodeAddress) SetPort(port uint16) error

func (HostNodeAddress) String 

func (addr HostNodeAddress) String() string

func (HostNodeAddress) Valid 

func (addr HostNodeAddress) Valid() bool

type HostNodeAddresses 

type HostNodeAddresses []HostNodeAddress

func (HostNodeAddresses) Equal 

func (it HostNodeAddresses) Equal(it2 HostNodeAddresses) bool

type Label 

type Label struct {
	Name  string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty" toml:"name,omitempty"` // struct:object_slice_key
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty" toml:"value,omitempty"`
	// contains filtered or unexported fields
}

func LabelSliceDel 

func LabelSliceDel(ls []*Label, arg_name string) ([]*Label, bool)

func LabelSliceGet 

func LabelSliceGet(ls []*Label, arg_name string) *Label

func LabelSliceSync 

func LabelSliceSync(ls []*Label, it2 *Label) ([]*Label, bool)

func LabelSliceSyncSlice 

func LabelSliceSyncSlice(ls, ls2 []*Label) ([]*Label, bool)

func (*Label) Descriptor deprecated 

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

Deprecated: Use Label.ProtoReflect.Descriptor instead.

func (*Label) Equal 

func (it *Label) Equal(it2 *Label) bool

func (*Label) GetName 

func (x *Label) GetName() string

func (*Label) GetValue 

func (x *Label) GetValue() string

func (*Label) ProtoMessage 

func (*Label) ProtoMessage()

func (*Label) ProtoReflect 

func (x *Label) ProtoReflect() protoreflect.Message

func (*Label) Reset 

func (x *Label) Reset()

func (*Label) String 

func (x *Label) String() string

func (*Label) Sync 

func (it *Label) Sync(it2 *Label) bool

type MailPodStatus 

type MailPodStatus struct {
	Id      string               `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty" toml:"id,omitempty"`
	User    string               `protobuf:"bytes,2,opt,name=user,proto3" json:"user,omitempty" toml:"user,omitempty"`
	Items   []*MailPodStatus_Pod `protobuf:"bytes,3,rep,name=items,proto3" json:"items,omitempty" toml:"items,omitempty"`
	Created uint32               `protobuf:"varint,5,opt,name=created,proto3" json:"created,omitempty" toml:"created,omitempty"`
	WeekNum uint32               `protobuf:"varint,6,opt,name=week_num,json=weekNum,proto3" json:"week_num,omitempty" toml:"week_num,omitempty"`
	// contains filtered or unexported fields
}

func (*MailPodStatus) Descriptor deprecated 

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

Deprecated: Use MailPodStatus.ProtoReflect.Descriptor instead.

func (*MailPodStatus) GetCreated 

func (x *MailPodStatus) GetCreated() uint32

func (*MailPodStatus) GetId 

func (x *MailPodStatus) GetId() string

func (*MailPodStatus) GetItems 

func (x *MailPodStatus) GetItems() []*MailPodStatus_Pod

func (*MailPodStatus) GetUser 

func (x *MailPodStatus) GetUser() string

func (*MailPodStatus) GetWeekNum 

func (x *MailPodStatus) GetWeekNum() uint32

func (*MailPodStatus) ProtoMessage 

func (*MailPodStatus) ProtoMessage()

func (*MailPodStatus) ProtoReflect 

func (x *MailPodStatus) ProtoReflect() protoreflect.Message

func (*MailPodStatus) Reset 

func (x *MailPodStatus) Reset()

func (*MailPodStatus) String 

func (x *MailPodStatus) String() string

type MailPodStatus_Pod 

type MailPodStatus_Pod struct {
	PodId              string                      `protobuf:"bytes,1,opt,name=pod_id,json=podId,proto3" json:"pod_id,omitempty" toml:"pod_id,omitempty"`
	PodName            string                      `protobuf:"bytes,9,opt,name=pod_name,json=podName,proto3" json:"pod_name,omitempty" toml:"pod_name,omitempty"`
	ZoneName           string                      `protobuf:"bytes,2,opt,name=zone_name,json=zoneName,proto3" json:"zone_name,omitempty" toml:"zone_name,omitempty"`
	CellName           string                      `protobuf:"bytes,3,opt,name=cell_name,json=cellName,proto3" json:"cell_name,omitempty" toml:"cell_name,omitempty"`
	SpecCpu            int32                       `protobuf:"varint,5,opt,name=spec_cpu,json=specCpu,proto3" json:"spec_cpu,omitempty" toml:"spec_cpu,omitempty"`
	SpecMem            int32                       `protobuf:"varint,6,opt,name=spec_mem,json=specMem,proto3" json:"spec_mem,omitempty" toml:"spec_mem,omitempty"`
	SpecVol            int32                       `protobuf:"varint,7,opt,name=spec_vol,json=specVol,proto3" json:"spec_vol,omitempty" toml:"spec_vol,omitempty"`
	PaymentCycleAmount float32                     `` /* 157-byte string literal not displayed */
	Reps               []*MailPodStatus_PodReplica `protobuf:"bytes,15,rep,name=reps,proto3" json:"reps,omitempty" toml:"reps,omitempty"`
	// contains filtered or unexported fields
}

func (*MailPodStatus_Pod) Descriptor deprecated 

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

Deprecated: Use MailPodStatus_Pod.ProtoReflect.Descriptor instead.

func (*MailPodStatus_Pod) GetCellName 

func (x *MailPodStatus_Pod) GetCellName() string

func (*MailPodStatus_Pod) GetPaymentCycleAmount 

func (x *MailPodStatus_Pod) GetPaymentCycleAmount() float32

func (*MailPodStatus_Pod) GetPodId 

func (x *MailPodStatus_Pod) GetPodId() string

func (*MailPodStatus_Pod) GetPodName 

func (x *MailPodStatus_Pod) GetPodName() string

func (*MailPodStatus_Pod) GetReps 

func (x *MailPodStatus_Pod) GetReps() []*MailPodStatus_PodReplica

func (*MailPodStatus_Pod) GetSpecCpu 

func (x *MailPodStatus_Pod) GetSpecCpu() int32

func (*MailPodStatus_Pod) GetSpecMem 

func (x *MailPodStatus_Pod) GetSpecMem() int32

func (*MailPodStatus_Pod) GetSpecVol 

func (x *MailPodStatus_Pod) GetSpecVol() int32

func (*MailPodStatus_Pod) GetZoneName 

func (x *MailPodStatus_Pod) GetZoneName() string

func (*MailPodStatus_Pod) ProtoMessage 

func (*MailPodStatus_Pod) ProtoMessage()

func (*MailPodStatus_Pod) ProtoReflect 

func (x *MailPodStatus_Pod) ProtoReflect() protoreflect.Message

func (*MailPodStatus_Pod) Reset 

func (x *MailPodStatus_Pod) Reset()

func (*MailPodStatus_Pod) String 

func (x *MailPodStatus_Pod) String() string

type MailPodStatus_PodReplica 

type MailPodStatus_PodReplica struct {
	Id      uint32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty" toml:"id,omitempty"`
	VolUsed int64  `protobuf:"varint,2,opt,name=vol_used,json=volUsed,proto3" json:"vol_used,omitempty" toml:"vol_used,omitempty"`
	// contains filtered or unexported fields
}

func (*MailPodStatus_PodReplica) Descriptor deprecated 

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

Deprecated: Use MailPodStatus_PodReplica.ProtoReflect.Descriptor instead.

func (*MailPodStatus_PodReplica) GetId 

func (x *MailPodStatus_PodReplica) GetId() uint32

func (*MailPodStatus_PodReplica) GetVolUsed 

func (x *MailPodStatus_PodReplica) GetVolUsed() int64

func (*MailPodStatus_PodReplica) ProtoMessage 

func (*MailPodStatus_PodReplica) ProtoMessage()

func (*MailPodStatus_PodReplica) ProtoReflect 

func (x *MailPodStatus_PodReplica) ProtoReflect() protoreflect.Message

func (*MailPodStatus_PodReplica) Reset 

func (x *MailPodStatus_PodReplica) Reset()

func (*MailPodStatus_PodReplica) String 

func (x *MailPodStatus_PodReplica) String() string

type ObjectMeta 

type ObjectMeta struct {
	Id      string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty" toml:"id,omitempty"`
	Name    string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty" toml:"name,omitempty"`
	Created uint64 `protobuf:"varint,3,opt,name=created,proto3" json:"created,omitempty" toml:"created,omitempty"`
	Updated uint64 `protobuf:"varint,4,opt,name=updated,proto3" json:"updated,omitempty" toml:"updated,omitempty"`
	// contains filtered or unexported fields
}

func (*ObjectMeta) Descriptor deprecated 

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

Deprecated: Use ObjectMeta.ProtoReflect.Descriptor instead.

func (*ObjectMeta) GetCreated 

func (x *ObjectMeta) GetCreated() uint64

func (*ObjectMeta) GetId 

func (x *ObjectMeta) GetId() string

func (*ObjectMeta) GetName 

func (x *ObjectMeta) GetName() string

func (*ObjectMeta) GetUpdated 

func (x *ObjectMeta) GetUpdated() uint64

func (*ObjectMeta) ProtoMessage 

func (*ObjectMeta) ProtoMessage()

func (*ObjectMeta) ProtoReflect 

func (x *ObjectMeta) ProtoReflect() protoreflect.Message

func (*ObjectMeta) Reset 

func (x *ObjectMeta) Reset()

func (*ObjectMeta) String 

func (x *ObjectMeta) String() string

func (*ObjectMeta) UnmarshalJSON 

func (it *ObjectMeta) UnmarshalJSON(b []byte) error

type ObjectReference 

type ObjectReference struct {
	Id      string `json:"id,omitempty" toml:"id,omitempty"`
	Name    string `json:"name,omitempty" toml:"name,omitempty"`
	Version string `json:"version,omitempty" toml:"version,omitempty"`
	Title   string `json:"title,omitempty" toml:"title,omitempty"`
}

ObjectReference contains enough information to let you inspect or modify the referred object

type OpLogList 

type OpLogList []*PbOpLogSets

func (*OpLogList) Get 

func (ls *OpLogList) Get(sets_name string) *PbOpLogSets

func (*OpLogList) LogSet 

func (ls *OpLogList) LogSet(sets_name string, version uint32, name, status, msg string)

type OpPerm 

type OpPerm uint8
const (
	OpPermRead   OpPerm = 1 << 0
	OpPermWrite  OpPerm = 1 << 1
	OpPermCreate OpPerm = 1 << 2
	OpPermDelete OpPerm = 1 << 3
	OpPermList   OpPerm = 1 << 4
	OpPermPut    OpPerm = OpPermWrite | OpPermCreate
	OpPermMirror OpPerm = OpPermRead | OpPermList
	OpPermAll    OpPerm = OpPermRead | OpPermWrite | OpPermCreate | OpPermDelete | OpPermList
)

func (OpPerm) Allow 

func (p OpPerm) Allow(perms OpPerm) bool

type PbOpLogEntry 

type PbOpLogEntry struct {
	Name    string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty" toml:"name,omitempty"` // struct:object_slice_key
	Status  string `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty" toml:"status,omitempty"`
	Updated uint64 `protobuf:"varint,3,opt,name=updated,proto3" json:"updated,omitempty" toml:"updated,omitempty"` // unix time in milliseconds
	Message string `protobuf:"bytes,4,opt,name=message,proto3" json:"message,omitempty" toml:"message,omitempty"`
	// contains filtered or unexported fields
}

func NewPbOpLogEntry 

func NewPbOpLogEntry(name, status, message string) *PbOpLogEntry

func PbOpLogEntrySliceDel 

func PbOpLogEntrySliceDel(ls []*PbOpLogEntry, arg_name string) ([]*PbOpLogEntry, bool)

func PbOpLogEntrySliceGet 

func PbOpLogEntrySliceGet(ls []*PbOpLogEntry, arg_name string) *PbOpLogEntry

func PbOpLogEntrySliceSync 

func PbOpLogEntrySliceSync(ls []*PbOpLogEntry, it2 *PbOpLogEntry) ([]*PbOpLogEntry, bool)

func PbOpLogEntrySliceSyncSlice 

func PbOpLogEntrySliceSyncSlice(ls, ls2 []*PbOpLogEntry) ([]*PbOpLogEntry, bool)

func (*PbOpLogEntry) Descriptor deprecated 

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

Deprecated: Use PbOpLogEntry.ProtoReflect.Descriptor instead.

func (*PbOpLogEntry) Equal 

func (it *PbOpLogEntry) Equal(it2 *PbOpLogEntry) bool

func (*PbOpLogEntry) GetMessage 

func (x *PbOpLogEntry) GetMessage() string

func (*PbOpLogEntry) GetName 

func (x *PbOpLogEntry) GetName() string

func (*PbOpLogEntry) GetStatus 

func (x *PbOpLogEntry) GetStatus() string

func (*PbOpLogEntry) GetUpdated 

func (x *PbOpLogEntry) GetUpdated() uint64

func (*PbOpLogEntry) ProtoMessage 

func (*PbOpLogEntry) ProtoMessage()

func (*PbOpLogEntry) ProtoReflect 

func (x *PbOpLogEntry) ProtoReflect() protoreflect.Message

func (*PbOpLogEntry) Reset 

func (x *PbOpLogEntry) Reset()

func (*PbOpLogEntry) String 

func (x *PbOpLogEntry) String() string

func (*PbOpLogEntry) Sync 

func (it *PbOpLogEntry) Sync(it2 *PbOpLogEntry) bool

type PbOpLogSets 

type PbOpLogSets struct {
	Name    string          `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty" toml:"name,omitempty"` // struct:object_slice_key
	Version uint32          `protobuf:"varint,3,opt,name=version,proto3" json:"version,omitempty" toml:"version,omitempty"`
	Items   []*PbOpLogEntry `protobuf:"bytes,4,rep,name=items,proto3" json:"items,omitempty" toml:"items,omitempty"`
	// contains filtered or unexported fields
}

func NewPbOpLogSets 

func NewPbOpLogSets(sets_name string, version uint32) *PbOpLogSets

func PbOpLogSetsSliceDel 

func PbOpLogSetsSliceDel(ls []*PbOpLogSets, arg_name string) ([]*PbOpLogSets, bool)

func PbOpLogSetsSliceGet 

func PbOpLogSetsSliceGet(ls []*PbOpLogSets, arg_name string) *PbOpLogSets

func PbOpLogSetsSliceSync 

func PbOpLogSetsSliceSync(ls []*PbOpLogSets, it2 *PbOpLogSets) ([]*PbOpLogSets, bool)

func PbOpLogSetsSliceSyncSlice 

func PbOpLogSetsSliceSyncSlice(ls, ls2 []*PbOpLogSets) ([]*PbOpLogSets, bool)

func (*PbOpLogSets) Descriptor deprecated 

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

Deprecated: Use PbOpLogSets.ProtoReflect.Descriptor instead.

func (*PbOpLogSets) Equal 

func (it *PbOpLogSets) Equal(it2 *PbOpLogSets) bool

func (*PbOpLogSets) GetItems 

func (x *PbOpLogSets) GetItems() []*PbOpLogEntry

func (*PbOpLogSets) GetName 

func (x *PbOpLogSets) GetName() string

func (*PbOpLogSets) GetVersion 

func (x *PbOpLogSets) GetVersion() uint32

func (*PbOpLogSets) LogSet 

func (rs *PbOpLogSets) LogSet(version uint32, name, status, message string)

func (*PbOpLogSets) LogSetEntry 

func (rs *PbOpLogSets) LogSetEntry(entry *PbOpLogEntry)

func (*PbOpLogSets) ProtoMessage 

func (*PbOpLogSets) ProtoMessage()

func (*PbOpLogSets) ProtoReflect 

func (x *PbOpLogSets) ProtoReflect() protoreflect.Message

func (*PbOpLogSets) Reset 

func (x *PbOpLogSets) Reset()

func (*PbOpLogSets) String 

func (x *PbOpLogSets) String() string

func (*PbOpLogSets) Sync 

func (it *PbOpLogSets) Sync(it2 *PbOpLogSets) bool

type PbPodBoxStatus 

type PbPodBoxStatus struct {
	Name         string                  `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty" toml:"name,omitempty"` // struct:object_slice_key
	ImageDriver  PbPodSpecBoxImageDriver ``                                                                                    /* 160-byte string literal not displayed */
	ImageOptions []*Label                ``                                                                                    /* 128-byte string literal not displayed */
	ResCpuLimit  int32                   ``                                                                                    // in 1 = .1 cores
	/* 128-byte string literal not displayed */
	ResMemLimit int32 `` // in MiB
	/* 128-byte string literal not displayed */
	Mounts            []*PbVolumeMount             `protobuf:"bytes,6,rep,name=mounts,proto3" json:"mounts,omitempty" toml:"mounts,omitempty"`
	Ports             []*PbServicePort             `protobuf:"bytes,7,rep,name=ports,proto3" json:"ports,omitempty" toml:"ports,omitempty"`
	Command           []string                     `protobuf:"bytes,8,rep,name=command,proto3" json:"command,omitempty" toml:"command,omitempty"`
	Executors         []*PbPodBoxStatusExecutor    `protobuf:"bytes,9,rep,name=executors,proto3" json:"executors,omitempty" toml:"executors,omitempty"`
	Action            uint32                       `protobuf:"varint,10,opt,name=action,proto3" json:"action,omitempty" toml:"action,omitempty"`
	Started           uint32                       `protobuf:"varint,11,opt,name=started,proto3" json:"started,omitempty" toml:"started,omitempty"` // unix time in seconds
	Updated           uint32                       `protobuf:"varint,12,opt,name=updated,proto3" json:"updated,omitempty" toml:"updated,omitempty"` // unix time in seconds
	CpuSets           []int32                      `protobuf:"varint,13,rep,packed,name=cpu_sets,json=cpuSets,proto3" json:"cpu_sets,omitempty" toml:"cpu_sets,omitempty"`
	NetworkMode       int32                        `` /* 126-byte string literal not displayed */
	NetworkIpv4       string                       `protobuf:"bytes,15,opt,name=network_ipv4,json=networkIpv4,proto3" json:"network_ipv4,omitempty" toml:"network_ipv4,omitempty"`
	BlkioDeviceLimits map[string]*PodBoxBlockLimit `` /* 240-byte string literal not displayed */
	// contains filtered or unexported fields
}

PodBoxStatus represents the current information about a box

func PbPodBoxStatusSliceDel 

func PbPodBoxStatusSliceDel(ls []*PbPodBoxStatus, arg_name string) ([]*PbPodBoxStatus, bool)

func PbPodBoxStatusSliceGet 

func PbPodBoxStatusSliceGet(ls []*PbPodBoxStatus, arg_name string) *PbPodBoxStatus

func PbPodBoxStatusSliceSync 

func PbPodBoxStatusSliceSync(ls []*PbPodBoxStatus, it2 *PbPodBoxStatus) ([]*PbPodBoxStatus, bool)

func PbPodBoxStatusSliceSyncSlice 

func PbPodBoxStatusSliceSyncSlice(ls, ls2 []*PbPodBoxStatus) ([]*PbPodBoxStatus, bool)

func (*PbPodBoxStatus) Descriptor deprecated 

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

Deprecated: Use PbPodBoxStatus.ProtoReflect.Descriptor instead.

func (*PbPodBoxStatus) Equal 

func (it *PbPodBoxStatus) Equal(it2 *PbPodBoxStatus) bool

func (*PbPodBoxStatus) GetAction 

func (x *PbPodBoxStatus) GetAction() uint32

func (*PbPodBoxStatus) GetBlkioDeviceLimits 

func (x *PbPodBoxStatus) GetBlkioDeviceLimits() map[string]*PodBoxBlockLimit

func (*PbPodBoxStatus) GetCommand 

func (x *PbPodBoxStatus) GetCommand() []string

func (*PbPodBoxStatus) GetCpuSets 

func (x *PbPodBoxStatus) GetCpuSets() []int32

func (*PbPodBoxStatus) GetExecutors 

func (x *PbPodBoxStatus) GetExecutors() []*PbPodBoxStatusExecutor

func (*PbPodBoxStatus) GetImageDriver 

func (x *PbPodBoxStatus) GetImageDriver() PbPodSpecBoxImageDriver

func (*PbPodBoxStatus) GetImageOptions 

func (x *PbPodBoxStatus) GetImageOptions() []*Label

func (*PbPodBoxStatus) GetMounts 

func (x *PbPodBoxStatus) GetMounts() []*PbVolumeMount

func (*PbPodBoxStatus) GetName 

func (x *PbPodBoxStatus) GetName() string

func (*PbPodBoxStatus) GetNetworkIpv4 

func (x *PbPodBoxStatus) GetNetworkIpv4() string

func (*PbPodBoxStatus) GetNetworkMode 

func (x *PbPodBoxStatus) GetNetworkMode() int32

func (*PbPodBoxStatus) GetPorts 

func (x *PbPodBoxStatus) GetPorts() []*PbServicePort

func (*PbPodBoxStatus) GetResCpuLimit 

func (x *PbPodBoxStatus) GetResCpuLimit() int32

func (*PbPodBoxStatus) GetResMemLimit 

func (x *PbPodBoxStatus) GetResMemLimit() int32

func (*PbPodBoxStatus) GetStarted 

func (x *PbPodBoxStatus) GetStarted() uint32

func (*PbPodBoxStatus) GetUpdated 

func (x *PbPodBoxStatus) GetUpdated() uint32

func (*PbPodBoxStatus) ProtoMessage 

func (*PbPodBoxStatus) ProtoMessage()

func (*PbPodBoxStatus) ProtoReflect 

func (x *PbPodBoxStatus) ProtoReflect() protoreflect.Message

func (*PbPodBoxStatus) Reset 

func (x *PbPodBoxStatus) Reset()

func (*PbPodBoxStatus) String 

func (x *PbPodBoxStatus) String() string

func (*PbPodBoxStatus) Sync 

func (it *PbPodBoxStatus) Sync(it2 *PbPodBoxStatus) bool

type PbPodBoxStatusExecutor 

type PbPodBoxStatusExecutor struct {
	Name         string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty" toml:"name,omitempty"` // struct:object_slice_key
	Phase        string `protobuf:"bytes,2,opt,name=phase,proto3" json:"phase,omitempty" toml:"phase,omitempty"`
	Retry        uint32 `protobuf:"varint,3,opt,name=retry,proto3" json:"retry,omitempty" toml:"retry,omitempty"`
	ErrorCode    uint32 `protobuf:"varint,4,opt,name=error_code,json=errorCode,proto3" json:"error_code,omitempty" toml:"error_code,omitempty"`
	ErrorMessage string `` /* 128-byte string literal not displayed */
	// contains filtered or unexported fields
}

func PbPodBoxStatusExecutorSliceDel 

func PbPodBoxStatusExecutorSliceDel(ls []*PbPodBoxStatusExecutor, arg_name string) ([]*PbPodBoxStatusExecutor, bool)

func PbPodBoxStatusExecutorSliceGet 

func PbPodBoxStatusExecutorSliceGet(ls []*PbPodBoxStatusExecutor, arg_name string) *PbPodBoxStatusExecutor

func PbPodBoxStatusExecutorSliceSync 

func PbPodBoxStatusExecutorSliceSync(ls []*PbPodBoxStatusExecutor, it2 *PbPodBoxStatusExecutor) ([]*PbPodBoxStatusExecutor, bool)

func PbPodBoxStatusExecutorSliceSyncSlice 

func PbPodBoxStatusExecutorSliceSyncSlice(ls, ls2 []*PbPodBoxStatusExecutor) ([]*PbPodBoxStatusExecutor, bool)

func (*PbPodBoxStatusExecutor) Descriptor deprecated 

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

Deprecated: Use PbPodBoxStatusExecutor.ProtoReflect.Descriptor instead.

func (*PbPodBoxStatusExecutor) Equal 

func (it *PbPodBoxStatusExecutor) Equal(it2 *PbPodBoxStatusExecutor) bool

func (*PbPodBoxStatusExecutor) GetErrorCode 

func (x *PbPodBoxStatusExecutor) GetErrorCode() uint32

func (*PbPodBoxStatusExecutor) GetErrorMessage 

func (x *PbPodBoxStatusExecutor) GetErrorMessage() string

func (*PbPodBoxStatusExecutor) GetName 

func (x *PbPodBoxStatusExecutor) GetName() string

func (*PbPodBoxStatusExecutor) GetPhase 

func (x *PbPodBoxStatusExecutor) GetPhase() string

func (*PbPodBoxStatusExecutor) GetRetry 

func (x *PbPodBoxStatusExecutor) GetRetry() uint32

func (*PbPodBoxStatusExecutor) ProtoMessage 

func (*PbPodBoxStatusExecutor) ProtoMessage()

func (*PbPodBoxStatusExecutor) ProtoReflect 

func (x *PbPodBoxStatusExecutor) ProtoReflect() protoreflect.Message

func (*PbPodBoxStatusExecutor) Reset 

func (x *PbPodBoxStatusExecutor) Reset()

func (*PbPodBoxStatusExecutor) String 

func (x *PbPodBoxStatusExecutor) String() string

func (*PbPodBoxStatusExecutor) Sync 

func (it *PbPodBoxStatusExecutor) Sync(it2 *PbPodBoxStatusExecutor) bool

type PbPodRepStatus 

type PbPodRepStatus struct {
	PodId  string `protobuf:"bytes,1,opt,name=pod_id,json=podId,proto3" json:"pod_id,omitempty" toml:"pod_id,omitempty"`  // struct:object_slice_key
	RepId  uint32 `protobuf:"varint,2,opt,name=rep_id,json=repId,proto3" json:"rep_id,omitempty" toml:"rep_id,omitempty"` // struct:object_slice_key
	Action uint32 `protobuf:"varint,3,opt,name=action,proto3" json:"action,omitempty" toml:"action,omitempty"`
	Node   string `protobuf:"bytes,4,opt,name=node,proto3" json:"node,omitempty" toml:"node,omitempty"`
	// PbPodBoxStatus          box     = 10;
	OpLog   *PbOpLogSets       `protobuf:"bytes,6,opt,name=op_log,json=opLog,proto3" json:"op_log,omitempty" toml:"op_log,omitempty"`
	Stats   *PbStatsSampleFeed `protobuf:"bytes,7,opt,name=stats,proto3" json:"stats,omitempty" toml:"stats,omitempty"`
	Updated uint32             `protobuf:"varint,8,opt,name=updated,proto3" json:"updated,omitempty" toml:"updated,omitempty"` // unix time in seconds
	Volumes []*PbVolumeStatus  `protobuf:"bytes,9,rep,name=volumes,proto3" json:"volumes,omitempty" toml:"volumes,omitempty"`
	Started uint32             `protobuf:"varint,11,opt,name=started,proto3" json:"started,omitempty" toml:"started,omitempty"` // unix time in seconds
	Ports   []*PbServicePort   `protobuf:"bytes,12,rep,name=ports,proto3" json:"ports,omitempty" toml:"ports,omitempty"`
	Health  *HealthStatus      `protobuf:"bytes,13,opt,name=health,proto3" json:"health,omitempty" toml:"health,omitempty"`
	// contains filtered or unexported fields
}

func PbPodRepStatusSliceDel 

func PbPodRepStatusSliceDel(ls []*PbPodRepStatus, arg_podid string, arg_repid uint32) ([]*PbPodRepStatus, bool)

func PbPodRepStatusSliceGet 

func PbPodRepStatusSliceGet(ls []*PbPodRepStatus, arg_podid string, arg_repid uint32) *PbPodRepStatus

func PbPodRepStatusSliceSync 

func PbPodRepStatusSliceSync(ls []*PbPodRepStatus, it2 *PbPodRepStatus) ([]*PbPodRepStatus, bool)

func PbPodRepStatusSliceSyncSlice 

func PbPodRepStatusSliceSyncSlice(ls, ls2 []*PbPodRepStatus) ([]*PbPodRepStatus, bool)

func (*PbPodRepStatus) Descriptor deprecated 

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

Deprecated: Use PbPodRepStatus.ProtoReflect.Descriptor instead.

func (*PbPodRepStatus) Equal 

func (it *PbPodRepStatus) Equal(it2 *PbPodRepStatus) bool

func (*PbPodRepStatus) GetAction 

func (x *PbPodRepStatus) GetAction() uint32

func (*PbPodRepStatus) GetHealth 

func (x *PbPodRepStatus) GetHealth() *HealthStatus

func (*PbPodRepStatus) GetNode 

func (x *PbPodRepStatus) GetNode() string

func (*PbPodRepStatus) GetOpLog 

func (x *PbPodRepStatus) GetOpLog() *PbOpLogSets

func (*PbPodRepStatus) GetPodId 

func (x *PbPodRepStatus) GetPodId() string

func (*PbPodRepStatus) GetPorts 

func (x *PbPodRepStatus) GetPorts() []*PbServicePort

func (*PbPodRepStatus) GetRepId 

func (x *PbPodRepStatus) GetRepId() uint32

func (*PbPodRepStatus) GetStarted 

func (x *PbPodRepStatus) GetStarted() uint32

func (*PbPodRepStatus) GetStats 

func (x *PbPodRepStatus) GetStats() *PbStatsSampleFeed

func (*PbPodRepStatus) GetUpdated 

func (x *PbPodRepStatus) GetUpdated() uint32

func (*PbPodRepStatus) GetVolumes 

func (x *PbPodRepStatus) GetVolumes() []*PbVolumeStatus

func (*PbPodRepStatus) ProtoMessage 

func (*PbPodRepStatus) ProtoMessage()

func (*PbPodRepStatus) ProtoReflect 

func (x *PbPodRepStatus) ProtoReflect() protoreflect.Message

func (*PbPodRepStatus) Reset 

func (x *PbPodRepStatus) Reset()

func (*PbPodRepStatus) String 

func (x *PbPodRepStatus) String() string

func (*PbPodRepStatus) Sync 

func (it *PbPodRepStatus) Sync(it2 *PbPodRepStatus) bool

type PbPodSpecBoxImageDriver 

type PbPodSpecBoxImageDriver int32
const (
	PbPodSpecBoxImageDriver_Unknown PbPodSpecBoxImageDriver = 0
	PbPodSpecBoxImageDriver_Docker  PbPodSpecBoxImageDriver = 1
	PbPodSpecBoxImageDriver_Rkt     PbPodSpecBoxImageDriver = 2
	PbPodSpecBoxImageDriver_Pouch   PbPodSpecBoxImageDriver = 3
)

func PodSpecBoxImageDriver 

func PodSpecBoxImageDriver(name string) PbPodSpecBoxImageDriver

func (PbPodSpecBoxImageDriver) Descriptor 

func (PbPodSpecBoxImageDriver) Descriptor() protoreflect.EnumDescriptor

func (PbPodSpecBoxImageDriver) Enum 

func (x PbPodSpecBoxImageDriver) Enum() *PbPodSpecBoxImageDriver

func (PbPodSpecBoxImageDriver) EnumDescriptor deprecated 

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

Deprecated: Use PbPodSpecBoxImageDriver.Descriptor instead.

func (PbPodSpecBoxImageDriver) Number 

func (x PbPodSpecBoxImageDriver) Number() protoreflect.EnumNumber

func (PbPodSpecBoxImageDriver) String 

func (x PbPodSpecBoxImageDriver) String() string

func (PbPodSpecBoxImageDriver) Type 

func (PbPodSpecBoxImageDriver) Type() protoreflect.EnumType

type PbServicePort 

type PbServicePort struct {
	Name     string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty" toml:"name,omitempty"`                           // struct:object_slice_equal_skip
	BoxPort  uint32 `protobuf:"varint,2,opt,name=box_port,json=boxPort,proto3" json:"box_port,omitempty" toml:"box_port,omitempty"` // struct:object_slice_key
	HostPort uint32 `protobuf:"varint,3,opt,name=host_port,json=hostPort,proto3" json:"host_port,omitempty" toml:"host_port,omitempty"`
	// contains filtered or unexported fields
}

func PbServicePortSliceDel 

func PbServicePortSliceDel(ls []*PbServicePort, arg_boxport uint32) ([]*PbServicePort, bool)

func PbServicePortSliceGet 

func PbServicePortSliceGet(ls []*PbServicePort, arg_boxport uint32) *PbServicePort

func PbServicePortSliceSync 

func PbServicePortSliceSync(ls []*PbServicePort, it2 *PbServicePort) ([]*PbServicePort, bool)

func PbServicePortSliceSyncSlice 

func PbServicePortSliceSyncSlice(ls, ls2 []*PbServicePort) ([]*PbServicePort, bool)

func (*PbServicePort) Descriptor deprecated 

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

Deprecated: Use PbServicePort.ProtoReflect.Descriptor instead.

func (*PbServicePort) Equal 

func (it *PbServicePort) Equal(it2 *PbServicePort) bool

func (*PbServicePort) GetBoxPort 

func (x *PbServicePort) GetBoxPort() uint32

func (*PbServicePort) GetHostPort 

func (x *PbServicePort) GetHostPort() uint32

func (*PbServicePort) GetName 

func (x *PbServicePort) GetName() string

func (*PbServicePort) ProtoMessage 

func (*PbServicePort) ProtoMessage()

func (*PbServicePort) ProtoReflect 

func (x *PbServicePort) ProtoReflect() protoreflect.Message

func (*PbServicePort) Reset 

func (x *PbServicePort) Reset()

func (*PbServicePort) String 

func (x *PbServicePort) String() string

func (*PbServicePort) Sync 

func (it *PbServicePort) Sync(it2 *PbServicePort) bool

type PbStatsIndexFeed 

type PbStatsIndexFeed struct {
	Time  uint32                `protobuf:"varint,1,opt,name=time,proto3" json:"time,omitempty" toml:"time,omitempty"`
	Items []*PbStatsSampleEntry `protobuf:"bytes,2,rep,name=items,proto3" json:"items,omitempty" toml:"items,omitempty"`
	// contains filtered or unexported fields
}

func (*PbStatsIndexFeed) Descriptor deprecated 

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

Deprecated: Use PbStatsIndexFeed.ProtoReflect.Descriptor instead.

func (*PbStatsIndexFeed) GetItems 

func (x *PbStatsIndexFeed) GetItems() []*PbStatsSampleEntry

func (*PbStatsIndexFeed) GetTime 

func (x *PbStatsIndexFeed) GetTime() uint32

func (*PbStatsIndexFeed) ProtoMessage 

func (*PbStatsIndexFeed) ProtoMessage()

func (*PbStatsIndexFeed) ProtoReflect 

func (x *PbStatsIndexFeed) ProtoReflect() protoreflect.Message

func (*PbStatsIndexFeed) Reset 

func (x *PbStatsIndexFeed) Reset()

func (*PbStatsIndexFeed) String 

func (x *PbStatsIndexFeed) String() string

func (*PbStatsIndexFeed) Sync 

func (this *PbStatsIndexFeed) Sync(name string, timo uint32, value int64)

type PbStatsIndexList 

type PbStatsIndexList struct {
	IndexCycle  uint32              `protobuf:"varint,1,opt,name=index_cycle,json=indexCycle,proto3" json:"index_cycle,omitempty" toml:"index_cycle,omitempty"`
	SampleCycle uint32              `protobuf:"varint,2,opt,name=sample_cycle,json=sampleCycle,proto3" json:"sample_cycle,omitempty" toml:"sample_cycle,omitempty"`
	Items       []*PbStatsIndexFeed `protobuf:"bytes,3,rep,name=items,proto3" json:"items,omitempty" toml:"items,omitempty"`
	// contains filtered or unexported fields
}

func NewPbStatsIndexList 

func NewPbStatsIndexList(idx_cycle, spl_cycle uint32) *PbStatsIndexList

func (*PbStatsIndexList) Descriptor deprecated 

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

Deprecated: Use PbStatsIndexList.ProtoReflect.Descriptor instead.

func (*PbStatsIndexList) GetIndexCycle 

func (x *PbStatsIndexList) GetIndexCycle() uint32

func (*PbStatsIndexList) GetItems 

func (x *PbStatsIndexList) GetItems() []*PbStatsIndexFeed

func (*PbStatsIndexList) GetSampleCycle 

func (x *PbStatsIndexList) GetSampleCycle() uint32

func (*PbStatsIndexList) ProtoMessage 

func (*PbStatsIndexList) ProtoMessage()

func (*PbStatsIndexList) ProtoReflect 

func (x *PbStatsIndexList) ProtoReflect() protoreflect.Message

func (*PbStatsIndexList) Reset 

func (x *PbStatsIndexList) Reset()

func (*PbStatsIndexList) String 

func (x *PbStatsIndexList) String() string

func (*PbStatsIndexList) Sync 

func (this *PbStatsIndexList) Sync(name string, timo uint32, value int64)

type PbStatsSampleEntry 

type PbStatsSampleEntry struct {
	Name  string                `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty" toml:"name,omitempty"` // struct:object_slice_key
	Items []*PbStatsSampleValue `protobuf:"bytes,2,rep,name=items,proto3" json:"items,omitempty" toml:"items,omitempty"`
	// contains filtered or unexported fields
}

func PbStatsSampleEntrySliceDel 

func PbStatsSampleEntrySliceDel(ls []*PbStatsSampleEntry, arg_name string) ([]*PbStatsSampleEntry, bool)

func PbStatsSampleEntrySliceGet 

func PbStatsSampleEntrySliceGet(ls []*PbStatsSampleEntry, arg_name string) *PbStatsSampleEntry

func PbStatsSampleEntrySliceSync 

func PbStatsSampleEntrySliceSync(ls []*PbStatsSampleEntry, it2 *PbStatsSampleEntry) ([]*PbStatsSampleEntry, bool)

func PbStatsSampleEntrySliceSyncSlice 

func PbStatsSampleEntrySliceSyncSlice(ls, ls2 []*PbStatsSampleEntry) ([]*PbStatsSampleEntry, bool)

func (*PbStatsSampleEntry) Descriptor deprecated 

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

Deprecated: Use PbStatsSampleEntry.ProtoReflect.Descriptor instead.

func (*PbStatsSampleEntry) Equal 

func (it *PbStatsSampleEntry) Equal(it2 *PbStatsSampleEntry) bool

func (*PbStatsSampleEntry) GetItems 

func (x *PbStatsSampleEntry) GetItems() []*PbStatsSampleValue

func (*PbStatsSampleEntry) GetName 

func (x *PbStatsSampleEntry) GetName() string

func (*PbStatsSampleEntry) ProtoMessage 

func (*PbStatsSampleEntry) ProtoMessage()

func (*PbStatsSampleEntry) ProtoReflect 

func (x *PbStatsSampleEntry) ProtoReflect() protoreflect.Message

func (*PbStatsSampleEntry) Reset 

func (x *PbStatsSampleEntry) Reset()

func (*PbStatsSampleEntry) SampleSync 

func (this *PbStatsSampleEntry) SampleSync(timo uint32, value int64, opAppend bool)

func (*PbStatsSampleEntry) Sort 

func (this *PbStatsSampleEntry) Sort()

func (*PbStatsSampleEntry) String 

func (x *PbStatsSampleEntry) String() string

func (*PbStatsSampleEntry) Sync 

func (it *PbStatsSampleEntry) Sync(it2 *PbStatsSampleEntry) bool

func (*PbStatsSampleEntry) SyncTrim 

func (this *PbStatsSampleEntry) SyncTrim(timo uint32, value int64)

type PbStatsSampleFeed 

type PbStatsSampleFeed struct {
	Kind  string                `protobuf:"bytes,1,opt,name=kind,proto3" json:"kind,omitempty" toml:"kind,omitempty"`
	Cycle uint32                `protobuf:"varint,2,opt,name=cycle,proto3" json:"cycle,omitempty" toml:"cycle,omitempty"` // struct:object_slice_key
	Items []*PbStatsSampleEntry `protobuf:"bytes,3,rep,name=items,proto3" json:"items,omitempty" toml:"items,omitempty"`
	// contains filtered or unexported fields
}

func NewPbStatsSampleFeed 

func NewPbStatsSampleFeed(c uint32) *PbStatsSampleFeed

func PbStatsSampleFeedSliceDel 

func PbStatsSampleFeedSliceDel(ls []*PbStatsSampleFeed, arg_cycle uint32) ([]*PbStatsSampleFeed, bool)

func PbStatsSampleFeedSliceGet 

func PbStatsSampleFeedSliceGet(ls []*PbStatsSampleFeed, arg_cycle uint32) *PbStatsSampleFeed

func PbStatsSampleFeedSliceSync 

func PbStatsSampleFeedSliceSync(ls []*PbStatsSampleFeed, it2 *PbStatsSampleFeed) ([]*PbStatsSampleFeed, bool)

func PbStatsSampleFeedSliceSyncSlice 

func PbStatsSampleFeedSliceSyncSlice(ls, ls2 []*PbStatsSampleFeed) ([]*PbStatsSampleFeed, bool)

func (*PbStatsSampleFeed) Descriptor deprecated 

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

Deprecated: Use PbStatsSampleFeed.ProtoReflect.Descriptor instead.

func (*PbStatsSampleFeed) Equal 

func (it *PbStatsSampleFeed) Equal(it2 *PbStatsSampleFeed) bool

func (*PbStatsSampleFeed) Extract 

func (this *PbStatsSampleFeed) Extract(name string, extract_cycle, extract_time uint32) (uint32, int64)

func (*PbStatsSampleFeed) Get 

func (this *PbStatsSampleFeed) Get(name string) *PbStatsSampleEntry

func (*PbStatsSampleFeed) GetCycle 

func (x *PbStatsSampleFeed) GetCycle() uint32

func (*PbStatsSampleFeed) GetItems 

func (x *PbStatsSampleFeed) GetItems() []*PbStatsSampleEntry

func (*PbStatsSampleFeed) GetKind 

func (x *PbStatsSampleFeed) GetKind() string

func (*PbStatsSampleFeed) ProtoMessage 

func (*PbStatsSampleFeed) ProtoMessage()

func (*PbStatsSampleFeed) ProtoReflect 

func (x *PbStatsSampleFeed) ProtoReflect() protoreflect.Message

func (*PbStatsSampleFeed) Reset 

func (x *PbStatsSampleFeed) Reset()

func (*PbStatsSampleFeed) SampleSync 

func (this *PbStatsSampleFeed) SampleSync(name string, timo uint32, value int64, opAppend bool)

func (*PbStatsSampleFeed) String 

func (x *PbStatsSampleFeed) String() string

func (*PbStatsSampleFeed) Sync 

func (it *PbStatsSampleFeed) Sync(it2 *PbStatsSampleFeed) bool

type PbStatsSampleValue 

type PbStatsSampleValue struct {
	Time  uint32 `protobuf:"varint,1,opt,name=time,proto3" json:"time,omitempty" toml:"time,omitempty"` // struct:object_slice_key
	Value int64  `protobuf:"varint,2,opt,name=value,proto3" json:"value,omitempty" toml:"value,omitempty"`
	// contains filtered or unexported fields
}

func PbStatsSampleValueSliceDel 

func PbStatsSampleValueSliceDel(ls []*PbStatsSampleValue, arg_time uint32) ([]*PbStatsSampleValue, bool)

func PbStatsSampleValueSliceGet 

func PbStatsSampleValueSliceGet(ls []*PbStatsSampleValue, arg_time uint32) *PbStatsSampleValue

func PbStatsSampleValueSliceSync 

func PbStatsSampleValueSliceSync(ls []*PbStatsSampleValue, it2 *PbStatsSampleValue) ([]*PbStatsSampleValue, bool)

func PbStatsSampleValueSliceSyncSlice 

func PbStatsSampleValueSliceSyncSlice(ls, ls2 []*PbStatsSampleValue) ([]*PbStatsSampleValue, bool)

func (*PbStatsSampleValue) Descriptor deprecated 

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

Deprecated: Use PbStatsSampleValue.ProtoReflect.Descriptor instead.

func (*PbStatsSampleValue) Equal 

func (it *PbStatsSampleValue) Equal(it2 *PbStatsSampleValue) bool

func (*PbStatsSampleValue) GetTime 

func (x *PbStatsSampleValue) GetTime() uint32

func (*PbStatsSampleValue) GetValue 

func (x *PbStatsSampleValue) GetValue() int64

func (*PbStatsSampleValue) ProtoMessage 

func (*PbStatsSampleValue) ProtoMessage()

func (*PbStatsSampleValue) ProtoReflect 

func (x *PbStatsSampleValue) ProtoReflect() protoreflect.Message

func (*PbStatsSampleValue) Reset 

func (x *PbStatsSampleValue) Reset()

func (*PbStatsSampleValue) String 

func (x *PbStatsSampleValue) String() string

func (*PbStatsSampleValue) Sync 

func (it *PbStatsSampleValue) Sync(it2 *PbStatsSampleValue) bool

type PbVolumeMount 

type PbVolumeMount struct {
	Name      string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty" toml:"name,omitempty"` // struct:object_slice_equal_skip
	ReadOnly  bool   `protobuf:"varint,2,opt,name=read_only,json=readOnly,proto3" json:"read_only,omitempty" toml:"read_only,omitempty"`
	MountPath string `protobuf:"bytes,3,opt,name=mount_path,json=mountPath,proto3" json:"mount_path,omitempty" toml:"mount_path,omitempty"` // struct:object_slice_key
	HostDir   string `protobuf:"bytes,4,opt,name=host_dir,json=hostDir,proto3" json:"host_dir,omitempty" toml:"host_dir,omitempty"`
	// contains filtered or unexported fields
}

func PbVolumeMountSliceDel 

func PbVolumeMountSliceDel(ls []*PbVolumeMount, arg_mountpath string) ([]*PbVolumeMount, bool)

func PbVolumeMountSliceGet 

func PbVolumeMountSliceGet(ls []*PbVolumeMount, arg_mountpath string) *PbVolumeMount

func PbVolumeMountSliceSync 

func PbVolumeMountSliceSync(ls []*PbVolumeMount, it2 *PbVolumeMount) ([]*PbVolumeMount, bool)

func PbVolumeMountSliceSyncSlice 

func PbVolumeMountSliceSyncSlice(ls, ls2 []*PbVolumeMount) ([]*PbVolumeMount, bool)

func (*PbVolumeMount) Descriptor deprecated 

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

Deprecated: Use PbVolumeMount.ProtoReflect.Descriptor instead.

func (*PbVolumeMount) Equal 

func (it *PbVolumeMount) Equal(it2 *PbVolumeMount) bool

func (*PbVolumeMount) GetHostDir 

func (x *PbVolumeMount) GetHostDir() string

func (*PbVolumeMount) GetMountPath 

func (x *PbVolumeMount) GetMountPath() string

func (*PbVolumeMount) GetName 

func (x *PbVolumeMount) GetName() string

func (*PbVolumeMount) GetReadOnly 

func (x *PbVolumeMount) GetReadOnly() bool

func (*PbVolumeMount) ProtoMessage 

func (*PbVolumeMount) ProtoMessage()

func (*PbVolumeMount) ProtoReflect 

func (x *PbVolumeMount) ProtoReflect() protoreflect.Message

func (*PbVolumeMount) Reset 

func (x *PbVolumeMount) Reset()

func (*PbVolumeMount) String 

func (x *PbVolumeMount) String() string

func (*PbVolumeMount) Sync 

func (it *PbVolumeMount) Sync(it2 *PbVolumeMount) bool

type PbVolumeStatus 

type PbVolumeStatus struct {
	MountPath string `protobuf:"bytes,1,opt,name=mount_path,json=mountPath,proto3" json:"mount_path,omitempty" toml:"mount_path,omitempty"` // struct:object_slice_key
	Used      int64  `protobuf:"varint,2,opt,name=used,proto3" json:"used,omitempty" toml:"used,omitempty"`
	// contains filtered or unexported fields
}

func PbVolumeStatusSliceDel 

func PbVolumeStatusSliceDel(ls []*PbVolumeStatus, arg_mountpath string) ([]*PbVolumeStatus, bool)

func PbVolumeStatusSliceGet 

func PbVolumeStatusSliceGet(ls []*PbVolumeStatus, arg_mountpath string) *PbVolumeStatus

func PbVolumeStatusSliceSync 

func PbVolumeStatusSliceSync(ls []*PbVolumeStatus, it2 *PbVolumeStatus) ([]*PbVolumeStatus, bool)

func PbVolumeStatusSliceSyncSlice 

func PbVolumeStatusSliceSyncSlice(ls, ls2 []*PbVolumeStatus) ([]*PbVolumeStatus, bool)

func (*PbVolumeStatus) Descriptor deprecated 

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

Deprecated: Use PbVolumeStatus.ProtoReflect.Descriptor instead.

func (*PbVolumeStatus) Equal 

func (it *PbVolumeStatus) Equal(it2 *PbVolumeStatus) bool

func (*PbVolumeStatus) GetMountPath 

func (x *PbVolumeStatus) GetMountPath() string

func (*PbVolumeStatus) GetUsed 

func (x *PbVolumeStatus) GetUsed() int64

func (*PbVolumeStatus) ProtoMessage 

func (*PbVolumeStatus) ProtoMessage()

func (*PbVolumeStatus) ProtoReflect 

func (x *PbVolumeStatus) ProtoReflect() protoreflect.Message

func (*PbVolumeStatus) Reset 

func (x *PbVolumeStatus) Reset()

func (*PbVolumeStatus) String 

func (x *PbVolumeStatus) String() string

func (*PbVolumeStatus) Sync 

func (it *PbVolumeStatus) Sync(it2 *PbVolumeStatus) bool

type Pod 

type Pod struct {
	types.TypeMeta `json:",inline" toml:",inline"`
	Meta           types.InnerObjectMeta `json:"meta,omitempty" toml:"meta,omitempty"`

	// Spec defines the behavior of a pod.
	Spec *PodSpecBound `json:"spec,omitempty" toml:"spec,omitempty"`

	// Apps represents the information about a collection of applications to deploy.
	// this is a module for App Engine
	Apps AppInstances `json:"apps,omitempty" toml:"apps,omitempty"`

	//
	Operate PodOperate `json:"operate,omitempty" toml:"operate,omitempty"`

	// Status represents the current information about a pod. This data may not be up
	// to date.
	Status *PodStatus `json:"status,omitempty" toml:"status,omitempty"`

	//
	Payment *PodPayment `json:"payment,omitempty" toml:"payment,omitempty"`
}

Pod is a collection of containers, used as either input (create, update) or as output (list, get).

func (*Pod) AppServicePorts 

func (pod *Pod) AppServicePorts() ServicePorts

func (*Pod) FailoverEnable 

func (pod *Pod) FailoverEnable() bool

func (*Pod) OpRepCapValid 

func (pod *Pod) OpRepCapValid(num_new int32) error

func (*Pod) OpResScheduleFit 

func (pod *Pod) OpResScheduleFit() bool

func (*Pod) OpSysStateValid 

func (pod *Pod) OpSysStateValid(state_new int32) error

func (*Pod) OpSysStateless 

func (it *Pod) OpSysStateless() bool

func (*Pod) PodRepClone 

func (pod *Pod) PodRepClone(repId uint32) *PodRep

func (*Pod) Stateless 

func (it *Pod) Stateless() bool

type PodBoxBlockLimit 

type PodBoxBlockLimit struct {
	Path      string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty" toml:"path,omitempty"`
	ReadBps   int64  `protobuf:"varint,2,opt,name=read_bps,json=readBps,proto3" json:"read_bps,omitempty" toml:"read_bps,omitempty"`
	ReadIops  int64  `protobuf:"varint,3,opt,name=read_iops,json=readIops,proto3" json:"read_iops,omitempty" toml:"read_iops,omitempty"`
	WriteBps  int64  `protobuf:"varint,4,opt,name=write_bps,json=writeBps,proto3" json:"write_bps,omitempty" toml:"write_bps,omitempty"`
	WriteIops int64  `protobuf:"varint,5,opt,name=write_iops,json=writeIops,proto3" json:"write_iops,omitempty" toml:"write_iops,omitempty"`
	// contains filtered or unexported fields
}

func (*PodBoxBlockLimit) Descriptor deprecated 

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

Deprecated: Use PodBoxBlockLimit.ProtoReflect.Descriptor instead.

func (*PodBoxBlockLimit) GetPath 

func (x *PodBoxBlockLimit) GetPath() string

func (*PodBoxBlockLimit) GetReadBps 

func (x *PodBoxBlockLimit) GetReadBps() int64

func (*PodBoxBlockLimit) GetReadIops 

func (x *PodBoxBlockLimit) GetReadIops() int64

func (*PodBoxBlockLimit) GetWriteBps 

func (x *PodBoxBlockLimit) GetWriteBps() int64

func (*PodBoxBlockLimit) GetWriteIops 

func (x *PodBoxBlockLimit) GetWriteIops() int64

func (*PodBoxBlockLimit) ProtoMessage 

func (*PodBoxBlockLimit) ProtoMessage()

func (*PodBoxBlockLimit) ProtoReflect 

func (x *PodBoxBlockLimit) ProtoReflect() protoreflect.Message

func (*PodBoxBlockLimit) Reset 

func (x *PodBoxBlockLimit) Reset()

func (*PodBoxBlockLimit) String 

func (x *PodBoxBlockLimit) String() string

type PodCreate 

type PodCreate struct {
	types.TypeMeta `json:",inline" toml:",inline"`
	Owner          string               `json:"owner,omitempty" toml:"owner,omitempty"`
	Pod            string               `json:"pod,omitempty" toml:"pod,omitempty"`
	Name           string               `json:"name" toml:"name"`
	Plan           string               `json:"plan" toml:"plan"`
	Zone           string               `json:"zone" toml:"zone"`
	Cell           string               `json:"cell" toml:"cell"`
	ResVolume      string               `json:"res_volume" toml:"res_volume"`
	ResVolumeSize  int32                `json:"res_volume_size" toml:"res_volume_size"` // in GiB
	Mounts         []*PodSpecBoundMount `json:"mounts" toml:"mounts"`
	Box            PodCreateBox         `json:"box" toml:"box"`
}

func (*PodCreate) Valid 

func (s *PodCreate) Valid(plan PodSpecPlan) error

type PodCreateBox 

type PodCreateBox struct {
	Name               string `json:"name" toml:"name"`
	Image              string `json:"image" toml:"image"`
	ResCompute         string `json:"res_compute" toml:"res_compute"`
	ResComputeCpuLimit int32  `json:"res_compute_cpu_limit,omitempty" toml:"res_compute_cpu_limit,omitempty"` // in .1 Cores
	ResComputeMemLimit int32  `json:"res_compute_mem_limit,omitempty" toml:"res_compute_mem_limit,omitempty"` // in MiB
}

type PodEstimateEntry 

type PodEstimateEntry struct {
	Name        string  `json:"name" toml:"name"`
	CycleAmount float64 `json:"cycle_amount" toml:"cycle_amount"`
	CycleTime   uint64  `json:"cycle_time" toml:"cycle_time"`
}

type PodEstimateList 

type PodEstimateList struct {
	types.TypeMeta `json:",inline" toml:",inline"`
	Items          []*PodEstimateEntry `json:"items" toml:"items"`
}

type PodExecutorStatus 

type PodExecutorStatus struct {
	types.TypeMeta `json:",inline" toml:",inline"`
	Items          ExecutorStatuses `json:"items" toml:"items"`
}

type PodItems 

type PodItems []*Pod

func (*PodItems) Del 

func (ls *PodItems) Del(podId string)

func (*PodItems) Each 

func (ls *PodItems) Each(fn func(item *Pod))

func (*PodItems) Get 

func (ls *PodItems) Get(podId string) *Pod

func (*PodItems) Set 

func (ls *PodItems) Set(item *Pod)

type PodList 

type PodList struct {
	types.TypeMeta `json:",inline" toml:",inline"`
	Items          PodItems           `json:"items" toml:"items"`
	UserTransfers  []*PodUserTransfer `json:"user_transfers,omitempty" toml:"user_transfers,omitempty"`
}

PodList is a list of Pods.

type PodOperate 

type PodOperate struct {
	Action       uint32                   `json:"action,omitempty" toml:"action,omitempty"`
	Version      uint32                   `json:"version,omitempty" toml:"version,omitempty"`
	Priority     int                      `json:"priority,omitempty" toml:"priority,omitempty"` // TODO
	ReplicaCap   int32                    `json:"replica_cap,omitempty" toml:"replica_cap,omitempty"`
	Replicas     PodOperateReplicas       `json:"replicas,omitempty" toml:"replicas,omitempty"`
	OpLog        []*PbOpLogEntry          `json:"op_log,omitempty" toml:"op_log,omitempty"`
	Operated     uint32                   `json:"operated,omitempty" toml:"operated,omitempty"`
	Access       *PodOperateAccess        `json:"access,omitempty" toml:"access,omitempty"`
	BindServices []*AppServicePortPodBind `json:"bind_services,omitempty" toml:"bind_services,omitempty"`
	Failover     *PodOperateFailover      `json:"failover,omitempty" toml:"failover,omitempty"`
	Deploy       *PodOperateDeploy        `json:"deploy,omitempty" toml:"deploy,omitempty"`
	ExpSysState  int32                    `json:"exp_sys_state,omitempty" toml:"exp_sys_state,omitempty"`
	ExpMigrates  []uint32                 `json:"exp_migrates,omitempty" toml:"exp_migrates,omitempty"`
}

type PodOperateAccess 

type PodOperateAccess struct {
	SshOn  bool   `json:"ssh_on" toml:"ssh_on"`
	SshKey string `json:"ssh_key,omitempty" toml:"ssh_key,omitempty"`
	SshPwd string `json:"ssh_pwd,omitempty" toml:"ssh_pwd,omitempty"`
}

type PodOperateDeploy 

type PodOperateDeploy struct {
	AllocHostRepeatEnable bool `` /* 171-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*PodOperateDeploy) Descriptor deprecated 

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

Deprecated: Use PodOperateDeploy.ProtoReflect.Descriptor instead.

func (*PodOperateDeploy) GetAllocHostRepeatEnable 

func (x *PodOperateDeploy) GetAllocHostRepeatEnable() bool

func (*PodOperateDeploy) ProtoMessage 

func (*PodOperateDeploy) ProtoMessage()

func (*PodOperateDeploy) ProtoReflect 

func (x *PodOperateDeploy) ProtoReflect() protoreflect.Message

func (*PodOperateDeploy) Reset 

func (x *PodOperateDeploy) Reset()

func (*PodOperateDeploy) String 

func (x *PodOperateDeploy) String() string

type PodOperateFailover 

type PodOperateFailover struct {
	Reps []*PodOperateFailoverReplica `protobuf:"bytes,2,rep,name=reps,proto3" json:"reps,omitempty" toml:"reps,omitempty"`
	// contains filtered or unexported fields
}

func (*PodOperateFailover) Descriptor deprecated 

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

Deprecated: Use PodOperateFailover.ProtoReflect.Descriptor instead.

func (*PodOperateFailover) GetReps 

func (x *PodOperateFailover) GetReps() []*PodOperateFailoverReplica

func (*PodOperateFailover) ProtoMessage 

func (*PodOperateFailover) ProtoMessage()

func (*PodOperateFailover) ProtoReflect 

func (x *PodOperateFailover) ProtoReflect() protoreflect.Message

func (*PodOperateFailover) Reset 

func (x *PodOperateFailover) Reset()

func (*PodOperateFailover) String 

func (x *PodOperateFailover) String() string

type PodOperateFailoverReplica 

type PodOperateFailoverReplica struct {
	RepId         uint32 `protobuf:"varint,1,opt,name=rep_id,json=repId,proto3" json:"rep_id,omitempty" toml:"rep_id,omitempty"` // struct:object_slice_key
	Action        uint32 `protobuf:"varint,4,opt,name=action,proto3" json:"action,omitempty" toml:"action,omitempty"`
	ManualChecked uint32 `` /* 134-byte string literal not displayed */
	Created       uint32 `protobuf:"varint,14,opt,name=created,proto3" json:"created,omitempty" toml:"created,omitempty"`
	Updated       uint32 `protobuf:"varint,15,opt,name=updated,proto3" json:"updated,omitempty" toml:"updated,omitempty"`
	// contains filtered or unexported fields
}

func PodOperateFailoverReplicaSliceDel 

func PodOperateFailoverReplicaSliceDel(ls []*PodOperateFailoverReplica, arg_repid uint32) ([]*PodOperateFailoverReplica, bool)

func PodOperateFailoverReplicaSliceGet 

func PodOperateFailoverReplicaSliceGet(ls []*PodOperateFailoverReplica, arg_repid uint32) *PodOperateFailoverReplica

func PodOperateFailoverReplicaSliceSync 

func PodOperateFailoverReplicaSliceSync(ls []*PodOperateFailoverReplica, it2 *PodOperateFailoverReplica) ([]*PodOperateFailoverReplica, bool)

func PodOperateFailoverReplicaSliceSyncSlice 

func PodOperateFailoverReplicaSliceSyncSlice(ls, ls2 []*PodOperateFailoverReplica) ([]*PodOperateFailoverReplica, bool)

func (*PodOperateFailoverReplica) Descriptor deprecated 

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

Deprecated: Use PodOperateFailoverReplica.ProtoReflect.Descriptor instead.

func (*PodOperateFailoverReplica) Equal 

func (it *PodOperateFailoverReplica) Equal(it2 *PodOperateFailoverReplica) bool

func (*PodOperateFailoverReplica) GetAction 

func (x *PodOperateFailoverReplica) GetAction() uint32

func (*PodOperateFailoverReplica) GetCreated 

func (x *PodOperateFailoverReplica) GetCreated() uint32

func (*PodOperateFailoverReplica) GetManualChecked 

func (x *PodOperateFailoverReplica) GetManualChecked() uint32

func (*PodOperateFailoverReplica) GetRepId 

func (x *PodOperateFailoverReplica) GetRepId() uint32

func (*PodOperateFailoverReplica) GetUpdated 

func (x *PodOperateFailoverReplica) GetUpdated() uint32

func (*PodOperateFailoverReplica) ProtoMessage 

func (*PodOperateFailoverReplica) ProtoMessage()

func (*PodOperateFailoverReplica) ProtoReflect 

func (x *PodOperateFailoverReplica) ProtoReflect() protoreflect.Message

func (*PodOperateFailoverReplica) Reset 

func (x *PodOperateFailoverReplica) Reset()

func (*PodOperateFailoverReplica) String 

func (x *PodOperateFailoverReplica) String() string

func (*PodOperateFailoverReplica) Sync 

func (it *PodOperateFailoverReplica) Sync(it2 *PodOperateFailoverReplica) bool

type PodOperateReplica 

type PodOperateReplica struct {
	RepId     uint32             `json:"rep_id" toml:"rep_id"`
	Node      string             `json:"node,omitempty" toml:"node,omitempty"`
	Action    uint32             `json:"action,omitempty" toml:"action,omitempty"`
	ResCpu    int32              `json:"res_cpu,omitempty" toml:"res_cpu,omitempty"`         // in 1 = .1 Cores
	ResMem    int32              `json:"res_mem,omitempty" toml:"res_mem,omitempty"`         // in MiB
	VolSys    int32              `json:"vol_sys,omitempty" toml:"vol_sys,omitempty"`         // in GiB
	VolSysMnt string             `json:"vol_sys_mnt,omitempty" toml:"vol_sys_mnt,omitempty"` //
	Ports     ServicePorts       `json:"ports,omitempty" toml:"ports,omitempty"`
	Options   types.Labels       `json:"options,omitempty" toml:"options,omitempty"`
	Next      *PodOperateReplica `json:"next,omitempty" toml:"next,omitempty"`
	PrevNode  string             `json:"prev_node,omitempty" toml:"prev_node,omitempty"`
	Updated   uint32             `json:"updated,omitempty" toml:"updated,omitempty"`
	Scheduled uint32             `json:"scheduled,omitempty" toml:"scheduled,omitempty"`
	VpcIpv4   string             `json:"vpc_ipv4,omitempty" toml:"vpc_ipv4,omitempty"`
}

func (*PodOperateReplica) HostAddress 

func (it *PodOperateReplica) HostAddress(podId string) string

type PodOperateReplicas 

type PodOperateReplicas []*PodOperateReplica

func (*PodOperateReplicas) Del 

func (ls *PodOperateReplicas) Del(repId uint32)

func (*PodOperateReplicas) Get 

func (ls *PodOperateReplicas) Get(repId uint32) *PodOperateReplica

func (*PodOperateReplicas) Set 

func (ls *PodOperateReplicas) Set(set PodOperateReplica) error

func (*PodOperateReplicas) Sort 

func (ls *PodOperateReplicas) Sort()

type PodPayment 

type PodPayment struct {
	TimeStart   uint32  `protobuf:"varint,2,opt,name=time_start,json=timeStart,proto3" json:"time_start,omitempty" toml:"time_start,omitempty"`
	TimeClose   uint32  `protobuf:"varint,3,opt,name=time_close,json=timeClose,proto3" json:"time_close,omitempty" toml:"time_close,omitempty"`
	Prepay      float64 `protobuf:"fixed64,5,opt,name=prepay,proto3" json:"prepay,omitempty" toml:"prepay,omitempty"`
	Payout      float64 `protobuf:"fixed64,6,opt,name=payout,proto3" json:"payout,omitempty" toml:"payout,omitempty"`
	CycleAmount float64 `` /* 126-byte string literal not displayed */
	User        string  `protobuf:"bytes,9,opt,name=user,proto3" json:"user,omitempty" toml:"user,omitempty"`
	// contains filtered or unexported fields
}

func (*PodPayment) Descriptor deprecated 

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

Deprecated: Use PodPayment.ProtoReflect.Descriptor instead.

func (*PodPayment) GetCycleAmount 

func (x *PodPayment) GetCycleAmount() float64

func (*PodPayment) GetPayout 

func (x *PodPayment) GetPayout() float64

func (*PodPayment) GetPrepay 

func (x *PodPayment) GetPrepay() float64

func (*PodPayment) GetTimeClose 

func (x *PodPayment) GetTimeClose() uint32

func (*PodPayment) GetTimeStart 

func (x *PodPayment) GetTimeStart() uint32

func (*PodPayment) GetUser 

func (x *PodPayment) GetUser() string

func (*PodPayment) ProtoMessage 

func (*PodPayment) ProtoMessage()

func (*PodPayment) ProtoReflect 

func (x *PodPayment) ProtoReflect() protoreflect.Message

func (*PodPayment) Reset 

func (x *PodPayment) Reset()

func (*PodPayment) String 

func (x *PodPayment) String() string

type PodRep 

type PodRep struct {
	Meta types.InnerObjectMeta `json:"meta,omitempty" toml:"meta,omitempty"`

	// Spec defines the behavior of a pod.
	Spec *PodSpecBound `json:"spec,omitempty" toml:"spec,omitempty"`

	// Apps represents the information about a collection of applications to deploy.
	// this is a module for App Engine
	Apps AppInstances `json:"apps,omitempty" toml:"apps,omitempty"`

	// Replica
	Replica PodOperateReplica `json:"replica,omitempty" toml:"replica,omitempty"`

	//
	Operate PodOperate `json:"operate,omitempty" toml:"operate,omitempty"`
}

func (*PodRep) RepKey 

func (it *PodRep) RepKey() string

type PodRepItems 

type PodRepItems []*PodRep

func (*PodRepItems) Del 

func (ls *PodRepItems) Del(repKey string)

func (*PodRepItems) Each 

func (ls *PodRepItems) Each(fn func(item *PodRep))

func (*PodRepItems) Get 

func (ls *PodRepItems) Get(podId string) *PodRep

func (*PodRepItems) Set 

func (ls *PodRepItems) Set(item *PodRep)

type PodRepStatuses 

type PodRepStatuses []*PbPodRepStatus

Pod Status

func (*PodRepStatuses) Sort 

func (ls *PodRepStatuses) Sort()

type PodSpecBound 

type PodSpecBound struct {
	Ref       ObjectReference      `json:"ref,omitempty" toml:"ref,omitempty"`
	Zone      string               `json:"zone,omitempty" toml:"zone,omitempty"`
	Cell      string               `json:"cell,omitempty" toml:"cell,omitempty"`
	BoxDriver string               `json:"box_driver,omitempty" toml:"box_driver,omitempty"`
	Labels    types.Labels         `json:"labels,omitempty" toml:"labels,omitempty"`
	VolSys    *ResVolBound         `json:"vol_sys,omitempty" toml:"vol_sys,omitempty"`
	Box       PodSpecBoxBound      `json:"box,omitempty" toml:"box,omitempty"`
	Mounts    []*PodSpecBoundMount `json:"mounts" toml:"mounts"`
	// Deprecated
	Volumes []PodSpecResVolumeBound `json:"volumes,omitempty" toml:"volumes,omitempty"`
}

PodSpecBound is a description of a bound spec based on PodSpecPlan

func (PodSpecBound) MarshalJSON 

func (it PodSpecBound) MarshalJSON() ([]byte, error)

struct upgrade

func (*PodSpecBound) MountSet 

func (it *PodSpecBound) MountSet(v *PodSpecBoundMount) bool

func (*PodSpecBound) ResComputeBound 

func (obj *PodSpecBound) ResComputeBound() *PodSpecBoxResComputeBound

func (*PodSpecBound) UnmarshalJSON 

func (it *PodSpecBound) UnmarshalJSON(b []byte) error

struct upgrade

type PodSpecBoundList 

type PodSpecBoundList struct {
	types.TypeMeta `json:",inline" toml:",inline"`
	Items          []PodSpecBound `json:"items,omitempty" toml:"items,omitempty"`
}

type PodSpecBoundMount 

type PodSpecBoundMount struct {
	Target string `json:"target" toml:"target"`
	Source string `json:"source,omitempty" toml:"source,omitempty"`
}

type PodSpecBoxBound 

type PodSpecBoxBound struct {
	Name      string                     `json:"name,omitempty" toml:"name,omitempty"`
	Image     PodSpecBoxImageBound       `json:"image,omitempty" toml:"image,omitempty"`
	Resources *PodSpecBoxResComputeBound `json:"resources,omitempty" toml:"resources,omitempty"`
	Mounts    []*PbVolumeMount           `json:"mounts,omitempty" toml:"mounts,omitempty"`
	Ports     Ports                      `json:"ports,omitempty" toml:"ports,omitempty"`
	Command   []string                   `json:"command,omitempty" toml:"command,omitempty"`
	Updated   types.MetaTime             `json:"updated,omitempty" toml:"updated,omitempty"`
}

type PodSpecBoxImage 

type PodSpecBoxImage struct {
	types.TypeMeta `json:",inline" toml:",inline"`
	Meta           types.InnerObjectMeta `json:"meta,omitempty" toml:"meta,omitempty"`

	Name      string `json:"name" toml:"name"`
	Tag       string `json:"tag" toml:"tag"`
	SortOrder int    `json:"sort_order" toml:"sort_order"`
	Action    uint32 `json:"action,omitempty" toml:"action,omitempty"`

	// Container type of the image.
	//  ex: docker, pouch, ...
	Driver string `json:"driver,omitempty" toml:"driver,omitempty"`

	// Distribution short name of the operating system.
	//  ex: el7, deb9, ubu1804, ...
	OsDist string `json:"os_dist,omitempty" toml:"os_dist,omitempty"`

	// Architecture indicates the type of hardware.
	//  ex: x64, armv6l, ...
	Arch string `json:"arch,omitempty" toml:"arch,omitempty"`
}

type PodSpecBoxImageBound 

type PodSpecBoxImageBound struct {
	Ref *ObjectReference `json:"ref,omitempty" toml:"ref,omitempty"`

	RefName  string `json:"ref_name" toml:"ref_name"`
	RefTag   string `json:"ref_tag" toml:"ref_tag"`
	RefTitle string `json:"ref_title" toml:"ref_title"`

	Driver string `json:"driver,omitempty" toml:"driver,omitempty"`

	// Distribution short name of the operating system.
	//  ex: el6, el7, deb7, ubu1404, ...
	OsDist string `json:"os_dist,omitempty" toml:"os_dist,omitempty"`

	// Architecture indicates the type of hardware.
	//  ex: amd64, armv6l, ...
	Arch string `json:"arch,omitempty" toml:"arch,omitempty"`
}

type PodSpecBoxImageList 

type PodSpecBoxImageList struct {
	types.TypeMeta `json:",inline" toml:",inline"`
	Items          []PodSpecBoxImage `json:"items,omitempty" toml:"items,omitempty"`
}

type PodSpecBoxResComputeBound 

type PodSpecBoxResComputeBound struct {
	Ref      *ObjectReference `json:"ref,omitempty" toml:"ref,omitempty"`
	CpuLimit int32            `json:"cpu_limit,omitempty" toml:"cpu_limit,omitempty"` // in .1 Cores
	MemLimit int32            `json:"mem_limit,omitempty" toml:"mem_limit,omitempty"` // in MiB
}

type PodSpecPlan 

type PodSpecPlan struct {
	types.TypeMeta `json:",inline" toml:",inline"`
	Meta           types.InnerObjectMeta `json:"meta,omitempty" toml:"meta,omitempty"`

	Status    string                  `json:"status,omitempty" toml:"status,omitempty"`
	Zones     []*PodSpecPlanZoneBound `json:"zones,omitempty" toml:"zones,omitempty"`
	SortOrder int                     `json:"sort_order" toml:"sort_order"`

	Labels      types.Labels `json:"labels,omitempty" toml:"labels,omitempty"`
	Annotations types.Labels `json:"annotations,omitempty" toml:"annotations,omitempty"`

	Images       []*PodSpecPlanBoxImageBound `json:"images,omitempty" toml:"images,omitempty"`
	ImageDefault string                      `json:"image_default,omitempty" toml:"image_default,omitempty"`

	ResComputes       PodSpecPlanResComputeBounds `json:"res_computes,omitempty" toml:"res_computes,omitempty"`
	ResComputeDefault string                      `json:"res_compute_default,omitempty" toml:"res_compute_default,omitempty"`
	ResComputeCharge  PodSpecResComputeCharge     `json:"res_compute_charge,omitempty" toml:"res_compute_charge,omitempty"`

	ResVolumes       []*PodSpecPlanResVolumeBound `json:"res_volumes,omitempty" toml:"res_volumes,omitempty"`
	ResVolumeDefault string                       `json:"res_volume_default,omitempty" toml:"res_volume_default,omitempty"`
	ResVolumeCharge  PodSpecResVolumeCharge       `json:"res_volume_charge,omitempty" toml:"res_volume_charge,omitempty"`

	ResourceCharge PodSpecPlanResourceCharge `json:"res_charge" toml:"res_charge"`
}

func (*PodSpecPlan) ChargeFix 

func (s *PodSpecPlan) ChargeFix()

TODO

func (PodSpecPlan) Image 

func (s PodSpecPlan) Image(id string) *PodSpecPlanBoxImageBound

func (*PodSpecPlan) ImagesSort 

func (it *PodSpecPlan) ImagesSort()

func (PodSpecPlan) ResCompute 

func (s PodSpecPlan) ResCompute(id string) *PodSpecPlanResComputeBound

func (PodSpecPlan) ResVolume 

func (s PodSpecPlan) ResVolume(id string) *PodSpecPlanResVolumeBound

func (*PodSpecPlan) VolCharge 

func (s *PodSpecPlan) VolCharge(ref_id string) float64

type PodSpecPlanBoxImageBound 

type PodSpecPlanBoxImageBound struct {
	RefId     string `json:"ref_id" toml:"ref_id"`
	RefName   string `json:"ref_name" toml:"ref_name"`
	RefTag    string `json:"ref_tag" toml:"ref_tag"`
	RefTitle  string `json:"ref_title" toml:"ref_title"`
	Driver    string `json:"driver,omitempty" toml:"driver,omitempty"`
	OsDist    string `json:"os_dist,omitempty" toml:"os_dist,omitempty"`
	Arch      string `json:"arch,omitempty" toml:"arch,omitempty"`
	SortOrder int    `json:"sort_order" toml:"sort_order"`
}

type PodSpecPlanList 

type PodSpecPlanList struct {
	types.TypeMeta `json:",inline" toml:",inline"`
	Items          PodSpecPlans `json:"items,omitempty" toml:"items,omitempty"`
}

func (*PodSpecPlanList) Get 

func (ls *PodSpecPlanList) Get(plan_id string) *PodSpecPlan

type PodSpecPlanResComputeBound 

type PodSpecPlanResComputeBound struct {
	RefId    string `json:"ref_id" toml:"ref_id"`
	CpuLimit int32  `json:"cpu_limit" toml:"cpu_limit"` // in .1 Cores
	MemLimit int32  `json:"mem_limit" toml:"mem_limit"` // in MiB
}

type PodSpecPlanResComputeBounds 

type PodSpecPlanResComputeBounds []*PodSpecPlanResComputeBound

func (PodSpecPlanResComputeBounds) Len 

func (s PodSpecPlanResComputeBounds) Len() int

func (PodSpecPlanResComputeBounds) Less 

func (s PodSpecPlanResComputeBounds) Less(i, j int) bool

func (PodSpecPlanResComputeBounds) Swap 

func (s PodSpecPlanResComputeBounds) Swap(i, j int)

type PodSpecPlanResVolumeBound 

type PodSpecPlanResVolumeBound struct {
	RefId       string       `json:"ref_id" toml:"ref_id"`
	RefName     string       `json:"ref_name" toml:"ref_name"`
	Limit       int32        `json:"limit,omitempty" toml:"limit,omitempty"`     // max to 2000 GB
	Request     int32        `json:"request,omitempty" toml:"request,omitempty"` // start from 1 GiB
	Step        int32        `json:"step,omitempty" toml:"step,omitempty"`       // every step by 1 GiB
	Default     int32        `json:"default,omitempty" toml:"default,omitempty"` // default to 1 GiB
	Labels      types.Labels `json:"labels,omitempty" toml:"labels,omitempty"`
	Attrs       uint32       `json:"attrs,omitempty" toml:"attrs,omitempty"`
	ChargeValue float64      `json:"charge_value,omitempty" toml:"charge_value,omitempty"`
}

type PodSpecPlanResourceCharge 

type PodSpecPlanResourceCharge struct {
	Type  uint8  `json:"type" toml:"type"`
	Cycle uint64 `json:"cycle" toml:"cycle"` // default to 3600 seconds
}

type PodSpecPlanZoneBound 

type PodSpecPlanZoneBound struct {
	Name  string            `json:"name,omitempty" toml:"name,omitempty"`
	Cells types.ArrayString `json:"cells,omitempty" toml:"cells,omitempty"`
}

type PodSpecPlans 

type PodSpecPlans []*PodSpecPlan

func (*PodSpecPlans) Get 

func (ls *PodSpecPlans) Get(plan_id string) *PodSpecPlan

type PodSpecResCompute 

type PodSpecResCompute struct {
	types.TypeMeta `json:",inline" toml:",inline"`
	Meta           types.InnerObjectMeta `json:"meta,omitempty" toml:"meta,omitempty"`

	Status string `json:"status,omitempty" toml:"status,omitempty"`

	// Labels are name value pairs that representing extensional information,
	// usually be used in special system components, names must be unique within the list.
	// ex:
	//  {name: "plan/name", value: "general"}, ...
	Labels types.Labels `json:"labels,omitempty" toml:"labels,omitempty"`

	// CPU, in Cores. (1 = .1 Cores)
	CpuLimit int32 `json:"cpu_limit,omitempty" toml:"cpu_limit,omitempty"`

	// Memory, in MiB
	MemLimit int32 `json:"mem_limit,omitempty" toml:"mem_limit,omitempty"`
}

type PodSpecResComputeCharge 

type PodSpecResComputeCharge struct {
	Type  uint8   `json:"type" toml:"type"`
	Cycle uint64  `json:"cycle" toml:"cycle"` // default to 3600 seconds
	Cpu   float64 `json:"cpu" toml:"cpu"`     // value in Cores
	Mem   float64 `json:"mem" toml:"mem"`     // value in MiB
}

type PodSpecResComputeList 

type PodSpecResComputeList struct {
	types.TypeMeta `json:",inline" toml:",inline"`
	Items          PodSpecResComputes `json:"items,omitempty" toml:"items,omitempty"`
}

type PodSpecResComputes 

type PodSpecResComputes []*PodSpecResCompute

func (PodSpecResComputes) Len 

func (s PodSpecResComputes) Len() int

func (PodSpecResComputes) Less 

func (s PodSpecResComputes) Less(i, j int) bool

func (PodSpecResComputes) Swap 

func (s PodSpecResComputes) Swap(i, j int)

type PodSpecResVolume 

type PodSpecResVolume struct {
	types.TypeMeta `json:",inline" toml:",inline"`
	Meta           types.InnerObjectMeta `json:"meta,omitempty" toml:"meta,omitempty"`

	Status string `json:"status,omitempty" toml:"status,omitempty"`

	// Labels are name value pairs that representing extensional information,
	// usually be used in special system components, names must be unique within the list.
	// ex:
	//  {name: "plan/name", value: "general"}, ...
	Labels types.Labels `json:"labels,omitempty" toml:"labels,omitempty"`

	// Volume size, in GiB.
	Limit   int32  `json:"limit,omitempty" toml:"limit,omitempty"`     // max to 1000 GB
	Request int32  `json:"request,omitempty" toml:"request,omitempty"` // start from 1 GiB
	Step    int32  `json:"step,omitempty" toml:"step,omitempty"`       // every step by 1 GiB
	Default int32  `json:"default,omitempty" toml:"default,omitempty"` // default to 1 GiB
	Attrs   uint32 `json:"attrs,omitempty" toml:"attrs,omitempty"`
}

type PodSpecResVolumeBound 

type PodSpecResVolumeBound struct {
	Ref       ObjectReference `json:"ref,omitempty" toml:"ref,omitempty"`
	Name      string          `json:"name" toml:"name"`
	Labels    types.Labels    `json:"labels,omitempty" toml:"labels,omitempty"`
	SizeLimit int32           `json:"size_limit,omitempty" toml:"size_limit,omitempty"` // in GiB
	Attrs     uint32          `json:"attrs,omitempty" toml:"attrs,omitempty"`
}

type PodSpecResVolumeCharge 

type PodSpecResVolumeCharge struct {
	Type  uint8   `json:"type" toml:"type"`
	Cycle uint64  `json:"cycle" toml:"cycle"` // default to 3600 seconds
	Value float64 `json:"value" toml:"value"`
}

type PodSpecResVolumeList 

type PodSpecResVolumeList struct {
	types.TypeMeta `json:",inline" toml:",inline"`
	Items          []PodSpecResVolume `json:"items,omitempty" toml:"items,omitempty"`
}

type PodSpecResourceNetwork 

type PodSpecResourceNetwork struct {
	types.TypeMeta `json:",inline" toml:",inline"`
	Meta           types.InnerObjectMeta `json:"meta,omitempty" toml:"meta,omitempty"`
}

TODO

type PodSpecResourceNetworkList 

type PodSpecResourceNetworkList struct {
	types.TypeMeta `json:",inline" toml:",inline"`
	Items          []PodSpecResourceNetwork `json:"items,omitempty" toml:"items,omitempty"`
}

TODO

type PodStatus 

type PodStatus struct {
	types.TypeMeta     `json:",inline" toml:",inline"`
	PodId              string          `json:"pod_id,omitempty" toml:"pod_id,omitempty"`
	Action             uint32          `json:"action,omitempty" toml:"action,omitempty"`
	ActionRunning      int             `json:"action_running" toml:"action_running"`
	Replicas           PodRepStatuses  `json:"replicas,omitempty" toml:"replicas,omitempty"`
	Updated            uint32          `json:"updated,omitempty" toml:"updated,omitempty"`
	OpLog              []*PbOpLogEntry `json:"op_log,omitempty" toml:"op_log,omitempty"`
	PaymentCycleAmount float32         `json:"payment_cycle_amount,omitempty" toml:"payment_cycle_amount,omitempty"`
}

PodStatus represents information about the status of a pod. Status may trail the actual state of a system.

func (*PodStatus) HealthFails 

func (it *PodStatus) HealthFails(delaySeconds int32, stateless bool, repCap int32) types.ArrayUint32

func (*PodStatus) RepActionAllow 

func (it *PodStatus) RepActionAllow(repCap int, op uint32) bool

func (*PodStatus) RepDel 

func (it *PodStatus) RepDel(repId uint32)

func (*PodStatus) RepGet 

func (it *PodStatus) RepGet(repId uint32) *PbPodRepStatus

func (*PodStatus) RepSync 

func (it *PodStatus) RepSync(v *PbPodRepStatus) bool

type PodStatusList 

type PodStatusList struct {
	Items []*PodStatus `json:"items" toml:"items"`
	// contains filtered or unexported fields
}

func (*PodStatusList) Get 

func (ls *PodStatusList) Get(id string) *PodStatus

func (*PodStatusList) Set 

func (ls *PodStatusList) Set(v2 *PodStatus) *PodStatus

type PodUserTransfer 

type PodUserTransfer struct {
	Id       string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty" toml:"id,omitempty"` // struct:object_slice_key
	Name     string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty" toml:"name,omitempty"`
	UserFrom string `protobuf:"bytes,5,opt,name=user_from,json=userFrom,proto3" json:"user_from,omitempty" toml:"user_from,omitempty"`
	UserTo   string `protobuf:"bytes,6,opt,name=user_to,json=userTo,proto3" json:"user_to,omitempty" toml:"user_to,omitempty"`
	Created  uint32 `protobuf:"varint,14,opt,name=created,proto3" json:"created,omitempty" toml:"created,omitempty"`
	// contains filtered or unexported fields
}

func PodUserTransferSliceDel 

func PodUserTransferSliceDel(ls []*PodUserTransfer, arg_id string) ([]*PodUserTransfer, bool)

func PodUserTransferSliceGet 

func PodUserTransferSliceGet(ls []*PodUserTransfer, arg_id string) *PodUserTransfer

func PodUserTransferSliceSync 

func PodUserTransferSliceSync(ls []*PodUserTransfer, it2 *PodUserTransfer) ([]*PodUserTransfer, bool)

func PodUserTransferSliceSyncSlice 

func PodUserTransferSliceSyncSlice(ls, ls2 []*PodUserTransfer) ([]*PodUserTransfer, bool)

func (*PodUserTransfer) Descriptor deprecated 

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

Deprecated: Use PodUserTransfer.ProtoReflect.Descriptor instead.

func (*PodUserTransfer) Equal 

func (it *PodUserTransfer) Equal(it2 *PodUserTransfer) bool

func (*PodUserTransfer) GetCreated 

func (x *PodUserTransfer) GetCreated() uint32

func (*PodUserTransfer) GetId 

func (x *PodUserTransfer) GetId() string

func (*PodUserTransfer) GetName 

func (x *PodUserTransfer) GetName() string

func (*PodUserTransfer) GetUserFrom 

func (x *PodUserTransfer) GetUserFrom() string

func (*PodUserTransfer) GetUserTo 

func (x *PodUserTransfer) GetUserTo() string

func (*PodUserTransfer) ProtoMessage 

func (*PodUserTransfer) ProtoMessage()

func (*PodUserTransfer) ProtoReflect 

func (x *PodUserTransfer) ProtoReflect() protoreflect.Message

func (*PodUserTransfer) Reset 

func (x *PodUserTransfer) Reset()

func (*PodUserTransfer) String 

func (x *PodUserTransfer) String() string

func (*PodUserTransfer) Sync 

func (it *PodUserTransfer) Sync(it2 *PodUserTransfer) bool

type Port 

type Port struct {
	// Optional: If specified, this must be a DNS_LABEL.  Each named port
	// in a pod must have a unique name.
	Name string `json:"name,omitempty" toml:"name,omitempty"`
	// Optional: If specified, this must be a valid port number, 0 < x < 65536.
	Protocol Protocol `json:"protocol,omitempty" toml:"protocol,omitempty"`
	// Required: This must be a valid port number, 0 < x < 65536.
	BoxPort int `json:"box_port" toml:"box_port"`
	// Optional: If specified, this must be a valid port number, 0 < x < 65536.
	HostPort int `json:"host_port,omitempty" toml:"host_port,omitempty"`
	// Optional: What host IP to bind the external port to.
	HostIP string `json:"host_ip,omitempty" toml:"host_ip,omitempty"`
}

Port represents a network port in a single container

type Ports 

type Ports []Port

func (*Ports) Equal 

func (ls *Ports) Equal(items Ports) bool

func (*Ports) Sync 

func (ls *Ports) Sync(item Port) (changed bool)

type Protocol 

type Protocol string

Protocol defines network protocols supported for things like conatiner ports. 

const (
	// ProtocolTCP is the TCP protocol.
	ProtocolTCP Protocol = "TCP"
	// ProtocolUDP is the UDP protocol.
	ProtocolUDP Protocol = "UDP"
)

type ResCell 

type ResCell struct {
	Meta        *ObjectMeta    `protobuf:"bytes,2,opt,name=meta,proto3" json:"meta,omitempty" toml:"meta,omitempty"`
	ZoneId      string         `protobuf:"bytes,3,opt,name=zone_id,json=zoneId,proto3" json:"zone_id,omitempty" toml:"zone_id,omitempty"`
	Phase       uint32         `protobuf:"varint,4,opt,name=phase,proto3" json:"phase,omitempty" toml:"phase,omitempty"`
	Description string         `protobuf:"bytes,5,opt,name=description,proto3" json:"description,omitempty" toml:"description,omitempty"`
	NodeNum     int32          `protobuf:"varint,6,opt,name=node_num,json=nodeNum,proto3" json:"node_num,omitempty" toml:"node_num,omitempty"`
	Status      *ResCellStatus `protobuf:"bytes,7,opt,name=status,proto3" json:"status,omitempty" toml:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*ResCell) Descriptor deprecated 

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

Deprecated: Use ResCell.ProtoReflect.Descriptor instead.

func (*ResCell) GetDescription 

func (x *ResCell) GetDescription() string

func (*ResCell) GetMeta 

func (x *ResCell) GetMeta() *ObjectMeta

func (*ResCell) GetNodeNum 

func (x *ResCell) GetNodeNum() int32

func (*ResCell) GetPhase 

func (x *ResCell) GetPhase() uint32

func (*ResCell) GetStatus 

func (x *ResCell) GetStatus() *ResCellStatus

func (*ResCell) GetZoneId 

func (x *ResCell) GetZoneId() string

func (*ResCell) ProtoMessage 

func (*ResCell) ProtoMessage()

func (*ResCell) ProtoReflect 

func (x *ResCell) ProtoReflect() protoreflect.Message

func (*ResCell) Reset 

func (x *ResCell) Reset()

func (*ResCell) String 

func (x *ResCell) String() string

type ResCellStatus 

type ResCellStatus struct {
	Id      string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty" toml:"id,omitempty"`
	Updated uint32 `protobuf:"varint,2,opt,name=updated,proto3" json:"updated,omitempty" toml:"updated,omitempty"`
	CpuCap  int64  `protobuf:"varint,5,opt,name=cpu_cap,json=cpuCap,proto3" json:"cpu_cap,omitempty" toml:"cpu_cap,omitempty"`
	CpuUsed int64  `protobuf:"varint,6,opt,name=cpu_used,json=cpuUsed,proto3" json:"cpu_used,omitempty" toml:"cpu_used,omitempty"`
	MemCap  int64  `protobuf:"varint,7,opt,name=mem_cap,json=memCap,proto3" json:"mem_cap,omitempty" toml:"mem_cap,omitempty"`
	MemUsed int64  `protobuf:"varint,8,opt,name=mem_used,json=memUsed,proto3" json:"mem_used,omitempty" toml:"mem_used,omitempty"`
	HostCap int32  `protobuf:"varint,10,opt,name=host_cap,json=hostCap,proto3" json:"host_cap,omitempty" toml:"host_cap,omitempty"`
	HostIn  int32  `protobuf:"varint,11,opt,name=host_in,json=hostIn,proto3" json:"host_in,omitempty" toml:"host_in,omitempty"`
	VolCap  int32  `protobuf:"varint,12,opt,name=vol_cap,json=volCap,proto3" json:"vol_cap,omitempty" toml:"vol_cap,omitempty"`
	VolUsed int32  `protobuf:"varint,13,opt,name=vol_used,json=volUsed,proto3" json:"vol_used,omitempty" toml:"vol_used,omitempty"`
	// contains filtered or unexported fields
}

func (*ResCellStatus) Descriptor deprecated 

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

Deprecated: Use ResCellStatus.ProtoReflect.Descriptor instead.

func (*ResCellStatus) GetCpuCap 

func (x *ResCellStatus) GetCpuCap() int64

func (*ResCellStatus) GetCpuUsed 

func (x *ResCellStatus) GetCpuUsed() int64

func (*ResCellStatus) GetHostCap 

func (x *ResCellStatus) GetHostCap() int32

func (*ResCellStatus) GetHostIn 

func (x *ResCellStatus) GetHostIn() int32

func (*ResCellStatus) GetId 

func (x *ResCellStatus) GetId() string

func (*ResCellStatus) GetMemCap 

func (x *ResCellStatus) GetMemCap() int64

func (*ResCellStatus) GetMemUsed 

func (x *ResCellStatus) GetMemUsed() int64

func (*ResCellStatus) GetUpdated 

func (x *ResCellStatus) GetUpdated() uint32

func (*ResCellStatus) GetVolCap 

func (x *ResCellStatus) GetVolCap() int32

func (*ResCellStatus) GetVolUsed 

func (x *ResCellStatus) GetVolUsed() int32

func (*ResCellStatus) ProtoMessage 

func (*ResCellStatus) ProtoMessage()

func (*ResCellStatus) ProtoReflect 

func (x *ResCellStatus) ProtoReflect() protoreflect.Message

func (*ResCellStatus) Reset 

func (x *ResCellStatus) Reset()

func (*ResCellStatus) String 

func (x *ResCellStatus) String() string

type ResHost 

type ResHost struct {
	Meta              *ObjectMeta           `protobuf:"bytes,1,opt,name=meta,proto3" json:"meta,omitempty" toml:"meta,omitempty"`
	Operate           *ResHostOperate       `protobuf:"bytes,2,opt,name=operate,proto3" json:"operate,omitempty" toml:"operate,omitempty"`
	Spec              *ResHostSpec          `protobuf:"bytes,3,opt,name=spec,proto3" json:"spec,omitempty" toml:"spec,omitempty"`
	Status            *ResHostStatus        `protobuf:"bytes,4,opt,name=status,proto3" json:"status,omitempty" toml:"status,omitempty"`
	Prs               []*PbPodRepStatus     `protobuf:"bytes,5,rep,name=prs,proto3" json:"prs,omitempty" toml:"prs,omitempty"`
	NetworkMapVersion uint64                `` /* 152-byte string literal not displayed */
	CloudProvider     *ResHostCloudProvider `` /* 132-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ResHost) Descriptor deprecated 

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

Deprecated: Use ResHost.ProtoReflect.Descriptor instead.

func (*ResHost) GetCloudProvider 

func (x *ResHost) GetCloudProvider() *ResHostCloudProvider

func (*ResHost) GetMeta 

func (x *ResHost) GetMeta() *ObjectMeta

func (*ResHost) GetNetworkMapVersion 

func (x *ResHost) GetNetworkMapVersion() uint64

func (*ResHost) GetOperate 

func (x *ResHost) GetOperate() *ResHostOperate

func (*ResHost) GetPrs 

func (x *ResHost) GetPrs() []*PbPodRepStatus

func (*ResHost) GetSpec 

func (x *ResHost) GetSpec() *ResHostSpec

func (*ResHost) GetStatus 

func (x *ResHost) GetStatus() *ResHostStatus

func (*ResHost) OpPortAlloc 

func (obj *ResHost) OpPortAlloc(port uint16) uint16

func (*ResHost) OpPortFree 

func (obj *ResHost) OpPortFree(port uint16)

func (*ResHost) OpPortFreeAll 

func (obj *ResHost) OpPortFreeAll()

func (*ResHost) OpPortHas 

func (obj *ResHost) OpPortHas(port uint16) bool

func (*ResHost) OpPortSort 

func (obj *ResHost) OpPortSort()

func (*ResHost) ProtoMessage 

func (*ResHost) ProtoMessage()

func (*ResHost) ProtoReflect 

func (x *ResHost) ProtoReflect() protoreflect.Message

func (*ResHost) Reset 

func (x *ResHost) Reset()

func (*ResHost) String 

func (x *ResHost) String() string

func (*ResHost) Sync 

func (obj *ResHost) Sync(item ResHost) (changed bool)

func (*ResHost) SyncOpCpu 

func (obj *ResHost) SyncOpCpu(cpu int32)

func (*ResHost) SyncOpMem 

func (obj *ResHost) SyncOpMem(ram int32)

func (*ResHost) SyncStatus 

func (obj *ResHost) SyncStatus(item ResHost) (changed bool)

type ResHostBound 

type ResHostBound struct {
	Masters              *ResZoneMasterList `protobuf:"bytes,2,opt,name=masters,proto3" json:"masters,omitempty" toml:"masters,omitempty"`
	ExpPods              []string           `protobuf:"bytes,5,rep,name=exp_pods,json=expPods,proto3" json:"exp_pods,omitempty" toml:"exp_pods,omitempty"`
	ZoneInpackServiceUrl string             `` /* 166-byte string literal not displayed */
	ExpBoxRemoves        []string           `` /* 135-byte string literal not displayed */
	ExpBoxStops          []string           `` /* 127-byte string literal not displayed */
	ImageServices        []*ResImageService `` /* 133-byte string literal not displayed */
	NetworkDomainName    string             `` /* 152-byte string literal not displayed */
	NetworkVpcBridge     string             `` /* 148-byte string literal not displayed */
	NetworkVpcInstance   string             `` /* 156-byte string literal not displayed */
	ZoneNetworkMap       *ZoneNetworkMap    `` /* 140-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ResHostBound) Descriptor deprecated 

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

Deprecated: Use ResHostBound.ProtoReflect.Descriptor instead.

func (*ResHostBound) GetExpBoxRemoves 

func (x *ResHostBound) GetExpBoxRemoves() []string

func (*ResHostBound) GetExpBoxStops 

func (x *ResHostBound) GetExpBoxStops() []string

func (*ResHostBound) GetExpPods 

func (x *ResHostBound) GetExpPods() []string

func (*ResHostBound) GetImageServices 

func (x *ResHostBound) GetImageServices() []*ResImageService

func (*ResHostBound) GetMasters 

func (x *ResHostBound) GetMasters() *ResZoneMasterList

func (*ResHostBound) GetNetworkDomainName 

func (x *ResHostBound) GetNetworkDomainName() string

func (*ResHostBound) GetNetworkVpcBridge 

func (x *ResHostBound) GetNetworkVpcBridge() string

func (*ResHostBound) GetNetworkVpcInstance 

func (x *ResHostBound) GetNetworkVpcInstance() string

func (*ResHostBound) GetZoneInpackServiceUrl 

func (x *ResHostBound) GetZoneInpackServiceUrl() string

func (*ResHostBound) GetZoneNetworkMap 

func (x *ResHostBound) GetZoneNetworkMap() *ZoneNetworkMap

func (*ResHostBound) ProtoMessage 

func (*ResHostBound) ProtoMessage()

func (*ResHostBound) ProtoReflect 

func (x *ResHostBound) ProtoReflect() protoreflect.Message

func (*ResHostBound) Reset 

func (x *ResHostBound) Reset()

func (*ResHostBound) String 

func (x *ResHostBound) String() string

type ResHostCloudProvider 

type ResHostCloudProvider struct {
	InstanceId   string `protobuf:"bytes,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty" toml:"instance_id,omitempty"`
	InstanceName string `` /* 128-byte string literal not displayed */
	PrivateIp    string `protobuf:"bytes,3,opt,name=private_ip,json=privateIp,proto3" json:"private_ip,omitempty" toml:"private_ip,omitempty"`
	RawJson      string `protobuf:"bytes,15,opt,name=raw_json,json=rawJson,proto3" json:"raw_json,omitempty" toml:"raw_json,omitempty"`
	// contains filtered or unexported fields
}

func (*ResHostCloudProvider) Descriptor deprecated 

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

Deprecated: Use ResHostCloudProvider.ProtoReflect.Descriptor instead.

func (*ResHostCloudProvider) GetInstanceId 

func (x *ResHostCloudProvider) GetInstanceId() string

func (*ResHostCloudProvider) GetInstanceName 

func (x *ResHostCloudProvider) GetInstanceName() string

func (*ResHostCloudProvider) GetPrivateIp 

func (x *ResHostCloudProvider) GetPrivateIp() string

func (*ResHostCloudProvider) GetRawJson 

func (x *ResHostCloudProvider) GetRawJson() string

func (*ResHostCloudProvider) ProtoMessage 

func (*ResHostCloudProvider) ProtoMessage()

func (*ResHostCloudProvider) ProtoReflect 

func (x *ResHostCloudProvider) ProtoReflect() protoreflect.Message

func (*ResHostCloudProvider) Reset 

func (x *ResHostCloudProvider) Reset()

func (*ResHostCloudProvider) String 

func (x *ResHostCloudProvider) String() string

type ResHostCloudProviderSyncEntry 

type ResHostCloudProviderSyncEntry struct {
	InstanceId    string                `protobuf:"bytes,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty" toml:"instance_id,omitempty"`
	InstanceName  string                `` /* 128-byte string literal not displayed */
	CloudProvider *ResHostCloudProvider `` /* 132-byte string literal not displayed */
	Action        uint64                `protobuf:"varint,8,opt,name=action,proto3" json:"action,omitempty" toml:"action,omitempty"`
	ZoneId        string                `protobuf:"bytes,9,opt,name=zone_id,json=zoneId,proto3" json:"zone_id,omitempty" toml:"zone_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ResHostCloudProviderSyncEntry) Descriptor deprecated 

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

Deprecated: Use ResHostCloudProviderSyncEntry.ProtoReflect.Descriptor instead.

func (*ResHostCloudProviderSyncEntry) GetAction 

func (x *ResHostCloudProviderSyncEntry) GetAction() uint64

func (*ResHostCloudProviderSyncEntry) GetCloudProvider 

func (x *ResHostCloudProviderSyncEntry) GetCloudProvider() *ResHostCloudProvider

func (*ResHostCloudProviderSyncEntry) GetInstanceId 

func (x *ResHostCloudProviderSyncEntry) GetInstanceId() string

func (*ResHostCloudProviderSyncEntry) GetInstanceName 

func (x *ResHostCloudProviderSyncEntry) GetInstanceName() string

func (*ResHostCloudProviderSyncEntry) GetZoneId 

func (x *ResHostCloudProviderSyncEntry) GetZoneId() string

func (*ResHostCloudProviderSyncEntry) ProtoMessage 

func (*ResHostCloudProviderSyncEntry) ProtoMessage()

func (*ResHostCloudProviderSyncEntry) ProtoReflect 

func (x *ResHostCloudProviderSyncEntry) ProtoReflect() protoreflect.Message

func (*ResHostCloudProviderSyncEntry) Reset 

func (x *ResHostCloudProviderSyncEntry) Reset()

func (*ResHostCloudProviderSyncEntry) String 

func (x *ResHostCloudProviderSyncEntry) String() string

type ResHostList 

type ResHostList struct {
	Items []*ResHost `protobuf:"bytes,2,rep,name=items,proto3" json:"items,omitempty" toml:"items,omitempty"`
	// contains filtered or unexported fields
}

func (*ResHostList) Del 

func (ls *ResHostList) Del(id string)

func (*ResHostList) Descriptor deprecated 

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

Deprecated: Use ResHostList.ProtoReflect.Descriptor instead.

func (*ResHostList) GetItems 

func (x *ResHostList) GetItems() []*ResHost

func (*ResHostList) Item 

func (ls *ResHostList) Item(id string) *ResHost

ResHostList

func (*ResHostList) ProtoMessage 

func (*ResHostList) ProtoMessage()

func (*ResHostList) ProtoReflect 

func (x *ResHostList) ProtoReflect() protoreflect.Message

func (*ResHostList) Reset 

func (x *ResHostList) Reset()

func (*ResHostList) String 

func (x *ResHostList) String() string

func (*ResHostList) Sync 

func (ls *ResHostList) Sync(item ResHost) (changed bool)

type ResHostNew 

type ResHostNew struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty" toml:"name,omitempty"`
	Action               uint32   `protobuf:"varint,2,opt,name=action,proto3" json:"action,omitempty" toml:"action,omitempty"`
	ZoneId               string   `protobuf:"bytes,3,opt,name=zone_id,json=zoneId,proto3" json:"zone_id,omitempty" toml:"zone_id,omitempty"`
	CellId               string   `protobuf:"bytes,4,opt,name=cell_id,json=cellId,proto3" json:"cell_id,omitempty" toml:"cell_id,omitempty"`
	PeerLanAddr          string   `` /* 127-byte string literal not displayed */
	SecretKey            string   `protobuf:"bytes,6,opt,name=secret_key,json=secretKey,proto3" json:"secret_key,omitempty" toml:"secret_key,omitempty"`
	ZoneMasters          []string `protobuf:"bytes,7,rep,name=zone_masters,json=zoneMasters,proto3" json:"zone_masters,omitempty" toml:"zone_masters,omitempty"`
	ZoneIamServiceUrl    string   `` /* 154-byte string literal not displayed */
	ZoneInpackServiceUrl string   `` /* 166-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ResHostNew) Descriptor deprecated 

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

Deprecated: Use ResHostNew.ProtoReflect.Descriptor instead.

func (*ResHostNew) GetAction 

func (x *ResHostNew) GetAction() uint32

func (*ResHostNew) GetCellId 

func (x *ResHostNew) GetCellId() string

func (*ResHostNew) GetName 

func (x *ResHostNew) GetName() string

func (*ResHostNew) GetPeerLanAddr 

func (x *ResHostNew) GetPeerLanAddr() string

func (*ResHostNew) GetSecretKey 

func (x *ResHostNew) GetSecretKey() string

func (*ResHostNew) GetZoneIamServiceUrl 

func (x *ResHostNew) GetZoneIamServiceUrl() string

func (*ResHostNew) GetZoneId 

func (x *ResHostNew) GetZoneId() string

func (*ResHostNew) GetZoneInpackServiceUrl 

func (x *ResHostNew) GetZoneInpackServiceUrl() string

func (*ResHostNew) GetZoneMasters 

func (x *ResHostNew) GetZoneMasters() []string

func (*ResHostNew) ProtoMessage 

func (*ResHostNew) ProtoMessage()

func (*ResHostNew) ProtoReflect 

func (x *ResHostNew) ProtoReflect() protoreflect.Message

func (*ResHostNew) Reset 

func (x *ResHostNew) Reset()

func (*ResHostNew) String 

func (x *ResHostNew) String() string

type ResHostOperate 

type ResHostOperate struct {
	Action             uint32         `protobuf:"varint,1,opt,name=action,proto3" json:"action,omitempty" toml:"action,omitempty"`
	CellId             string         `protobuf:"bytes,2,opt,name=cell_id,json=cellId,proto3" json:"cell_id,omitempty" toml:"cell_id,omitempty"`
	ZoneId             string         `protobuf:"bytes,3,opt,name=zone_id,json=zoneId,proto3" json:"zone_id,omitempty" toml:"zone_id,omitempty"`
	CpuUsed            int32          `protobuf:"varint,4,opt,name=cpu_used,json=cpuUsed,proto3" json:"cpu_used,omitempty" toml:"cpu_used,omitempty"` // 10m
	MemUsed            int64          `protobuf:"varint,5,opt,name=mem_used,json=memUsed,proto3" json:"mem_used,omitempty" toml:"mem_used,omitempty"` // MB
	VolUsed            []*ResVolValue `protobuf:"bytes,6,rep,name=vol_used,json=volUsed,proto3" json:"vol_used,omitempty" toml:"vol_used,omitempty"`
	PortUsed           []uint32       `protobuf:"varint,7,rep,packed,name=port_used,json=portUsed,proto3" json:"port_used,omitempty" toml:"port_used,omitempty"`
	BoxNum             int32          `protobuf:"varint,8,opt,name=box_num,json=boxNum,proto3" json:"box_num,omitempty" toml:"box_num,omitempty"`
	Pr                 uint32         `protobuf:"varint,9,opt,name=pr,proto3" json:"pr,omitempty" toml:"pr,omitempty"` // Priority
	NetworkVpcBridge   string         ``                                                                               /* 148-byte string literal not displayed */
	NetworkVpcInstance string         ``                                                                               /* 156-byte string literal not displayed */
	Groups             []string       `protobuf:"bytes,12,rep,name=groups,proto3" json:"groups,omitempty" toml:"groups,omitempty"`
	SecretKey          string         `protobuf:"bytes,13,opt,name=secret_key,json=secretKey,proto3" json:"secret_key,omitempty" toml:"secret_key,omitempty"`
	// contains filtered or unexported fields
}

host

func (*ResHostOperate) Descriptor deprecated 

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

Deprecated: Use ResHostOperate.ProtoReflect.Descriptor instead.

func (*ResHostOperate) GetAction 

func (x *ResHostOperate) GetAction() uint32

func (*ResHostOperate) GetBoxNum 

func (x *ResHostOperate) GetBoxNum() int32

func (*ResHostOperate) GetCellId 

func (x *ResHostOperate) GetCellId() string

func (*ResHostOperate) GetCpuUsed 

func (x *ResHostOperate) GetCpuUsed() int32

func (*ResHostOperate) GetGroups 

func (x *ResHostOperate) GetGroups() []string

func (*ResHostOperate) GetMemUsed 

func (x *ResHostOperate) GetMemUsed() int64

func (*ResHostOperate) GetNetworkVpcBridge 

func (x *ResHostOperate) GetNetworkVpcBridge() string

func (*ResHostOperate) GetNetworkVpcInstance 

func (x *ResHostOperate) GetNetworkVpcInstance() string

func (*ResHostOperate) GetPortUsed 

func (x *ResHostOperate) GetPortUsed() []uint32

func (*ResHostOperate) GetPr 

func (x *ResHostOperate) GetPr() uint32

func (*ResHostOperate) GetSecretKey 

func (x *ResHostOperate) GetSecretKey() string

func (*ResHostOperate) GetVolUsed 

func (x *ResHostOperate) GetVolUsed() []*ResVolValue

func (*ResHostOperate) GetZoneId 

func (x *ResHostOperate) GetZoneId() string

func (*ResHostOperate) ProtoMessage 

func (*ResHostOperate) ProtoMessage()

func (*ResHostOperate) ProtoReflect 

func (x *ResHostOperate) ProtoReflect() protoreflect.Message

func (*ResHostOperate) Reset 

func (x *ResHostOperate) Reset()

func (*ResHostOperate) String 

func (x *ResHostOperate) String() string

type ResHostResource 

type ResHostResource struct {
	Mem  int64          `protobuf:"varint,1,opt,name=mem,proto3" json:"mem,omitempty" toml:"mem,omitempty"`
	Cpu  int32          `protobuf:"varint,2,opt,name=cpu,proto3" json:"cpu,omitempty" toml:"cpu,omitempty"`
	Vols []*ResVolValue `protobuf:"bytes,3,rep,name=vols,proto3" json:"vols,omitempty" toml:"vols,omitempty"`
	// contains filtered or unexported fields
}

func (*ResHostResource) Descriptor deprecated 

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

Deprecated: Use ResHostResource.ProtoReflect.Descriptor instead.

func (*ResHostResource) GetCpu 

func (x *ResHostResource) GetCpu() int32

func (*ResHostResource) GetMem 

func (x *ResHostResource) GetMem() int64

func (*ResHostResource) GetVols 

func (x *ResHostResource) GetVols() []*ResVolValue

func (*ResHostResource) ProtoMessage 

func (*ResHostResource) ProtoMessage()

func (*ResHostResource) ProtoReflect 

func (x *ResHostResource) ProtoReflect() protoreflect.Message

func (*ResHostResource) Reset 

func (x *ResHostResource) Reset()

func (*ResHostResource) String 

func (x *ResHostResource) String() string

type ResHostSpec 

type ResHostSpec struct {
	Platform         *ResPlatform     `protobuf:"bytes,2,opt,name=platform,proto3" json:"platform,omitempty" toml:"platform,omitempty"`
	Capacity         *ResHostResource `protobuf:"bytes,3,opt,name=capacity,proto3" json:"capacity,omitempty" toml:"capacity,omitempty"`
	HttpPort         uint32           `protobuf:"varint,5,opt,name=http_port,json=httpPort,proto3" json:"http_port,omitempty" toml:"http_port,omitempty"`
	PeerLanAddr      string           `` /* 127-byte string literal not displayed */
	PeerWanAddr      string           `` /* 127-byte string literal not displayed */
	ExpDockerVersion string           `` /* 148-byte string literal not displayed */
	ExpRktVersion    string           `` /* 136-byte string literal not displayed */
	ExpPouchVersion  string           `` /* 144-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ResHostSpec) Descriptor deprecated 

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

Deprecated: Use ResHostSpec.ProtoReflect.Descriptor instead.

func (*ResHostSpec) GetCapacity 

func (x *ResHostSpec) GetCapacity() *ResHostResource

func (*ResHostSpec) GetExpDockerVersion 

func (x *ResHostSpec) GetExpDockerVersion() string

func (*ResHostSpec) GetExpPouchVersion 

func (x *ResHostSpec) GetExpPouchVersion() string

func (*ResHostSpec) GetExpRktVersion 

func (x *ResHostSpec) GetExpRktVersion() string

func (*ResHostSpec) GetHttpPort 

func (x *ResHostSpec) GetHttpPort() uint32

func (*ResHostSpec) GetPeerLanAddr 

func (x *ResHostSpec) GetPeerLanAddr() string

func (*ResHostSpec) GetPeerWanAddr 

func (x *ResHostSpec) GetPeerWanAddr() string

func (*ResHostSpec) GetPlatform 

func (x *ResHostSpec) GetPlatform() *ResPlatform

func (*ResHostSpec) ProtoMessage 

func (*ResHostSpec) ProtoMessage()

func (*ResHostSpec) ProtoReflect 

func (x *ResHostSpec) ProtoReflect() protoreflect.Message

func (*ResHostSpec) Reset 

func (x *ResHostSpec) Reset()

func (*ResHostSpec) String 

func (x *ResHostSpec) String() string

type ResHostStatus 

type ResHostStatus struct {
	Phase   string             `protobuf:"bytes,1,opt,name=phase,proto3" json:"phase,omitempty" toml:"phase,omitempty"`
	Uptime  uint32             `protobuf:"varint,2,opt,name=uptime,proto3" json:"uptime,omitempty" toml:"uptime,omitempty"`
	Volumes []*ResHostVolume   `protobuf:"bytes,3,rep,name=volumes,proto3" json:"volumes,omitempty" toml:"volumes,omitempty"`
	Stats   *PbStatsSampleFeed `protobuf:"bytes,4,opt,name=stats,proto3" json:"stats,omitempty" toml:"stats,omitempty"`
	Updated uint32             `protobuf:"varint,5,opt,name=updated,proto3" json:"updated,omitempty" toml:"updated,omitempty"`
	// contains filtered or unexported fields
}

func (*ResHostStatus) Descriptor deprecated 

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

Deprecated: Use ResHostStatus.ProtoReflect.Descriptor instead.

func (*ResHostStatus) GetPhase 

func (x *ResHostStatus) GetPhase() string

func (*ResHostStatus) GetStats 

func (x *ResHostStatus) GetStats() *PbStatsSampleFeed

func (*ResHostStatus) GetUpdated 

func (x *ResHostStatus) GetUpdated() uint32

func (*ResHostStatus) GetUptime 

func (x *ResHostStatus) GetUptime() uint32

func (*ResHostStatus) GetVolumes 

func (x *ResHostStatus) GetVolumes() []*ResHostVolume

func (*ResHostStatus) ProtoMessage 

func (*ResHostStatus) ProtoMessage()

func (*ResHostStatus) ProtoReflect 

func (x *ResHostStatus) ProtoReflect() protoreflect.Message

func (*ResHostStatus) Reset 

func (x *ResHostStatus) Reset()

func (*ResHostStatus) String 

func (x *ResHostStatus) String() string

type ResHostVolume 

type ResHostVolume struct {
	Name  string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty" toml:"name,omitempty"`
	Total uint64 `protobuf:"varint,2,opt,name=total,proto3" json:"total,omitempty" toml:"total,omitempty"`
	Used  uint64 `protobuf:"varint,3,opt,name=used,proto3" json:"used,omitempty" toml:"used,omitempty"`
	// contains filtered or unexported fields
}

func (*ResHostVolume) Descriptor deprecated 

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

Deprecated: Use ResHostVolume.ProtoReflect.Descriptor instead.

func (*ResHostVolume) GetName 

func (x *ResHostVolume) GetName() string

func (*ResHostVolume) GetTotal 

func (x *ResHostVolume) GetTotal() uint64

func (*ResHostVolume) GetUsed 

func (x *ResHostVolume) GetUsed() uint64

func (*ResHostVolume) ProtoMessage 

func (*ResHostVolume) ProtoMessage()

func (*ResHostVolume) ProtoReflect 

func (x *ResHostVolume) ProtoReflect() protoreflect.Message

func (*ResHostVolume) Reset 

func (x *ResHostVolume) Reset()

func (*ResHostVolume) String 

func (x *ResHostVolume) String() string

type ResImageService 

type ResImageService struct {
	Driver string `protobuf:"bytes,1,opt,name=driver,proto3" json:"driver,omitempty" toml:"driver,omitempty"`
	Url    string `protobuf:"bytes,2,opt,name=url,proto3" json:"url,omitempty" toml:"url,omitempty"` // struct:object_slice_key
	// contains filtered or unexported fields
}

image

func ResImageServiceSliceDel 

func ResImageServiceSliceDel(ls []*ResImageService, arg_url string) ([]*ResImageService, bool)

func ResImageServiceSliceGet 

func ResImageServiceSliceGet(ls []*ResImageService, arg_url string) *ResImageService

func ResImageServiceSliceSync 

func ResImageServiceSliceSync(ls []*ResImageService, it2 *ResImageService) ([]*ResImageService, bool)

func ResImageServiceSliceSyncSlice 

func ResImageServiceSliceSyncSlice(ls, ls2 []*ResImageService) ([]*ResImageService, bool)

func (*ResImageService) Descriptor deprecated 

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

Deprecated: Use ResImageService.ProtoReflect.Descriptor instead.

func (*ResImageService) Equal 

func (it *ResImageService) Equal(it2 *ResImageService) bool

func (*ResImageService) GetDriver 

func (x *ResImageService) GetDriver() string

func (*ResImageService) GetUrl 

func (x *ResImageService) GetUrl() string

func (*ResImageService) ProtoMessage 

func (*ResImageService) ProtoMessage()

func (*ResImageService) ProtoReflect 

func (x *ResImageService) ProtoReflect() protoreflect.Message

func (*ResImageService) Reset 

func (x *ResImageService) Reset()

func (*ResImageService) String 

func (x *ResImageService) String() string

func (*ResImageService) Sync 

func (it *ResImageService) Sync(it2 *ResImageService) bool

type ResOperate 

type ResOperate struct {
	AppId string `json:"app_id,omitempty" toml:"app_id,omitempty"`
}

type ResPlatform 

type ResPlatform struct {
	Os     string `protobuf:"bytes,1,opt,name=os,proto3" json:"os,omitempty" toml:"os,omitempty"`
	Kernel string `protobuf:"bytes,2,opt,name=kernel,proto3" json:"kernel,omitempty" toml:"kernel,omitempty"`
	Arch   string `protobuf:"bytes,3,opt,name=arch,proto3" json:"arch,omitempty" toml:"arch,omitempty"`
	// contains filtered or unexported fields
}

func (*ResPlatform) Descriptor deprecated 

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

Deprecated: Use ResPlatform.ProtoReflect.Descriptor instead.

func (*ResPlatform) GetArch 

func (x *ResPlatform) GetArch() string

func (*ResPlatform) GetKernel 

func (x *ResPlatform) GetKernel() string

func (*ResPlatform) GetOs 

func (x *ResPlatform) GetOs() string

func (*ResPlatform) ProtoMessage 

func (*ResPlatform) ProtoMessage()

func (*ResPlatform) ProtoReflect 

func (x *ResPlatform) ProtoReflect() protoreflect.Message

func (*ResPlatform) Reset 

func (x *ResPlatform) Reset()

func (*ResPlatform) String 

func (x *ResPlatform) String() string

type ResVolBound 

type ResVolBound struct {
	RefId   string `protobuf:"bytes,1,opt,name=ref_id,json=refId,proto3" json:"ref_id,omitempty" toml:"ref_id,omitempty"`
	RefName string `protobuf:"bytes,2,opt,name=ref_name,json=refName,proto3" json:"ref_name,omitempty" toml:"ref_name,omitempty"`
	Mnt     string `protobuf:"bytes,4,opt,name=mnt,proto3" json:"mnt,omitempty" toml:"mnt,omitempty"`
	Size    int32  `protobuf:"varint,5,opt,name=size,proto3" json:"size,omitempty" toml:"size,omitempty"`
	Attrs   uint32 `protobuf:"varint,6,opt,name=attrs,proto3" json:"attrs,omitempty" toml:"attrs,omitempty"`
	// contains filtered or unexported fields
}

func (*ResVolBound) Descriptor deprecated 

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

Deprecated: Use ResVolBound.ProtoReflect.Descriptor instead.

func (*ResVolBound) GetAttrs 

func (x *ResVolBound) GetAttrs() uint32

func (*ResVolBound) GetMnt 

func (x *ResVolBound) GetMnt() string

func (*ResVolBound) GetRefId 

func (x *ResVolBound) GetRefId() string

func (*ResVolBound) GetRefName 

func (x *ResVolBound) GetRefName() string

func (*ResVolBound) GetSize 

func (x *ResVolBound) GetSize() int32

func (*ResVolBound) ProtoMessage 

func (*ResVolBound) ProtoMessage()

func (*ResVolBound) ProtoReflect 

func (x *ResVolBound) ProtoReflect() protoreflect.Message

func (*ResVolBound) Reset 

func (x *ResVolBound) Reset()

func (*ResVolBound) String 

func (x *ResVolBound) String() string

type ResVolValue 

type ResVolValue struct {
	Name  string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty" toml:"name,omitempty"`     // struct:object_slice_key
	Value int32  `protobuf:"varint,2,opt,name=value,proto3" json:"value,omitempty" toml:"value,omitempty"` // GB
	Attrs uint32 `protobuf:"varint,3,opt,name=attrs,proto3" json:"attrs,omitempty" toml:"attrs,omitempty"`
	// contains filtered or unexported fields
}

volume

func ResVolValueSliceDel 

func ResVolValueSliceDel(ls []*ResVolValue, arg_name string) ([]*ResVolValue, bool)

func ResVolValueSliceGet 

func ResVolValueSliceGet(ls []*ResVolValue, arg_name string) *ResVolValue

func ResVolValueSliceSync 

func ResVolValueSliceSync(ls []*ResVolValue, it2 *ResVolValue) ([]*ResVolValue, bool)

func ResVolValueSliceSyncSlice 

func ResVolValueSliceSyncSlice(ls, ls2 []*ResVolValue) ([]*ResVolValue, bool)

func (*ResVolValue) Descriptor deprecated 

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

Deprecated: Use ResVolValue.ProtoReflect.Descriptor instead.

func (*ResVolValue) Equal 

func (it *ResVolValue) Equal(it2 *ResVolValue) bool

func (*ResVolValue) GetAttrs 

func (x *ResVolValue) GetAttrs() uint32

func (*ResVolValue) GetName 

func (x *ResVolValue) GetName() string

func (*ResVolValue) GetValue 

func (x *ResVolValue) GetValue() int32

func (*ResVolValue) ProtoMessage 

func (*ResVolValue) ProtoMessage()

func (*ResVolValue) ProtoReflect 

func (x *ResVolValue) ProtoReflect() protoreflect.Message

func (*ResVolValue) Reset 

func (x *ResVolValue) Reset()

func (*ResVolValue) String 

func (x *ResVolValue) String() string

func (*ResVolValue) Sync 

func (it *ResVolValue) Sync(it2 *ResVolValue) bool

type ResZone 

type ResZone struct {
	Meta               *ObjectMeta        `protobuf:"bytes,2,opt,name=meta,proto3" json:"meta,omitempty" toml:"meta,omitempty"`
	Phase              uint32             `protobuf:"varint,3,opt,name=phase,proto3" json:"phase,omitempty" toml:"phase,omitempty"`
	Summary            string             `protobuf:"bytes,4,opt,name=summary,proto3" json:"summary,omitempty" toml:"summary,omitempty"`
	WanAddrs           []string           `protobuf:"bytes,5,rep,name=wan_addrs,json=wanAddrs,proto3" json:"wan_addrs,omitempty" toml:"wan_addrs,omitempty"`
	LanAddrs           []string           `protobuf:"bytes,6,rep,name=lan_addrs,json=lanAddrs,proto3" json:"lan_addrs,omitempty" toml:"lan_addrs,omitempty"`
	Cells              []*ResCell         `protobuf:"bytes,7,rep,name=cells,proto3" json:"cells,omitempty" toml:"cells,omitempty"`
	Options            []*Label           `protobuf:"bytes,8,rep,name=options,proto3" json:"options,omitempty" toml:"options,omitempty"`
	WanApi             string             `protobuf:"bytes,9,opt,name=wan_api,json=wanApi,proto3" json:"wan_api,omitempty" toml:"wan_api,omitempty"`
	ImageServices      []*ResImageService `` /* 133-byte string literal not displayed */
	NetworkDomainName  string             `` /* 152-byte string literal not displayed */
	NetworkVpcBridge   string             `` /* 148-byte string literal not displayed */
	NetworkVpcInstance string             `` /* 156-byte string literal not displayed */
	Driver             *ConfigInstance    `protobuf:"bytes,14,opt,name=driver,proto3" json:"driver,omitempty" toml:"driver,omitempty"`
	Groups             []*ZoneGroupSpec   `protobuf:"bytes,15,rep,name=groups,proto3" json:"groups,omitempty" toml:"groups,omitempty"`
	// contains filtered or unexported fields
}

func (*ResZone) Cell 

func (obj *ResZone) Cell(id string) *ResCell

func (*ResZone) CellSync 

func (obj *ResZone) CellSync(item *ResCell) (*ResCell, bool)

func (*ResZone) Descriptor deprecated 

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

Deprecated: Use ResZone.ProtoReflect.Descriptor instead.

func (*ResZone) GetCells 

func (x *ResZone) GetCells() []*ResCell

func (*ResZone) GetDriver 

func (x *ResZone) GetDriver() *ConfigInstance

func (*ResZone) GetGroups 

func (x *ResZone) GetGroups() []*ZoneGroupSpec

func (*ResZone) GetImageServices 

func (x *ResZone) GetImageServices() []*ResImageService

func (*ResZone) GetLanAddrs 

func (x *ResZone) GetLanAddrs() []string

func (*ResZone) GetMeta 

func (x *ResZone) GetMeta() *ObjectMeta

func (*ResZone) GetNetworkDomainName 

func (x *ResZone) GetNetworkDomainName() string

func (*ResZone) GetNetworkVpcBridge 

func (x *ResZone) GetNetworkVpcBridge() string

func (*ResZone) GetNetworkVpcInstance 

func (x *ResZone) GetNetworkVpcInstance() string

func (*ResZone) GetOptions 

func (x *ResZone) GetOptions() []*Label

func (*ResZone) GetPhase 

func (x *ResZone) GetPhase() uint32

func (*ResZone) GetSummary 

func (x *ResZone) GetSummary() string

func (*ResZone) GetWanAddrs 

func (x *ResZone) GetWanAddrs() []string

func (*ResZone) GetWanApi 

func (x *ResZone) GetWanApi() string

func (*ResZone) OptionDel 

func (ls *ResZone) OptionDel(name string)

Del remove the res_label entry (if any) for "name".

func (*ResZone) OptionGet 

func (ls *ResZone) OptionGet(name string) (string, bool)

Get fetch the res_label entry "value" (if any) for "name".

func (*ResZone) OptionSet 

func (ls *ResZone) OptionSet(name string, value interface{}) error

Set create or update the res_label entry for "name" to "value".

func (*ResZone) ProtoMessage 

func (*ResZone) ProtoMessage()

func (*ResZone) ProtoReflect 

func (x *ResZone) ProtoReflect() protoreflect.Message

func (*ResZone) Reset 

func (x *ResZone) Reset()

func (*ResZone) String 

func (x *ResZone) String() string

type ResZoneMasterList 

type ResZoneMasterList struct {
	Version uint64               `protobuf:"varint,1,opt,name=version,proto3" json:"version,omitempty" toml:"version,omitempty"`
	Leader  string               `protobuf:"bytes,2,opt,name=leader,proto3" json:"leader,omitempty" toml:"leader,omitempty"`
	Updated uint64               `protobuf:"varint,3,opt,name=updated,proto3" json:"updated,omitempty" toml:"updated,omitempty"`
	Items   []*ResZoneMasterNode `protobuf:"bytes,4,rep,name=items,proto3" json:"items,omitempty" toml:"items,omitempty"`
	// contains filtered or unexported fields
}

func (*ResZoneMasterList) Descriptor deprecated 

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

Deprecated: Use ResZoneMasterList.ProtoReflect.Descriptor instead.

func (*ResZoneMasterList) GetItems 

func (x *ResZoneMasterList) GetItems() []*ResZoneMasterNode

func (*ResZoneMasterList) GetLeader 

func (x *ResZoneMasterList) GetLeader() string

func (*ResZoneMasterList) GetUpdated 

func (x *ResZoneMasterList) GetUpdated() uint64

func (*ResZoneMasterList) GetVersion 

func (x *ResZoneMasterList) GetVersion() uint64

func (*ResZoneMasterList) Item 

func (obj *ResZoneMasterList) Item(id string) *ResZoneMasterNode

func (*ResZoneMasterList) LeaderAddr 

func (obj *ResZoneMasterList) LeaderAddr() string

func (*ResZoneMasterList) ProtoMessage 

func (*ResZoneMasterList) ProtoMessage()

func (*ResZoneMasterList) ProtoReflect 

func (x *ResZoneMasterList) ProtoReflect() protoreflect.Message

func (*ResZoneMasterList) Reset 

func (x *ResZoneMasterList) Reset()

func (*ResZoneMasterList) String 

func (x *ResZoneMasterList) String() string

func (*ResZoneMasterList) Sync 

func (obj *ResZoneMasterList) Sync(item ResZoneMasterNode) (changed bool)

func (*ResZoneMasterList) SyncList 

func (obj *ResZoneMasterList) SyncList(ls *ResZoneMasterList) (changed bool)

type ResZoneMasterNode 

type ResZoneMasterNode struct {
	Id     string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty" toml:"id,omitempty"`
	Addr   string `protobuf:"bytes,2,opt,name=addr,proto3" json:"addr,omitempty" toml:"addr,omitempty"`
	Action uint32 `protobuf:"varint,3,opt,name=action,proto3" json:"action,omitempty" toml:"action,omitempty"`
	// contains filtered or unexported fields
}

func (*ResZoneMasterNode) Descriptor deprecated 

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

Deprecated: Use ResZoneMasterNode.ProtoReflect.Descriptor instead.

func (*ResZoneMasterNode) GetAction 

func (x *ResZoneMasterNode) GetAction() uint32

func (*ResZoneMasterNode) GetAddr 

func (x *ResZoneMasterNode) GetAddr() string

func (*ResZoneMasterNode) GetId 

func (x *ResZoneMasterNode) GetId() string

func (*ResZoneMasterNode) ProtoMessage 

func (*ResZoneMasterNode) ProtoMessage()

func (*ResZoneMasterNode) ProtoReflect 

func (x *ResZoneMasterNode) ProtoReflect() protoreflect.Message

func (*ResZoneMasterNode) Reset 

func (x *ResZoneMasterNode) Reset()

func (*ResZoneMasterNode) String 

func (x *ResZoneMasterNode) String() string

type Resource 

type Resource struct {
	types.TypeMeta `json:",inline" toml:",inline"`
	Meta           types.InnerObjectMeta `json:"meta,omitempty" toml:"meta,omitempty"`
	Description    string                `json:"description,omitempty" toml:"description,omitempty"`
	Operate        ResOperate            `json:"operate,omitempty" toml:"operate,omitempty"`
	Bounds         ResourceBounds        `json:"bounds,omitempty" toml:"bounds,omitempty"`
	Options        types.Labels          `json:"options,omitempty" toml:"options,omitempty"`
	Action         types.StringArray     `json:"action,omitempty" toml:"action,omitempty"`
	Updated        uint64                `json:"updated,omitempty" toml:"updated,omitempty"`
}

type ResourceBound 

type ResourceBound struct {
	Name   string `json:"name" toml:"name"`
	Value  string `json:"value,omitempty" toml:"value,omitempty"`
	Action uint8  `json:"action,omitempty" toml:"action,omitempty"`
}

type ResourceBounds 

type ResourceBounds []*ResourceBound

func (*ResourceBounds) Del 

func (ls *ResourceBounds) Del(name string)

func (*ResourceBounds) Equal 

func (ls *ResourceBounds) Equal(items ResourceBounds) bool

func (ResourceBounds) Get 

func (ls ResourceBounds) Get(name string) *ResourceBound

func (*ResourceBounds) Sync 

func (ls *ResourceBounds) Sync(item ResourceBound) (changed bool, err error)

type ResourceList 

type ResourceList struct {
	types.TypeMeta `json:",inline" toml:",inline"`
	Items          []Resource `json:"items,omitempty" toml:"items,omitempty"`
}

type ServicePort 

type ServicePort struct {
	// Optional: If specified, this must be a DNS_LABEL.  Each named port
	// in a pod must have a unique name.
	Name string `json:"name,omitempty" toml:"name,omitempty"`
	// Required: This must be a valid port number, 0 < x < 65536.
	BoxPort uint16 `json:"box_port" toml:"box_port"`
	// Optional: If specified, this must be a valid port number, 0 < x < 65536.
	HostPort uint16 `json:"host_port,omitempty" toml:"host_port,omitempty"`
	// Optional
	LanAddr string `json:"lan_addr,omitempty" toml:"lan_addr,omitempty"`
	// Optional
	WanAddr string `json:"wan_addr,omitempty" toml:"wan_addr,omitempty"`
	// Optional
	AppSpec string `json:"app_spec,omitempty" toml:"app_spec,omitempty"`
}

ServicePort represents a network port in a single box(container)

type ServicePorts 

type ServicePorts []*ServicePort

func (*ServicePorts) Clean 

func (ls *ServicePorts) Clean()

func (*ServicePorts) Del 

func (ls *ServicePorts) Del(box_port uint16)

func (*ServicePorts) Equal 

func (ls *ServicePorts) Equal(items ServicePorts) bool

func (*ServicePorts) Get 

func (ls *ServicePorts) Get(box_port uint16) *ServicePort

func (*ServicePorts) Sync 

func (ls *ServicePorts) Sync(item ServicePort) (changed bool)

type ServiceReply 

type ServiceReply struct {
	Kind string `protobuf:"bytes,1,opt,name=kind,proto3" json:"kind,omitempty" toml:"kind,omitempty"`
	// contains filtered or unexported fields
}

func (*ServiceReply) Descriptor deprecated 

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

Deprecated: Use ServiceReply.ProtoReflect.Descriptor instead.

func (*ServiceReply) GetKind 

func (x *ServiceReply) GetKind() string

func (*ServiceReply) ProtoMessage 

func (*ServiceReply) ProtoMessage()

func (*ServiceReply) ProtoReflect 

func (x *ServiceReply) ProtoReflect() protoreflect.Message

func (*ServiceReply) Reset 

func (x *ServiceReply) Reset()

func (*ServiceReply) String 

func (x *ServiceReply) String() string

type SpecExecutor 

type SpecExecutor struct {
	types.TypeMeta `json:",inline" toml:",inline"`
	Meta           types.InnerObjectMeta `json:"meta" toml:"meta"`
	Description    string                `json:"description,omitempty" toml:"description,omitempty"`
	Labels         types.Labels          `json:"labels,omitempty" toml:"labels,omitempty"`
	Executor       Executor              `json:"executor,omitempty" toml:"executor,omitempty"`
	Priority       uint8                 `json:"priority,omitempty" toml:"priority,omitempty"`
}

type SpecExecutorList 

type SpecExecutorList struct {
	types.TypeMeta `json:",inline" toml:",inline"`
	Items          []SpecExecutor `json:"items,omitempty" toml:"items,omitempty"`
}

type SysConfigGroup 

type SysConfigGroup struct {
	Name    string       `json:"name" toml:"name"`
	Items   types.Labels `json:"items,omitempty" toml:"items,omitempty"`
	Updated uint32       `json:"updated,omitempty" toml:"updated,omitempty"`
}

type SysConfigGroupList 

type SysConfigGroupList struct {
	types.TypeMeta `json:",inline" toml:",inline"`
	Items          []*SysConfigGroup `json:"items,omitempty" toml:"items,omitempty"`
}

func (*SysConfigGroupList) Get 

func (ls *SysConfigGroupList) Get(name string) *SysConfigGroup

func (*SysConfigGroupList) Sync 

func (ls *SysConfigGroupList) Sync(vn *SysConfigGroup)

func (*SysConfigGroupList) Value 

func (ls *SysConfigGroupList) Value(groupName, itemName string) (string, bool)

type SysConfigWizard 

type SysConfigWizard struct {
	types.TypeMeta `json:",inline" toml:",inline"`
	Option         AppOption        `json:"option" toml:"option"`
	Configurator   *SysConfigurator `json:"configurator,omitempty" toml:"configurator,omitempty"`
}

type SysConfigWizardList 

type SysConfigWizardList struct {
	types.TypeMeta `json:",inline" toml:",inline"`
	Items          []*SysConfigWizard `json:"items,omitempty" toml:"items,omitempty"`
}

type SysConfigurator 

type SysConfigurator struct {
	Name      string            `json:"name" toml:"name"`
	Title     string            `json:"title,omitempty" toml:"title,omitempty"`
	Fields    AppConfigFields   `json:"fields,omitempty" toml:"fields,omitempty"`
	ReadRoles types.ArrayUint32 `json:"read_roles,omitempty" toml:"read_roles,omitempty"`
}

type SysConfiguratorList 

type SysConfiguratorList struct {
	types.TypeMeta `json:",inline" toml:",inline"`
	Items          []*SysConfigurator `json:"items,omitempty" toml:"items,omitempty"`
}

type TimeStatsEntryQuerySet 

type TimeStatsEntryQuerySet struct {
	Name  string `json:"n,omitempty" toml:"n,omitempty"`
	Delta bool   `json:"d,omitempty" toml:"d,omitempty"`
}

type TimeStatsFeedQuerySet 

type TimeStatsFeedQuerySet struct {
	TimeCycle  uint32                    `json:"tc,omitempty" toml:"tc,omitempty"`
	TimePast   uint32                    `json:"tp,omitempty" toml:"tp,omitempty"`
	TimeStart  uint32                    `json:"ts,omitempty" toml:"ts,omitempty"`
	TimeCutset uint32                    `json:"tcs,omitempty" toml:"tcs,omitempty"`
	Items      []*TimeStatsEntryQuerySet `json:"is,omitempty" toml:"is,omitempty"`
}

func (*TimeStatsFeedQuerySet) Fix 

func (this *TimeStatsFeedQuerySet) Fix()

func (*TimeStatsFeedQuerySet) Get 

func (this *TimeStatsFeedQuerySet) Get(name string) *TimeStatsEntryQuerySet

type TypeMeta 

type TypeMeta struct {
	Kind  string     `protobuf:"bytes,1,opt,name=kind,proto3" json:"kind,omitempty" toml:"kind,omitempty"`
	Error *ErrorMeta `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty" toml:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*TypeMeta) Descriptor deprecated 

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

Deprecated: Use TypeMeta.ProtoReflect.Descriptor instead.

func (*TypeMeta) GetError 

func (x *TypeMeta) GetError() *ErrorMeta

func (*TypeMeta) GetKind 

func (x *TypeMeta) GetKind() string

func (*TypeMeta) ProtoMessage 

func (*TypeMeta) ProtoMessage()

func (*TypeMeta) ProtoReflect 

func (x *TypeMeta) ProtoReflect() protoreflect.Message

func (*TypeMeta) Reset 

func (x *TypeMeta) Reset()

func (*TypeMeta) String 

func (x *TypeMeta) String() string

type UnimplementedApiHostMemberServer 

type UnimplementedApiHostMemberServer struct {
}

UnimplementedApiHostMemberServer must be embedded to have forward compatible implementations.

func (UnimplementedApiHostMemberServer) HostJoin 

func (UnimplementedApiHostMemberServer) HostJoin(context.Context, *ResHostNew) (*ResHost, error)

type UnimplementedApiZoneMasterServer 

type UnimplementedApiZoneMasterServer struct {
}

UnimplementedApiZoneMasterServer must be embedded to have forward compatible implementations.

func (UnimplementedApiZoneMasterServer) HostConfig 

func (UnimplementedApiZoneMasterServer) HostConfig(context.Context, *ZoneHostConfigRequest) (*ZoneHostConfigReply, error)

func (UnimplementedApiZoneMasterServer) HostStatusSync 

func (UnimplementedApiZoneMasterServer) HostStatusSync(context.Context, *ResHost) (*ResHostBound, error)

type UnsafeApiHostMemberServer 

type UnsafeApiHostMemberServer interface {
	// contains filtered or unexported methods
}

UnsafeApiHostMemberServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ApiHostMemberServer will result in compilation errors.

type UnsafeApiZoneMasterServer 

type UnsafeApiZoneMasterServer interface {
	// contains filtered or unexported methods
}

UnsafeApiZoneMasterServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ApiZoneMasterServer will result in compilation errors.

type Validator 

type Validator interface {
	Valid(s string) error
}

type VcsRepoItem 

type VcsRepoItem struct {
	Dir             string `json:"dir" toml:"dir"` // primary key
	Url             string `json:"url" toml:"url"`
	Branch          string `json:"branch" toml:"branch"`
	Plan            string `json:"plan" toml:"plan"`
	AuthUser        string `json:"auth_user,omitempty" toml:"auth_user,omitempty"`
	AuthPass        string `json:"auth_pass,omitempty" toml:"auth_pass,omitempty"`
	HookExecRestart string `json:"hook_exec_restart,omitempty" toml:"hook_exec_restart,omitempty"`
	HookPodRestart  bool   `json:"hook_pod_restart,omitempty" toml:"hook_pod_restart,omitempty"`
}

func (*VcsRepoItem) Valid 

func (it *VcsRepoItem) Valid() error

type VcsRepoItems 

type VcsRepoItems []*VcsRepoItem

func (*VcsRepoItems) Del 

func (ls *VcsRepoItems) Del(id string)

func (*VcsRepoItems) Get 

func (ls *VcsRepoItems) Get(id string) *VcsRepoItem

func (*VcsRepoItems) Set 

func (ls *VcsRepoItems) Set(v2 *VcsRepoItem)

type VolumeGitRepo 

type VolumeGitRepo struct {
	// Repository URL
	Repository string `json:"repository" toml:"repository"`
	// Commit hash, this is optional
	Revision string `json:"revision" toml:"revision"`
	//
	BoxPath string `json:"boxPath,omitempty" toml:"boxPath,omitempty"`
}

VolumeGitRepo represents a volume that is pulled from git when the pod is created.

type VolumeHostDir 

type VolumeHostDir struct {
	HostDir string `json:"hostDir" toml:"hostDir"`
	// BoxPath    string `json:"boxPath,omitempty" toml:"boxPath,omitempty"`
	Path string `json:"path" toml:"path"`
}

type VolumeMount 

type VolumeMount struct {
	// Required: This must match the Name of a Volume [above].
	Name string `json:"name,omitempty" toml:"name,omitempty"`
	// Optional: Defaults to false (read-write).
	ReadOnly bool `json:"readOnly,omitempty" toml:"readOnly,omitempty"`
	// Required.
	MountPath string `json:"mountPath" toml:"mountPath"`
	// //
	HostDir string `json:"hostDir,omitempty" toml:"hostDir,omitempty"`
}

VolumeMount describes a mounting of a Volume within a container.

type VolumeMounts 

type VolumeMounts []VolumeMount

func (*VolumeMounts) DiffSync 

func (ls *VolumeMounts) DiffSync(items VolumeMounts)

func (*VolumeMounts) Equal 

func (ls *VolumeMounts) Equal(items VolumeMounts) bool

func (*VolumeMounts) Sync 

func (ls *VolumeMounts) Sync(item VolumeMount) bool

type VolumePackage 

type VolumePackage struct {
	// Package Name form an identifier that is assumed to be completely unique
	Name string `json:"name" toml:"name"`
	// Package Version
	Version string `json:"version,omitempty" toml:"version,omitempty"`
	// Package Release
	Release string `json:"release,omitempty" toml:"release,omitempty"`
	// Distribution indicates the type of operating system.
	Dist string `json:"dist,omitempty" toml:"dist,omitempty"`
	// Architecture indicates the type of hardware.
	Arch string `json:"arch,omitempty" toml:"arch,omitempty"`

	//
	HostDir string `json:"hostDir,omitempty" toml:"hostDir,omitempty"`
}

VolumePackage represents a volume that is pulled from lessos package service.

type WebServiceReply 

type WebServiceReply struct {
	Kind    string      `json:"kind,omitempty" toml:"kind,omitempty"`
	Message string      `json:"message,omitempty" toml:"message,omitempty"`
	Item    interface{} `json:"item,omitempty" toml:"item,omitempty"`
	Items   interface{} `json:"items,omitempty" toml:"items,omitempty"`
}

type ZoneDriver 

type ZoneDriver interface {
	Name() string
	ConfigSpec() *ConfigSpec
	ConfigValid(cfg *ConfigInstance) error
	HostAlloc(cfg *ConfigInstance, host *ResHost) error
	HostFree(cfg *ConfigInstance, host *ResHost) error
	HostList(cfg *ConfigInstance) ([]*ResHostCloudProvider, error)
}

type ZoneGroupSpec 

type ZoneGroupSpec struct {
	Id          string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty" toml:"id,omitempty"`
	Name        string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty" toml:"name,omitempty"`
	Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty" toml:"description,omitempty"`
	Action      uint64 `protobuf:"varint,4,opt,name=action,proto3" json:"action,omitempty" toml:"action,omitempty"`
	// contains filtered or unexported fields
}

func (*ZoneGroupSpec) Descriptor deprecated 

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

Deprecated: Use ZoneGroupSpec.ProtoReflect.Descriptor instead.

func (*ZoneGroupSpec) GetAction 

func (x *ZoneGroupSpec) GetAction() uint64

func (*ZoneGroupSpec) GetDescription 

func (x *ZoneGroupSpec) GetDescription() string

func (*ZoneGroupSpec) GetId 

func (x *ZoneGroupSpec) GetId() string

func (*ZoneGroupSpec) GetName 

func (x *ZoneGroupSpec) GetName() string

func (*ZoneGroupSpec) ProtoMessage 

func (*ZoneGroupSpec) ProtoMessage()

func (*ZoneGroupSpec) ProtoReflect 

func (x *ZoneGroupSpec) ProtoReflect() protoreflect.Message

func (*ZoneGroupSpec) Reset 

func (x *ZoneGroupSpec) Reset()

func (*ZoneGroupSpec) String 

func (x *ZoneGroupSpec) String() string

type ZoneHostConfigReply 

type ZoneHostConfigReply struct {
	ZoneId        string   `protobuf:"bytes,3,opt,name=zone_id,json=zoneId,proto3" json:"zone_id,omitempty" toml:"zone_id,omitempty"`
	CellId        string   `protobuf:"bytes,4,opt,name=cell_id,json=cellId,proto3" json:"cell_id,omitempty" toml:"cell_id,omitempty"`
	ZoneMainNodes []string `` /* 135-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ZoneHostConfigReply) Descriptor deprecated 

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

Deprecated: Use ZoneHostConfigReply.ProtoReflect.Descriptor instead.

func (*ZoneHostConfigReply) GetCellId 

func (x *ZoneHostConfigReply) GetCellId() string

func (*ZoneHostConfigReply) GetZoneId 

func (x *ZoneHostConfigReply) GetZoneId() string

func (*ZoneHostConfigReply) GetZoneMainNodes 

func (x *ZoneHostConfigReply) GetZoneMainNodes() []string

func (*ZoneHostConfigReply) ProtoMessage 

func (*ZoneHostConfigReply) ProtoMessage()

func (*ZoneHostConfigReply) ProtoReflect 

func (x *ZoneHostConfigReply) ProtoReflect() protoreflect.Message

func (*ZoneHostConfigReply) Reset 

func (x *ZoneHostConfigReply) Reset()

func (*ZoneHostConfigReply) String 

func (x *ZoneHostConfigReply) String() string

type ZoneHostConfigRequest 

type ZoneHostConfigRequest struct {
	Action    uint64 `protobuf:"varint,2,opt,name=action,proto3" json:"action,omitempty" toml:"action,omitempty"`
	Id        string `protobuf:"bytes,3,opt,name=id,proto3" json:"id,omitempty" toml:"id,omitempty"`
	CellId    string `protobuf:"bytes,4,opt,name=cell_id,json=cellId,proto3" json:"cell_id,omitempty" toml:"cell_id,omitempty"`
	LanAddr   string `protobuf:"bytes,5,opt,name=lan_addr,json=lanAddr,proto3" json:"lan_addr,omitempty" toml:"lan_addr,omitempty"`
	SecretKey string `protobuf:"bytes,6,opt,name=secret_key,json=secretKey,proto3" json:"secret_key,omitempty" toml:"secret_key,omitempty"`
	// contains filtered or unexported fields
}

func (*ZoneHostConfigRequest) Descriptor deprecated 

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

Deprecated: Use ZoneHostConfigRequest.ProtoReflect.Descriptor instead.

func (*ZoneHostConfigRequest) GetAction 

func (x *ZoneHostConfigRequest) GetAction() uint64

func (*ZoneHostConfigRequest) GetCellId 

func (x *ZoneHostConfigRequest) GetCellId() string

func (*ZoneHostConfigRequest) GetId 

func (x *ZoneHostConfigRequest) GetId() string

func (*ZoneHostConfigRequest) GetLanAddr 

func (x *ZoneHostConfigRequest) GetLanAddr() string

func (*ZoneHostConfigRequest) GetSecretKey 

func (x *ZoneHostConfigRequest) GetSecretKey() string

func (*ZoneHostConfigRequest) ProtoMessage 

func (*ZoneHostConfigRequest) ProtoMessage()

func (*ZoneHostConfigRequest) ProtoReflect 

func (x *ZoneHostConfigRequest) ProtoReflect() protoreflect.Message

func (*ZoneHostConfigRequest) Reset 

func (x *ZoneHostConfigRequest) Reset()

func (*ZoneHostConfigRequest) String 

func (x *ZoneHostConfigRequest) String() string

type ZoneNetworkMap 

type ZoneNetworkMap struct {
	UpdateVersion   uint64            `` /* 133-byte string literal not displayed */
	VpcRouteData    []byte            `` /* 131-byte string literal not displayed */
	VpcInstanceData map[uint32]string `` /* 232-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ZoneNetworkMap) Descriptor deprecated 

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

Deprecated: Use ZoneNetworkMap.ProtoReflect.Descriptor instead.

func (*ZoneNetworkMap) GetUpdateVersion 

func (x *ZoneNetworkMap) GetUpdateVersion() uint64

func (*ZoneNetworkMap) GetVpcInstanceData 

func (x *ZoneNetworkMap) GetVpcInstanceData() map[uint32]string

func (*ZoneNetworkMap) GetVpcRouteData 

func (x *ZoneNetworkMap) GetVpcRouteData() []byte

func (*ZoneNetworkMap) ProtoMessage 

func (*ZoneNetworkMap) ProtoMessage()

func (*ZoneNetworkMap) ProtoReflect 

func (x *ZoneNetworkMap) ProtoReflect() protoreflect.Message

func (*ZoneNetworkMap) Reset 

func (x *ZoneNetworkMap) Reset()

func (*ZoneNetworkMap) String 

func (x *ZoneNetworkMap) String() string

type ZoneNetworkMapInstance 

type ZoneNetworkMapInstance struct {
	Id     string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty" toml:"id,omitempty"`
	RepCap uint32 `protobuf:"varint,2,opt,name=rep_cap,json=repCap,proto3" json:"rep_cap,omitempty" toml:"rep_cap,omitempty"`
	// contains filtered or unexported fields
}

func (*ZoneNetworkMapInstance) Descriptor deprecated 

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

Deprecated: Use ZoneNetworkMapInstance.ProtoReflect.Descriptor instead.

func (*ZoneNetworkMapInstance) GetId 

func (x *ZoneNetworkMapInstance) GetId() string

func (*ZoneNetworkMapInstance) GetRepCap 

func (x *ZoneNetworkMapInstance) GetRepCap() uint32

func (*ZoneNetworkMapInstance) ProtoMessage 

func (*ZoneNetworkMapInstance) ProtoMessage()

func (*ZoneNetworkMapInstance) ProtoReflect 

func (x *ZoneNetworkMapInstance) ProtoReflect() protoreflect.Message

func (*ZoneNetworkMapInstance) Reset 

func (x *ZoneNetworkMapInstance) Reset()

func (*ZoneNetworkMapInstance) String 

func (x *ZoneNetworkMapInstance) String() string

Source Files

View all Source files

Directories

Path Synopsis

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.