pb

package
v0.0.0-...-ff909ee Latest Latest
Warning

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

 Go to latest Published: Oct 16, 2024 License: MIT Imports: 8 Imported by: 17

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	TriOpt_name = map[int32]string{
		0: "KEEP",
		1: "TRUE",
		2: "FALSE",
	}
	TriOpt_value = map[string]int32{
		"KEEP":  0,
		"TRUE":  1,
		"FALSE": 2,
	}
)

Enum value maps for TriOpt.

View Source 
var (
	StdStreamType_name = map[int32]string{
		0:  "STDOUT",
		1:  "STDERR",
		6:  "TYPEWORKLOADID",
		-1: "ERUERROR",
	}
	StdStreamType_value = map[string]int32{
		"STDOUT":         0,
		"STDERR":         1,
		"TYPEWORKLOADID": 6,
		"ERUERROR":       -1,
	}
)

Enum value maps for StdStreamType.

View Source 
var (
	BuildImageOptions_BuildMethod_name = map[int32]string{
		0: "SCM",
		1: "RAW",
		2: "EXIST",
	}
	BuildImageOptions_BuildMethod_value = map[string]int32{
		"SCM":   0,
		"RAW":   1,
		"EXIST": 2,
	}
)

Enum value maps for BuildImageOptions_BuildMethod.

View Source 
var (
	DeployOptions_Strategy_name = map[int32]string{
		0:  "AUTO",
		1:  "FILL",
		2:  "EACH",
		3:  "GLOBAL",
		4:  "DRAINED",
		99: "DUMMY",
	}
	DeployOptions_Strategy_value = map[string]int32{
		"AUTO":    0,
		"FILL":    1,
		"EACH":    2,
		"GLOBAL":  3,
		"DRAINED": 4,
		"DUMMY":   99,
	}
)

Enum value maps for DeployOptions_Strategy.

View Source 
var CoreRPC_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "pb.CoreRPC",
	HandlerType: (*CoreRPCServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Info",
			Handler:    _CoreRPC_Info_Handler,
		},
		{
			MethodName: "ListNetworks",
			Handler:    _CoreRPC_ListNetworks_Handler,
		},
		{
			MethodName: "ConnectNetwork",
			Handler:    _CoreRPC_ConnectNetwork_Handler,
		},
		{
			MethodName: "DisconnectNetwork",
			Handler:    _CoreRPC_DisconnectNetwork_Handler,
		},
		{
			MethodName: "AddPod",
			Handler:    _CoreRPC_AddPod_Handler,
		},
		{
			MethodName: "RemovePod",
			Handler:    _CoreRPC_RemovePod_Handler,
		},
		{
			MethodName: "GetPod",
			Handler:    _CoreRPC_GetPod_Handler,
		},
		{
			MethodName: "ListPods",
			Handler:    _CoreRPC_ListPods_Handler,
		},
		{
			MethodName: "GetNodeResource",
			Handler:    _CoreRPC_GetNodeResource_Handler,
		},
		{
			MethodName: "AddNode",
			Handler:    _CoreRPC_AddNode_Handler,
		},
		{
			MethodName: "RemoveNode",
			Handler:    _CoreRPC_RemoveNode_Handler,
		},
		{
			MethodName: "GetNode",
			Handler:    _CoreRPC_GetNode_Handler,
		},
		{
			MethodName: "GetNodeEngineInfo",
			Handler:    _CoreRPC_GetNodeEngineInfo_Handler,
		},
		{
			MethodName: "SetNode",
			Handler:    _CoreRPC_SetNode_Handler,
		},
		{
			MethodName: "GetNodeStatus",
			Handler:    _CoreRPC_GetNodeStatus_Handler,
		},
		{
			MethodName: "SetNodeStatus",
			Handler:    _CoreRPC_SetNodeStatus_Handler,
		},
		{
			MethodName: "GetWorkloadsStatus",
			Handler:    _CoreRPC_GetWorkloadsStatus_Handler,
		},
		{
			MethodName: "SetWorkloadsStatus",
			Handler:    _CoreRPC_SetWorkloadsStatus_Handler,
		},
		{
			MethodName: "CalculateCapacity",
			Handler:    _CoreRPC_CalculateCapacity_Handler,
		},
		{
			MethodName: "GetWorkload",
			Handler:    _CoreRPC_GetWorkload_Handler,
		},
		{
			MethodName: "GetWorkloads",
			Handler:    _CoreRPC_GetWorkloads_Handler,
		},
		{
			MethodName: "ListNodeWorkloads",
			Handler:    _CoreRPC_ListNodeWorkloads_Handler,
		},
		{
			MethodName: "ReallocResource",
			Handler:    _CoreRPC_ReallocResource_Handler,
		},
		{
			MethodName: "RawEngine",
			Handler:    _CoreRPC_RawEngine_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "WatchServiceStatus",
			Handler:       _CoreRPC_WatchServiceStatus_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "GetPodResource",
			Handler:       _CoreRPC_GetPodResource_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "ListPodNodes",
			Handler:       _CoreRPC_ListPodNodes_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "NodeStatusStream",
			Handler:       _CoreRPC_NodeStatusStream_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "WorkloadStatusStream",
			Handler:       _CoreRPC_WorkloadStatusStream_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "ListWorkloads",
			Handler:       _CoreRPC_ListWorkloads_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "Copy",
			Handler:       _CoreRPC_Copy_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "Send",
			Handler:       _CoreRPC_Send_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SendLargeFile",
			Handler:       _CoreRPC_SendLargeFile_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
		{
			StreamName:    "BuildImage",
			Handler:       _CoreRPC_BuildImage_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "CacheImage",
			Handler:       _CoreRPC_CacheImage_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "RemoveImage",
			Handler:       _CoreRPC_RemoveImage_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "ListImage",
			Handler:       _CoreRPC_ListImage_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "CreateWorkload",
			Handler:       _CoreRPC_CreateWorkload_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "ReplaceWorkload",
			Handler:       _CoreRPC_ReplaceWorkload_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "RemoveWorkload",
			Handler:       _CoreRPC_RemoveWorkload_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "DissociateWorkload",
			Handler:       _CoreRPC_DissociateWorkload_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "ControlWorkload",
			Handler:       _CoreRPC_ControlWorkload_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "ExecuteWorkload",
			Handler:       _CoreRPC_ExecuteWorkload_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
		{
			StreamName:    "LogStream",
			Handler:       _CoreRPC_LogStream_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "RunAndWait",
			Handler:       _CoreRPC_RunAndWait_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "rpc/gen/core.proto",
}

CoreRPC_ServiceDesc is the grpc.ServiceDesc for CoreRPC 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 File_rpc_gen_core_proto protoreflect.FileDescriptor

Functions

func RegisterCoreRPCServer 

func RegisterCoreRPCServer(s grpc.ServiceRegistrar, srv CoreRPCServer)

Types

type AddNodeOptions 

type AddNodeOptions struct {
	Nodename  string            `protobuf:"bytes,1001,opt,name=nodename,proto3" json:"nodename,omitempty"`
	Endpoint  string            `protobuf:"bytes,1002,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	Podname   string            `protobuf:"bytes,1003,opt,name=podname,proto3" json:"podname,omitempty"`
	Ca        string            `protobuf:"bytes,1004,opt,name=ca,proto3" json:"ca,omitempty"`
	Cert      string            `protobuf:"bytes,1005,opt,name=cert,proto3" json:"cert,omitempty"`
	Key       string            `protobuf:"bytes,1006,opt,name=key,proto3" json:"key,omitempty"`
	Labels    map[string]string `` /* 156-byte string literal not displayed */
	Resources map[string][]byte `` /* 162-byte string literal not displayed */
	Test      bool              `protobuf:"varint,1009,opt,name=test,proto3" json:"test,omitempty"`
	// contains filtered or unexported fields
}

func (*AddNodeOptions) Descriptor deprecated 

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

Deprecated: Use AddNodeOptions.ProtoReflect.Descriptor instead.

func (*AddNodeOptions) GetCa 

func (x *AddNodeOptions) GetCa() string

func (*AddNodeOptions) GetCert 

func (x *AddNodeOptions) GetCert() string

func (*AddNodeOptions) GetEndpoint 

func (x *AddNodeOptions) GetEndpoint() string

func (*AddNodeOptions) GetKey 

func (x *AddNodeOptions) GetKey() string

func (*AddNodeOptions) GetLabels 

func (x *AddNodeOptions) GetLabels() map[string]string

func (*AddNodeOptions) GetNodename 

func (x *AddNodeOptions) GetNodename() string

func (*AddNodeOptions) GetPodname 

func (x *AddNodeOptions) GetPodname() string

func (*AddNodeOptions) GetResources 

func (x *AddNodeOptions) GetResources() map[string][]byte

func (*AddNodeOptions) GetTest 

func (x *AddNodeOptions) GetTest() bool

func (*AddNodeOptions) ProtoMessage 

func (*AddNodeOptions) ProtoMessage()

func (*AddNodeOptions) ProtoReflect 

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

func (*AddNodeOptions) Reset 

func (x *AddNodeOptions) Reset()

func (*AddNodeOptions) String 

func (x *AddNodeOptions) String() string

type AddPodOptions 

type AddPodOptions struct {
	Name string `protobuf:"bytes,1001,opt,name=name,proto3" json:"name,omitempty"`
	Desc string `protobuf:"bytes,1002,opt,name=desc,proto3" json:"desc,omitempty"`
	// contains filtered or unexported fields
}

func (*AddPodOptions) Descriptor deprecated 

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

Deprecated: Use AddPodOptions.ProtoReflect.Descriptor instead.

func (*AddPodOptions) GetDesc 

func (x *AddPodOptions) GetDesc() string

func (*AddPodOptions) GetName 

func (x *AddPodOptions) GetName() string

func (*AddPodOptions) ProtoMessage 

func (*AddPodOptions) ProtoMessage()

func (*AddPodOptions) ProtoReflect 

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

func (*AddPodOptions) Reset 

func (x *AddPodOptions) Reset()

func (*AddPodOptions) String 

func (x *AddPodOptions) String() string

type AttachWorkloadMessage 

type AttachWorkloadMessage struct {
	WorkloadId    string        `protobuf:"bytes,1001,opt,name=workload_id,json=workloadId,proto3" json:"workload_id,omitempty"`
	Data          []byte        `protobuf:"bytes,1002,opt,name=data,proto3" json:"data,omitempty"`
	StdStreamType StdStreamType `` /* 128-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*AttachWorkloadMessage) Descriptor deprecated 

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

Deprecated: Use AttachWorkloadMessage.ProtoReflect.Descriptor instead.

func (*AttachWorkloadMessage) GetData 

func (x *AttachWorkloadMessage) GetData() []byte

func (*AttachWorkloadMessage) GetStdStreamType 

func (x *AttachWorkloadMessage) GetStdStreamType() StdStreamType

func (*AttachWorkloadMessage) GetWorkloadId 

func (x *AttachWorkloadMessage) GetWorkloadId() string

func (*AttachWorkloadMessage) ProtoMessage 

func (*AttachWorkloadMessage) ProtoMessage()

func (*AttachWorkloadMessage) ProtoReflect 

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

func (*AttachWorkloadMessage) Reset 

func (x *AttachWorkloadMessage) Reset()

func (*AttachWorkloadMessage) String 

func (x *AttachWorkloadMessage) String() string

type Build 

type Build struct {
	Base       string            `protobuf:"bytes,1001,opt,name=base,proto3" json:"base,omitempty"`
	Repo       string            `protobuf:"bytes,1002,opt,name=repo,proto3" json:"repo,omitempty"`
	Version    string            `protobuf:"bytes,1003,opt,name=version,proto3" json:"version,omitempty"`
	Dir        string            `protobuf:"bytes,1004,opt,name=dir,proto3" json:"dir,omitempty"`
	Submodule  bool              `protobuf:"varint,1005,opt,name=submodule,proto3" json:"submodule,omitempty"`
	Commands   []string          `protobuf:"bytes,1006,rep,name=commands,proto3" json:"commands,omitempty"`
	Envs       map[string]string `` /* 152-byte string literal not displayed */
	Args       map[string]string `` /* 152-byte string literal not displayed */
	Labels     map[string]string `` /* 156-byte string literal not displayed */
	Artifacts  map[string]string `` /* 162-byte string literal not displayed */
	Cache      map[string]string `` /* 154-byte string literal not displayed */
	StopSignal string            `protobuf:"bytes,1012,opt,name=stop_signal,json=stopSignal,proto3" json:"stop_signal,omitempty"`
	Security   bool              `protobuf:"varint,1013,opt,name=security,proto3" json:"security,omitempty"`
	// contains filtered or unexported fields
}

func (*Build) Descriptor deprecated 

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

Deprecated: Use Build.ProtoReflect.Descriptor instead.

func (*Build) GetArgs 

func (x *Build) GetArgs() map[string]string

func (*Build) GetArtifacts 

func (x *Build) GetArtifacts() map[string]string

func (*Build) GetBase 

func (x *Build) GetBase() string

func (*Build) GetCache 

func (x *Build) GetCache() map[string]string

func (*Build) GetCommands 

func (x *Build) GetCommands() []string

func (*Build) GetDir 

func (x *Build) GetDir() string

func (*Build) GetEnvs 

func (x *Build) GetEnvs() map[string]string

func (*Build) GetLabels 

func (x *Build) GetLabels() map[string]string

func (*Build) GetRepo 

func (x *Build) GetRepo() string

func (*Build) GetSecurity 

func (x *Build) GetSecurity() bool

func (*Build) GetStopSignal 

func (x *Build) GetStopSignal() string

func (*Build) GetSubmodule 

func (x *Build) GetSubmodule() bool

func (*Build) GetVersion 

func (x *Build) GetVersion() string

func (*Build) ProtoMessage 

func (*Build) ProtoMessage()

func (*Build) ProtoReflect 

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

func (*Build) Reset 

func (x *Build) Reset()

func (*Build) String 

func (x *Build) String() string

type BuildImageMessage 

type BuildImageMessage struct {
	Id          string       `protobuf:"bytes,1001,opt,name=id,proto3" json:"id,omitempty"`
	Status      string       `protobuf:"bytes,1002,opt,name=status,proto3" json:"status,omitempty"`
	Progress    string       `protobuf:"bytes,1003,opt,name=progress,proto3" json:"progress,omitempty"`
	Error       string       `protobuf:"bytes,1004,opt,name=error,proto3" json:"error,omitempty"`
	Stream      string       `protobuf:"bytes,1005,opt,name=stream,proto3" json:"stream,omitempty"`
	ErrorDetail *ErrorDetail `protobuf:"bytes,1006,opt,name=error_detail,json=errorDetail,proto3" json:"error_detail,omitempty"`
	// contains filtered or unexported fields
}

func (*BuildImageMessage) Descriptor deprecated 

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

Deprecated: Use BuildImageMessage.ProtoReflect.Descriptor instead.

func (*BuildImageMessage) GetError 

func (x *BuildImageMessage) GetError() string

func (*BuildImageMessage) GetErrorDetail 

func (x *BuildImageMessage) GetErrorDetail() *ErrorDetail

func (*BuildImageMessage) GetId 

func (x *BuildImageMessage) GetId() string

func (*BuildImageMessage) GetProgress 

func (x *BuildImageMessage) GetProgress() string

func (*BuildImageMessage) GetStatus 

func (x *BuildImageMessage) GetStatus() string

func (*BuildImageMessage) GetStream 

func (x *BuildImageMessage) GetStream() string

func (*BuildImageMessage) ProtoMessage 

func (*BuildImageMessage) ProtoMessage()

func (*BuildImageMessage) ProtoReflect 

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

func (*BuildImageMessage) Reset 

func (x *BuildImageMessage) Reset()

func (*BuildImageMessage) String 

func (x *BuildImageMessage) String() string

type BuildImageOptions 

type BuildImageOptions struct {
	Name        string                        `protobuf:"bytes,1001,opt,name=name,proto3" json:"name,omitempty"`
	User        string                        `protobuf:"bytes,1002,opt,name=user,proto3" json:"user,omitempty"`
	Uid         int32                         `protobuf:"varint,1003,opt,name=uid,proto3" json:"uid,omitempty"`
	Tags        []string                      `protobuf:"bytes,1004,rep,name=tags,proto3" json:"tags,omitempty"`
	Builds      *Builds                       `protobuf:"bytes,1005,opt,name=builds,proto3" json:"builds,omitempty"`
	Tar         []byte                        `protobuf:"bytes,1006,opt,name=tar,proto3" json:"tar,omitempty"`
	BuildMethod BuildImageOptions_BuildMethod `` /* 136-byte string literal not displayed */
	ExistId     string                        `protobuf:"bytes,1008,opt,name=exist_id,json=existId,proto3" json:"exist_id,omitempty"`
	Platform    string                        `protobuf:"bytes,1009,opt,name=platform,proto3" json:"platform,omitempty"`
	// contains filtered or unexported fields
}

func (*BuildImageOptions) Descriptor deprecated 

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

Deprecated: Use BuildImageOptions.ProtoReflect.Descriptor instead.

func (*BuildImageOptions) GetBuildMethod 

func (x *BuildImageOptions) GetBuildMethod() BuildImageOptions_BuildMethod

func (*BuildImageOptions) GetBuilds 

func (x *BuildImageOptions) GetBuilds() *Builds

func (*BuildImageOptions) GetExistId 

func (x *BuildImageOptions) GetExistId() string

func (*BuildImageOptions) GetName 

func (x *BuildImageOptions) GetName() string

func (*BuildImageOptions) GetPlatform 

func (x *BuildImageOptions) GetPlatform() string

func (*BuildImageOptions) GetTags 

func (x *BuildImageOptions) GetTags() []string

func (*BuildImageOptions) GetTar 

func (x *BuildImageOptions) GetTar() []byte

func (*BuildImageOptions) GetUid 

func (x *BuildImageOptions) GetUid() int32

func (*BuildImageOptions) GetUser 

func (x *BuildImageOptions) GetUser() string

func (*BuildImageOptions) ProtoMessage 

func (*BuildImageOptions) ProtoMessage()

func (*BuildImageOptions) ProtoReflect 

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

func (*BuildImageOptions) Reset 

func (x *BuildImageOptions) Reset()

func (*BuildImageOptions) String 

func (x *BuildImageOptions) String() string

type BuildImageOptions_BuildMethod 

type BuildImageOptions_BuildMethod int32
const (
	BuildImageOptions_SCM   BuildImageOptions_BuildMethod = 0
	BuildImageOptions_RAW   BuildImageOptions_BuildMethod = 1
	BuildImageOptions_EXIST BuildImageOptions_BuildMethod = 2
)

func (BuildImageOptions_BuildMethod) Descriptor 

func (BuildImageOptions_BuildMethod) Descriptor() protoreflect.EnumDescriptor

func (BuildImageOptions_BuildMethod) Enum 

func (x BuildImageOptions_BuildMethod) Enum() *BuildImageOptions_BuildMethod

func (BuildImageOptions_BuildMethod) EnumDescriptor deprecated 

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

Deprecated: Use BuildImageOptions_BuildMethod.Descriptor instead.

func (BuildImageOptions_BuildMethod) Number 

func (x BuildImageOptions_BuildMethod) Number() protoreflect.EnumNumber

func (BuildImageOptions_BuildMethod) String 

func (x BuildImageOptions_BuildMethod) String() string

func (BuildImageOptions_BuildMethod) Type 

func (BuildImageOptions_BuildMethod) Type() protoreflect.EnumType

type Builds 

type Builds struct {
	Stages []string          `protobuf:"bytes,1001,rep,name=stages,proto3" json:"stages,omitempty"`
	Builds map[string]*Build `` /* 156-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Builds) Descriptor deprecated 

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

Deprecated: Use Builds.ProtoReflect.Descriptor instead.

func (*Builds) GetBuilds 

func (x *Builds) GetBuilds() map[string]*Build

func (*Builds) GetStages 

func (x *Builds) GetStages() []string

func (*Builds) ProtoMessage 

func (*Builds) ProtoMessage()

func (*Builds) ProtoReflect 

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

func (*Builds) Reset 

func (x *Builds) Reset()

func (*Builds) String 

func (x *Builds) String() string

type CacheImageMessage 

type CacheImageMessage struct {
	Image    string `protobuf:"bytes,1001,opt,name=image,proto3" json:"image,omitempty"`
	Success  bool   `protobuf:"varint,1002,opt,name=success,proto3" json:"success,omitempty"`
	Nodename string `protobuf:"bytes,1003,opt,name=nodename,proto3" json:"nodename,omitempty"`
	Message  string `protobuf:"bytes,1004,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*CacheImageMessage) Descriptor deprecated 

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

Deprecated: Use CacheImageMessage.ProtoReflect.Descriptor instead.

func (*CacheImageMessage) GetImage 

func (x *CacheImageMessage) GetImage() string

func (*CacheImageMessage) GetMessage 

func (x *CacheImageMessage) GetMessage() string

func (*CacheImageMessage) GetNodename 

func (x *CacheImageMessage) GetNodename() string

func (*CacheImageMessage) GetSuccess 

func (x *CacheImageMessage) GetSuccess() bool

func (*CacheImageMessage) ProtoMessage 

func (*CacheImageMessage) ProtoMessage()

func (*CacheImageMessage) ProtoReflect 

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

func (*CacheImageMessage) Reset 

func (x *CacheImageMessage) Reset()

func (*CacheImageMessage) String 

func (x *CacheImageMessage) String() string

type CacheImageOptions 

type CacheImageOptions struct {
	Podname   string   `protobuf:"bytes,1001,opt,name=podname,proto3" json:"podname,omitempty"`
	Nodenames []string `protobuf:"bytes,1002,rep,name=nodenames,proto3" json:"nodenames,omitempty"`
	Images    []string `protobuf:"bytes,1003,rep,name=images,proto3" json:"images,omitempty"`
	// contains filtered or unexported fields
}

func (*CacheImageOptions) Descriptor deprecated 

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

Deprecated: Use CacheImageOptions.ProtoReflect.Descriptor instead.

func (*CacheImageOptions) GetImages 

func (x *CacheImageOptions) GetImages() []string

func (*CacheImageOptions) GetNodenames 

func (x *CacheImageOptions) GetNodenames() []string

func (*CacheImageOptions) GetPodname 

func (x *CacheImageOptions) GetPodname() string

func (*CacheImageOptions) ProtoMessage 

func (*CacheImageOptions) ProtoMessage()

func (*CacheImageOptions) ProtoReflect 

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

func (*CacheImageOptions) Reset 

func (x *CacheImageOptions) Reset()

func (*CacheImageOptions) String 

func (x *CacheImageOptions) String() string

type CapacityMessage 

type CapacityMessage struct {
	Total          int64            `protobuf:"varint,1001,opt,name=total,proto3" json:"total,omitempty"`
	NodeCapacities map[string]int64 `` /* 195-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*CapacityMessage) Descriptor deprecated 

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

Deprecated: Use CapacityMessage.ProtoReflect.Descriptor instead.

func (*CapacityMessage) GetNodeCapacities 

func (x *CapacityMessage) GetNodeCapacities() map[string]int64

func (*CapacityMessage) GetTotal 

func (x *CapacityMessage) GetTotal() int64

func (*CapacityMessage) ProtoMessage 

func (*CapacityMessage) ProtoMessage()

func (*CapacityMessage) ProtoReflect 

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

func (*CapacityMessage) Reset 

func (x *CapacityMessage) Reset()

func (*CapacityMessage) String 

func (x *CapacityMessage) String() string

type ConnectNetworkOptions 

type ConnectNetworkOptions struct {
	Network string `protobuf:"bytes,1001,opt,name=network,proto3" json:"network,omitempty"`
	Target  string `protobuf:"bytes,1002,opt,name=target,proto3" json:"target,omitempty"`
	Ipv4    string `protobuf:"bytes,1003,opt,name=ipv4,proto3" json:"ipv4,omitempty"`
	Ipv6    string `protobuf:"bytes,1004,opt,name=ipv6,proto3" json:"ipv6,omitempty"`
	// contains filtered or unexported fields
}

func (*ConnectNetworkOptions) Descriptor deprecated 

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

Deprecated: Use ConnectNetworkOptions.ProtoReflect.Descriptor instead.

func (*ConnectNetworkOptions) GetIpv4 

func (x *ConnectNetworkOptions) GetIpv4() string

func (*ConnectNetworkOptions) GetIpv6 

func (x *ConnectNetworkOptions) GetIpv6() string

func (*ConnectNetworkOptions) GetNetwork 

func (x *ConnectNetworkOptions) GetNetwork() string

func (*ConnectNetworkOptions) GetTarget 

func (x *ConnectNetworkOptions) GetTarget() string

func (*ConnectNetworkOptions) ProtoMessage 

func (*ConnectNetworkOptions) ProtoMessage()

func (*ConnectNetworkOptions) ProtoReflect 

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

func (*ConnectNetworkOptions) Reset 

func (x *ConnectNetworkOptions) Reset()

func (*ConnectNetworkOptions) String 

func (x *ConnectNetworkOptions) String() string

type ControlWorkloadMessage 

type ControlWorkloadMessage struct {
	Id    string `protobuf:"bytes,1001,opt,name=id,proto3" json:"id,omitempty"`
	Error string `protobuf:"bytes,1002,opt,name=error,proto3" json:"error,omitempty"`
	Hook  []byte `protobuf:"bytes,1003,opt,name=hook,proto3" json:"hook,omitempty"`
	// contains filtered or unexported fields
}

func (*ControlWorkloadMessage) Descriptor deprecated 

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

Deprecated: Use ControlWorkloadMessage.ProtoReflect.Descriptor instead.

func (*ControlWorkloadMessage) GetError 

func (x *ControlWorkloadMessage) GetError() string

func (*ControlWorkloadMessage) GetHook 

func (x *ControlWorkloadMessage) GetHook() []byte

func (*ControlWorkloadMessage) GetId 

func (x *ControlWorkloadMessage) GetId() string

func (*ControlWorkloadMessage) ProtoMessage 

func (*ControlWorkloadMessage) ProtoMessage()

func (*ControlWorkloadMessage) ProtoReflect 

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

func (*ControlWorkloadMessage) Reset 

func (x *ControlWorkloadMessage) Reset()

func (*ControlWorkloadMessage) String 

func (x *ControlWorkloadMessage) String() string

type ControlWorkloadOptions 

type ControlWorkloadOptions struct {
	IDs   []string `protobuf:"bytes,1001,rep,name=IDs,proto3" json:"IDs,omitempty"`
	Type  string   `protobuf:"bytes,1002,opt,name=type,proto3" json:"type,omitempty"`
	Force bool     `protobuf:"varint,1003,opt,name=force,proto3" json:"force,omitempty"`
	// contains filtered or unexported fields
}

func (*ControlWorkloadOptions) Descriptor deprecated 

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

Deprecated: Use ControlWorkloadOptions.ProtoReflect.Descriptor instead.

func (*ControlWorkloadOptions) GetForce 

func (x *ControlWorkloadOptions) GetForce() bool

func (*ControlWorkloadOptions) GetIDs 

func (x *ControlWorkloadOptions) GetIDs() []string

func (*ControlWorkloadOptions) GetType 

func (x *ControlWorkloadOptions) GetType() string

func (*ControlWorkloadOptions) ProtoMessage 

func (*ControlWorkloadOptions) ProtoMessage()

func (*ControlWorkloadOptions) ProtoReflect 

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

func (*ControlWorkloadOptions) Reset 

func (x *ControlWorkloadOptions) Reset()

func (*ControlWorkloadOptions) String 

func (x *ControlWorkloadOptions) String() string

type CopyMessage 

type CopyMessage struct {
	Id    string `protobuf:"bytes,1001,opt,name=id,proto3" json:"id,omitempty"`
	Name  string `protobuf:"bytes,1002,opt,name=name,proto3" json:"name,omitempty"`
	Path  string `protobuf:"bytes,1003,opt,name=path,proto3" json:"path,omitempty"`
	Error string `protobuf:"bytes,1004,opt,name=error,proto3" json:"error,omitempty"`
	Data  []byte `protobuf:"bytes,1005,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*CopyMessage) Descriptor deprecated 

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

Deprecated: Use CopyMessage.ProtoReflect.Descriptor instead.

func (*CopyMessage) GetData 

func (x *CopyMessage) GetData() []byte

func (*CopyMessage) GetError 

func (x *CopyMessage) GetError() string

func (*CopyMessage) GetId 

func (x *CopyMessage) GetId() string

func (*CopyMessage) GetName 

func (x *CopyMessage) GetName() string

func (*CopyMessage) GetPath 

func (x *CopyMessage) GetPath() string

func (*CopyMessage) ProtoMessage 

func (*CopyMessage) ProtoMessage()

func (*CopyMessage) ProtoReflect 

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

func (*CopyMessage) Reset 

func (x *CopyMessage) Reset()

func (*CopyMessage) String 

func (x *CopyMessage) String() string

type CopyOptions 

type CopyOptions struct {
	Targets map[string]*CopyPaths `` /* 158-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*CopyOptions) Descriptor deprecated 

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

Deprecated: Use CopyOptions.ProtoReflect.Descriptor instead.

func (*CopyOptions) GetTargets 

func (x *CopyOptions) GetTargets() map[string]*CopyPaths

func (*CopyOptions) ProtoMessage 

func (*CopyOptions) ProtoMessage()

func (*CopyOptions) ProtoReflect 

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

func (*CopyOptions) Reset 

func (x *CopyOptions) Reset()

func (*CopyOptions) String 

func (x *CopyOptions) String() string

type CopyPaths 

type CopyPaths struct {
	Paths []string `protobuf:"bytes,1001,rep,name=paths,proto3" json:"paths,omitempty"`
	// contains filtered or unexported fields
}

func (*CopyPaths) Descriptor deprecated 

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

Deprecated: Use CopyPaths.ProtoReflect.Descriptor instead.

func (*CopyPaths) GetPaths 

func (x *CopyPaths) GetPaths() []string

func (*CopyPaths) ProtoMessage 

func (*CopyPaths) ProtoMessage()

func (*CopyPaths) ProtoReflect 

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

func (*CopyPaths) Reset 

func (x *CopyPaths) Reset()

func (*CopyPaths) String 

func (x *CopyPaths) String() string

type CoreInfo 

type CoreInfo struct {
	Version       string `protobuf:"bytes,1001,opt,name=version,proto3" json:"version,omitempty"`
	Revison       string `protobuf:"bytes,1002,opt,name=revison,proto3" json:"revison,omitempty"`
	BuildAt       string `protobuf:"bytes,1003,opt,name=build_at,json=buildAt,proto3" json:"build_at,omitempty"`
	GolangVersion string `protobuf:"bytes,1004,opt,name=golang_version,json=golangVersion,proto3" json:"golang_version,omitempty"`
	OsArch        string `protobuf:"bytes,1005,opt,name=os_arch,json=osArch,proto3" json:"os_arch,omitempty"`
	Identifier    string `protobuf:"bytes,1006,opt,name=identifier,proto3" json:"identifier,omitempty"`
	// contains filtered or unexported fields
}

func (*CoreInfo) Descriptor deprecated 

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

Deprecated: Use CoreInfo.ProtoReflect.Descriptor instead.

func (*CoreInfo) GetBuildAt 

func (x *CoreInfo) GetBuildAt() string

func (*CoreInfo) GetGolangVersion 

func (x *CoreInfo) GetGolangVersion() string

func (*CoreInfo) GetIdentifier 

func (x *CoreInfo) GetIdentifier() string

func (*CoreInfo) GetOsArch 

func (x *CoreInfo) GetOsArch() string

func (*CoreInfo) GetRevison 

func (x *CoreInfo) GetRevison() string

func (*CoreInfo) GetVersion 

func (x *CoreInfo) GetVersion() string

func (*CoreInfo) ProtoMessage 

func (*CoreInfo) ProtoMessage()

func (*CoreInfo) ProtoReflect 

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

func (*CoreInfo) Reset 

func (x *CoreInfo) Reset()

func (*CoreInfo) String 

func (x *CoreInfo) String() string

type CoreRPCClient 

type CoreRPCClient interface {
	Info(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*CoreInfo, error)
	WatchServiceStatus(ctx context.Context, in *Empty, opts ...grpc.CallOption) (CoreRPC_WatchServiceStatusClient, error)
	ListNetworks(ctx context.Context, in *ListNetworkOptions, opts ...grpc.CallOption) (*Networks, error)
	ConnectNetwork(ctx context.Context, in *ConnectNetworkOptions, opts ...grpc.CallOption) (*Network, error)
	DisconnectNetwork(ctx context.Context, in *DisconnectNetworkOptions, opts ...grpc.CallOption) (*Empty, error)
	AddPod(ctx context.Context, in *AddPodOptions, opts ...grpc.CallOption) (*Pod, error)
	RemovePod(ctx context.Context, in *RemovePodOptions, opts ...grpc.CallOption) (*Empty, error)
	GetPod(ctx context.Context, in *GetPodOptions, opts ...grpc.CallOption) (*Pod, error)
	ListPods(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Pods, error)
	GetPodResource(ctx context.Context, in *GetPodOptions, opts ...grpc.CallOption) (CoreRPC_GetPodResourceClient, error)
	GetNodeResource(ctx context.Context, in *GetNodeResourceOptions, opts ...grpc.CallOption) (*NodeResource, error)
	AddNode(ctx context.Context, in *AddNodeOptions, opts ...grpc.CallOption) (*Node, error)
	RemoveNode(ctx context.Context, in *RemoveNodeOptions, opts ...grpc.CallOption) (*Empty, error)
	ListPodNodes(ctx context.Context, in *ListNodesOptions, opts ...grpc.CallOption) (CoreRPC_ListPodNodesClient, error)
	GetNode(ctx context.Context, in *GetNodeOptions, opts ...grpc.CallOption) (*Node, error)
	GetNodeEngineInfo(ctx context.Context, in *GetNodeOptions, opts ...grpc.CallOption) (*Engine, error)
	SetNode(ctx context.Context, in *SetNodeOptions, opts ...grpc.CallOption) (*Node, error)
	GetNodeStatus(ctx context.Context, in *GetNodeStatusOptions, opts ...grpc.CallOption) (*NodeStatusStreamMessage, error)
	SetNodeStatus(ctx context.Context, in *SetNodeStatusOptions, opts ...grpc.CallOption) (*Empty, error)
	NodeStatusStream(ctx context.Context, in *Empty, opts ...grpc.CallOption) (CoreRPC_NodeStatusStreamClient, error)
	GetWorkloadsStatus(ctx context.Context, in *WorkloadIDs, opts ...grpc.CallOption) (*WorkloadsStatus, error)
	SetWorkloadsStatus(ctx context.Context, in *SetWorkloadsStatusOptions, opts ...grpc.CallOption) (*WorkloadsStatus, error)
	WorkloadStatusStream(ctx context.Context, in *WorkloadStatusStreamOptions, opts ...grpc.CallOption) (CoreRPC_WorkloadStatusStreamClient, error)
	CalculateCapacity(ctx context.Context, in *DeployOptions, opts ...grpc.CallOption) (*CapacityMessage, error)
	GetWorkload(ctx context.Context, in *WorkloadID, opts ...grpc.CallOption) (*Workload, error)
	GetWorkloads(ctx context.Context, in *WorkloadIDs, opts ...grpc.CallOption) (*Workloads, error)
	ListWorkloads(ctx context.Context, in *ListWorkloadsOptions, opts ...grpc.CallOption) (CoreRPC_ListWorkloadsClient, error)
	ListNodeWorkloads(ctx context.Context, in *GetNodeOptions, opts ...grpc.CallOption) (*Workloads, error)
	Copy(ctx context.Context, in *CopyOptions, opts ...grpc.CallOption) (CoreRPC_CopyClient, error)
	Send(ctx context.Context, in *SendOptions, opts ...grpc.CallOption) (CoreRPC_SendClient, error)
	SendLargeFile(ctx context.Context, opts ...grpc.CallOption) (CoreRPC_SendLargeFileClient, error)
	BuildImage(ctx context.Context, in *BuildImageOptions, opts ...grpc.CallOption) (CoreRPC_BuildImageClient, error)
	CacheImage(ctx context.Context, in *CacheImageOptions, opts ...grpc.CallOption) (CoreRPC_CacheImageClient, error)
	RemoveImage(ctx context.Context, in *RemoveImageOptions, opts ...grpc.CallOption) (CoreRPC_RemoveImageClient, error)
	ListImage(ctx context.Context, in *ListImageOptions, opts ...grpc.CallOption) (CoreRPC_ListImageClient, error)
	CreateWorkload(ctx context.Context, in *DeployOptions, opts ...grpc.CallOption) (CoreRPC_CreateWorkloadClient, error)
	ReplaceWorkload(ctx context.Context, in *ReplaceOptions, opts ...grpc.CallOption) (CoreRPC_ReplaceWorkloadClient, error)
	RemoveWorkload(ctx context.Context, in *RemoveWorkloadOptions, opts ...grpc.CallOption) (CoreRPC_RemoveWorkloadClient, error)
	DissociateWorkload(ctx context.Context, in *DissociateWorkloadOptions, opts ...grpc.CallOption) (CoreRPC_DissociateWorkloadClient, error)
	ControlWorkload(ctx context.Context, in *ControlWorkloadOptions, opts ...grpc.CallOption) (CoreRPC_ControlWorkloadClient, error)
	ExecuteWorkload(ctx context.Context, opts ...grpc.CallOption) (CoreRPC_ExecuteWorkloadClient, error)
	ReallocResource(ctx context.Context, in *ReallocOptions, opts ...grpc.CallOption) (*ReallocResourceMessage, error)
	LogStream(ctx context.Context, in *LogStreamOptions, opts ...grpc.CallOption) (CoreRPC_LogStreamClient, error)
	RunAndWait(ctx context.Context, opts ...grpc.CallOption) (CoreRPC_RunAndWaitClient, error)
	RawEngine(ctx context.Context, in *RawEngineOptions, opts ...grpc.CallOption) (*RawEngineMessage, error)
}

CoreRPCClient is the client API for CoreRPC 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 NewCoreRPCClient 

func NewCoreRPCClient(cc grpc.ClientConnInterface) CoreRPCClient

type CoreRPCServer 

type CoreRPCServer interface {
	Info(context.Context, *Empty) (*CoreInfo, error)
	WatchServiceStatus(*Empty, CoreRPC_WatchServiceStatusServer) error
	ListNetworks(context.Context, *ListNetworkOptions) (*Networks, error)
	ConnectNetwork(context.Context, *ConnectNetworkOptions) (*Network, error)
	DisconnectNetwork(context.Context, *DisconnectNetworkOptions) (*Empty, error)
	AddPod(context.Context, *AddPodOptions) (*Pod, error)
	RemovePod(context.Context, *RemovePodOptions) (*Empty, error)
	GetPod(context.Context, *GetPodOptions) (*Pod, error)
	ListPods(context.Context, *Empty) (*Pods, error)
	GetPodResource(*GetPodOptions, CoreRPC_GetPodResourceServer) error
	GetNodeResource(context.Context, *GetNodeResourceOptions) (*NodeResource, error)
	AddNode(context.Context, *AddNodeOptions) (*Node, error)
	RemoveNode(context.Context, *RemoveNodeOptions) (*Empty, error)
	ListPodNodes(*ListNodesOptions, CoreRPC_ListPodNodesServer) error
	GetNode(context.Context, *GetNodeOptions) (*Node, error)
	GetNodeEngineInfo(context.Context, *GetNodeOptions) (*Engine, error)
	SetNode(context.Context, *SetNodeOptions) (*Node, error)
	GetNodeStatus(context.Context, *GetNodeStatusOptions) (*NodeStatusStreamMessage, error)
	SetNodeStatus(context.Context, *SetNodeStatusOptions) (*Empty, error)
	NodeStatusStream(*Empty, CoreRPC_NodeStatusStreamServer) error
	GetWorkloadsStatus(context.Context, *WorkloadIDs) (*WorkloadsStatus, error)
	SetWorkloadsStatus(context.Context, *SetWorkloadsStatusOptions) (*WorkloadsStatus, error)
	WorkloadStatusStream(*WorkloadStatusStreamOptions, CoreRPC_WorkloadStatusStreamServer) error
	CalculateCapacity(context.Context, *DeployOptions) (*CapacityMessage, error)
	GetWorkload(context.Context, *WorkloadID) (*Workload, error)
	GetWorkloads(context.Context, *WorkloadIDs) (*Workloads, error)
	ListWorkloads(*ListWorkloadsOptions, CoreRPC_ListWorkloadsServer) error
	ListNodeWorkloads(context.Context, *GetNodeOptions) (*Workloads, error)
	Copy(*CopyOptions, CoreRPC_CopyServer) error
	Send(*SendOptions, CoreRPC_SendServer) error
	SendLargeFile(CoreRPC_SendLargeFileServer) error
	BuildImage(*BuildImageOptions, CoreRPC_BuildImageServer) error
	CacheImage(*CacheImageOptions, CoreRPC_CacheImageServer) error
	RemoveImage(*RemoveImageOptions, CoreRPC_RemoveImageServer) error
	ListImage(*ListImageOptions, CoreRPC_ListImageServer) error
	CreateWorkload(*DeployOptions, CoreRPC_CreateWorkloadServer) error
	ReplaceWorkload(*ReplaceOptions, CoreRPC_ReplaceWorkloadServer) error
	RemoveWorkload(*RemoveWorkloadOptions, CoreRPC_RemoveWorkloadServer) error
	DissociateWorkload(*DissociateWorkloadOptions, CoreRPC_DissociateWorkloadServer) error
	ControlWorkload(*ControlWorkloadOptions, CoreRPC_ControlWorkloadServer) error
	ExecuteWorkload(CoreRPC_ExecuteWorkloadServer) error
	ReallocResource(context.Context, *ReallocOptions) (*ReallocResourceMessage, error)
	LogStream(*LogStreamOptions, CoreRPC_LogStreamServer) error
	RunAndWait(CoreRPC_RunAndWaitServer) error
	RawEngine(context.Context, *RawEngineOptions) (*RawEngineMessage, error)
}

CoreRPCServer is the server API for CoreRPC service. All implementations should embed UnimplementedCoreRPCServer for forward compatibility

type CoreRPC_BuildImageClient 

type CoreRPC_BuildImageClient interface {
	Recv() (*BuildImageMessage, error)
	grpc.ClientStream
}

type CoreRPC_BuildImageServer 

type CoreRPC_BuildImageServer interface {
	Send(*BuildImageMessage) error
	grpc.ServerStream
}

type CoreRPC_CacheImageClient 

type CoreRPC_CacheImageClient interface {
	Recv() (*CacheImageMessage, error)
	grpc.ClientStream
}

type CoreRPC_CacheImageServer 

type CoreRPC_CacheImageServer interface {
	Send(*CacheImageMessage) error
	grpc.ServerStream
}

type CoreRPC_ControlWorkloadClient 

type CoreRPC_ControlWorkloadClient interface {
	Recv() (*ControlWorkloadMessage, error)
	grpc.ClientStream
}

type CoreRPC_ControlWorkloadServer 

type CoreRPC_ControlWorkloadServer interface {
	Send(*ControlWorkloadMessage) error
	grpc.ServerStream
}

type CoreRPC_CopyClient 

type CoreRPC_CopyClient interface {
	Recv() (*CopyMessage, error)
	grpc.ClientStream
}

type CoreRPC_CopyServer 

type CoreRPC_CopyServer interface {
	Send(*CopyMessage) error
	grpc.ServerStream
}

type CoreRPC_CreateWorkloadClient 

type CoreRPC_CreateWorkloadClient interface {
	Recv() (*CreateWorkloadMessage, error)
	grpc.ClientStream
}

type CoreRPC_CreateWorkloadServer 

type CoreRPC_CreateWorkloadServer interface {
	Send(*CreateWorkloadMessage) error
	grpc.ServerStream
}

type CoreRPC_DissociateWorkloadClient 

type CoreRPC_DissociateWorkloadClient interface {
	Recv() (*DissociateWorkloadMessage, error)
	grpc.ClientStream
}

type CoreRPC_DissociateWorkloadServer 

type CoreRPC_DissociateWorkloadServer interface {
	Send(*DissociateWorkloadMessage) error
	grpc.ServerStream
}

type CoreRPC_ExecuteWorkloadClient 

type CoreRPC_ExecuteWorkloadClient interface {
	Send(*ExecuteWorkloadOptions) error
	Recv() (*AttachWorkloadMessage, error)
	grpc.ClientStream
}

type CoreRPC_ExecuteWorkloadServer 

type CoreRPC_ExecuteWorkloadServer interface {
	Send(*AttachWorkloadMessage) error
	Recv() (*ExecuteWorkloadOptions, error)
	grpc.ServerStream
}

type CoreRPC_GetPodResourceClient 

type CoreRPC_GetPodResourceClient interface {
	Recv() (*NodeResource, error)
	grpc.ClientStream
}

type CoreRPC_GetPodResourceServer 

type CoreRPC_GetPodResourceServer interface {
	Send(*NodeResource) error
	grpc.ServerStream
}

type CoreRPC_ListImageClient 

type CoreRPC_ListImageClient interface {
	Recv() (*ListImageMessage, error)
	grpc.ClientStream
}

type CoreRPC_ListImageServer 

type CoreRPC_ListImageServer interface {
	Send(*ListImageMessage) error
	grpc.ServerStream
}

type CoreRPC_ListPodNodesClient 

type CoreRPC_ListPodNodesClient interface {
	Recv() (*Node, error)
	grpc.ClientStream
}

type CoreRPC_ListPodNodesServer 

type CoreRPC_ListPodNodesServer interface {
	Send(*Node) error
	grpc.ServerStream
}

type CoreRPC_ListWorkloadsClient 

type CoreRPC_ListWorkloadsClient interface {
	Recv() (*Workload, error)
	grpc.ClientStream
}

type CoreRPC_ListWorkloadsServer 

type CoreRPC_ListWorkloadsServer interface {
	Send(*Workload) error
	grpc.ServerStream
}

type CoreRPC_LogStreamClient 

type CoreRPC_LogStreamClient interface {
	Recv() (*LogStreamMessage, error)
	grpc.ClientStream
}

type CoreRPC_LogStreamServer 

type CoreRPC_LogStreamServer interface {
	Send(*LogStreamMessage) error
	grpc.ServerStream
}

type CoreRPC_NodeStatusStreamClient 

type CoreRPC_NodeStatusStreamClient interface {
	Recv() (*NodeStatusStreamMessage, error)
	grpc.ClientStream
}

type CoreRPC_NodeStatusStreamServer 

type CoreRPC_NodeStatusStreamServer interface {
	Send(*NodeStatusStreamMessage) error
	grpc.ServerStream
}

type CoreRPC_RemoveImageClient 

type CoreRPC_RemoveImageClient interface {
	Recv() (*RemoveImageMessage, error)
	grpc.ClientStream
}

type CoreRPC_RemoveImageServer 

type CoreRPC_RemoveImageServer interface {
	Send(*RemoveImageMessage) error
	grpc.ServerStream
}

type CoreRPC_RemoveWorkloadClient 

type CoreRPC_RemoveWorkloadClient interface {
	Recv() (*RemoveWorkloadMessage, error)
	grpc.ClientStream
}

type CoreRPC_RemoveWorkloadServer 

type CoreRPC_RemoveWorkloadServer interface {
	Send(*RemoveWorkloadMessage) error
	grpc.ServerStream
}

type CoreRPC_ReplaceWorkloadClient 

type CoreRPC_ReplaceWorkloadClient interface {
	Recv() (*ReplaceWorkloadMessage, error)
	grpc.ClientStream
}

type CoreRPC_ReplaceWorkloadServer 

type CoreRPC_ReplaceWorkloadServer interface {
	Send(*ReplaceWorkloadMessage) error
	grpc.ServerStream
}

type CoreRPC_RunAndWaitClient 

type CoreRPC_RunAndWaitClient interface {
	Send(*RunAndWaitOptions) error
	Recv() (*AttachWorkloadMessage, error)
	grpc.ClientStream
}

type CoreRPC_RunAndWaitServer 

type CoreRPC_RunAndWaitServer interface {
	Send(*AttachWorkloadMessage) error
	Recv() (*RunAndWaitOptions, error)
	grpc.ServerStream
}

type CoreRPC_SendClient 

type CoreRPC_SendClient interface {
	Recv() (*SendMessage, error)
	grpc.ClientStream
}

type CoreRPC_SendLargeFileClient 

type CoreRPC_SendLargeFileClient interface {
	Send(*FileOptions) error
	Recv() (*SendMessage, error)
	grpc.ClientStream
}

type CoreRPC_SendLargeFileServer 

type CoreRPC_SendLargeFileServer interface {
	Send(*SendMessage) error
	Recv() (*FileOptions, error)
	grpc.ServerStream
}

type CoreRPC_SendServer 

type CoreRPC_SendServer interface {
	Send(*SendMessage) error
	grpc.ServerStream
}

type CoreRPC_WatchServiceStatusClient 

type CoreRPC_WatchServiceStatusClient interface {
	Recv() (*ServiceStatus, error)
	grpc.ClientStream
}

type CoreRPC_WatchServiceStatusServer 

type CoreRPC_WatchServiceStatusServer interface {
	Send(*ServiceStatus) error
	grpc.ServerStream
}

type CoreRPC_WorkloadStatusStreamClient 

type CoreRPC_WorkloadStatusStreamClient interface {
	Recv() (*WorkloadStatusStreamMessage, error)
	grpc.ClientStream
}

type CoreRPC_WorkloadStatusStreamServer 

type CoreRPC_WorkloadStatusStreamServer interface {
	Send(*WorkloadStatusStreamMessage) error
	grpc.ServerStream
}

type CreateWorkloadMessage 

type CreateWorkloadMessage struct {
	Podname   string            `protobuf:"bytes,1001,opt,name=podname,proto3" json:"podname,omitempty"`
	Nodename  string            `protobuf:"bytes,1002,opt,name=nodename,proto3" json:"nodename,omitempty"`
	Id        string            `protobuf:"bytes,1003,opt,name=id,proto3" json:"id,omitempty"`
	Name      string            `protobuf:"bytes,1004,opt,name=name,proto3" json:"name,omitempty"`
	Error     string            `protobuf:"bytes,1005,opt,name=error,proto3" json:"error,omitempty"`
	Success   bool              `protobuf:"varint,1006,opt,name=success,proto3" json:"success,omitempty"`
	Publish   map[string]string `` /* 158-byte string literal not displayed */
	Hook      []byte            `protobuf:"bytes,1008,opt,name=hook,proto3" json:"hook,omitempty"`
	Resources string            `protobuf:"bytes,1009,opt,name=resources,proto3" json:"resources,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateWorkloadMessage) Descriptor deprecated 

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

Deprecated: Use CreateWorkloadMessage.ProtoReflect.Descriptor instead.

func (*CreateWorkloadMessage) GetError 

func (x *CreateWorkloadMessage) GetError() string

func (*CreateWorkloadMessage) GetHook 

func (x *CreateWorkloadMessage) GetHook() []byte

func (*CreateWorkloadMessage) GetId 

func (x *CreateWorkloadMessage) GetId() string

func (*CreateWorkloadMessage) GetName 

func (x *CreateWorkloadMessage) GetName() string

func (*CreateWorkloadMessage) GetNodename 

func (x *CreateWorkloadMessage) GetNodename() string

func (*CreateWorkloadMessage) GetPodname 

func (x *CreateWorkloadMessage) GetPodname() string

func (*CreateWorkloadMessage) GetPublish 

func (x *CreateWorkloadMessage) GetPublish() map[string]string

func (*CreateWorkloadMessage) GetResources 

func (x *CreateWorkloadMessage) GetResources() string

func (*CreateWorkloadMessage) GetSuccess 

func (x *CreateWorkloadMessage) GetSuccess() bool

func (*CreateWorkloadMessage) ProtoMessage 

func (*CreateWorkloadMessage) ProtoMessage()

func (*CreateWorkloadMessage) ProtoReflect 

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

func (*CreateWorkloadMessage) Reset 

func (x *CreateWorkloadMessage) Reset()

func (*CreateWorkloadMessage) String 

func (x *CreateWorkloadMessage) String() string

type DeployOptions 

type DeployOptions struct {
	Name           string                 `protobuf:"bytes,1001,opt,name=name,proto3" json:"name,omitempty"`
	Entrypoint     *EntrypointOptions     `protobuf:"bytes,1002,opt,name=entrypoint,proto3" json:"entrypoint,omitempty"`
	Podname        string                 `protobuf:"bytes,1003,opt,name=podname,proto3" json:"podname,omitempty"`
	Nodenames      []string               `protobuf:"bytes,1004,rep,name=nodenames,proto3" json:"nodenames,omitempty"`
	Image          string                 `protobuf:"bytes,1005,opt,name=image,proto3" json:"image,omitempty"`
	ExtraArgs      string                 `protobuf:"bytes,1006,opt,name=extra_args,json=extraArgs,proto3" json:"extra_args,omitempty"`
	Count          int32                  `protobuf:"varint,1007,opt,name=count,proto3" json:"count,omitempty"`
	Env            []string               `protobuf:"bytes,1008,rep,name=env,proto3" json:"env,omitempty"`
	Dns            []string               `protobuf:"bytes,1009,rep,name=dns,proto3" json:"dns,omitempty"`
	ExtraHosts     []string               `protobuf:"bytes,1010,rep,name=extra_hosts,json=extraHosts,proto3" json:"extra_hosts,omitempty"`
	Networks       map[string]string      `` /* 160-byte string literal not displayed */
	User           string                 `protobuf:"bytes,1013,opt,name=user,proto3" json:"user,omitempty"`
	Debug          bool                   `protobuf:"varint,1014,opt,name=debug,proto3" json:"debug,omitempty"`
	OpenStdin      bool                   `protobuf:"varint,1015,opt,name=open_stdin,json=openStdin,proto3" json:"open_stdin,omitempty"`
	Labels         map[string]string      `` /* 156-byte string literal not displayed */
	Nodelabels     map[string]string      `` /* 164-byte string literal not displayed */
	DeployStrategy DeployOptions_Strategy `` /* 138-byte string literal not displayed */
	Data           map[string][]byte      `` /* 152-byte string literal not displayed */
	NodesLimit     int32                  `protobuf:"varint,1020,opt,name=nodes_limit,json=nodesLimit,proto3" json:"nodes_limit,omitempty"`
	IgnoreHook     bool                   `protobuf:"varint,1021,opt,name=ignore_hook,json=ignoreHook,proto3" json:"ignore_hook,omitempty"`
	AfterCreate    []string               `protobuf:"bytes,1022,rep,name=after_create,json=afterCreate,proto3" json:"after_create,omitempty"`
	RawArgs        []byte                 `protobuf:"bytes,1023,opt,name=raw_args,json=rawArgs,proto3" json:"raw_args,omitempty"`
	NodeFilter     *NodeFilter            `protobuf:"bytes,1024,opt,name=node_filter,json=nodeFilter,proto3" json:"node_filter,omitempty"`
	Modes          map[string]*FileMode   `` /* 154-byte string literal not displayed */
	Owners         map[string]*FileOwner  `` /* 156-byte string literal not displayed */
	Resources      map[string][]byte      `` /* 162-byte string literal not displayed */
	IgnorePull     bool                   `protobuf:"varint,1028,opt,name=ignore_pull,json=ignorePull,proto3" json:"ignore_pull,omitempty"`
	// contains filtered or unexported fields
}

func (*DeployOptions) Descriptor deprecated 

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

Deprecated: Use DeployOptions.ProtoReflect.Descriptor instead.

func (*DeployOptions) GetAfterCreate 

func (x *DeployOptions) GetAfterCreate() []string

func (*DeployOptions) GetCount 

func (x *DeployOptions) GetCount() int32

func (*DeployOptions) GetData 

func (x *DeployOptions) GetData() map[string][]byte

func (*DeployOptions) GetDebug 

func (x *DeployOptions) GetDebug() bool

func (*DeployOptions) GetDeployStrategy 

func (x *DeployOptions) GetDeployStrategy() DeployOptions_Strategy

func (*DeployOptions) GetDns 

func (x *DeployOptions) GetDns() []string

func (*DeployOptions) GetEntrypoint 

func (x *DeployOptions) GetEntrypoint() *EntrypointOptions

func (*DeployOptions) GetEnv 

func (x *DeployOptions) GetEnv() []string

func (*DeployOptions) GetExtraArgs 

func (x *DeployOptions) GetExtraArgs() string

func (*DeployOptions) GetExtraHosts 

func (x *DeployOptions) GetExtraHosts() []string

func (*DeployOptions) GetIgnoreHook 

func (x *DeployOptions) GetIgnoreHook() bool

func (*DeployOptions) GetIgnorePull 

func (x *DeployOptions) GetIgnorePull() bool

func (*DeployOptions) GetImage 

func (x *DeployOptions) GetImage() string

func (*DeployOptions) GetLabels 

func (x *DeployOptions) GetLabels() map[string]string

func (*DeployOptions) GetModes 

func (x *DeployOptions) GetModes() map[string]*FileMode

func (*DeployOptions) GetName 

func (x *DeployOptions) GetName() string

func (*DeployOptions) GetNetworks 

func (x *DeployOptions) GetNetworks() map[string]string

func (*DeployOptions) GetNodeFilter 

func (x *DeployOptions) GetNodeFilter() *NodeFilter

func (*DeployOptions) GetNodelabels 

func (x *DeployOptions) GetNodelabels() map[string]string

func (*DeployOptions) GetNodenames 

func (x *DeployOptions) GetNodenames() []string

func (*DeployOptions) GetNodesLimit 

func (x *DeployOptions) GetNodesLimit() int32

func (*DeployOptions) GetOpenStdin 

func (x *DeployOptions) GetOpenStdin() bool

func (*DeployOptions) GetOwners 

func (x *DeployOptions) GetOwners() map[string]*FileOwner

func (*DeployOptions) GetPodname 

func (x *DeployOptions) GetPodname() string

func (*DeployOptions) GetRawArgs 

func (x *DeployOptions) GetRawArgs() []byte

func (*DeployOptions) GetResources 

func (x *DeployOptions) GetResources() map[string][]byte

func (*DeployOptions) GetUser 

func (x *DeployOptions) GetUser() string

func (*DeployOptions) ProtoMessage 

func (*DeployOptions) ProtoMessage()

func (*DeployOptions) ProtoReflect 

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

func (*DeployOptions) Reset 

func (x *DeployOptions) Reset()

func (*DeployOptions) String 

func (x *DeployOptions) String() string

type DeployOptions_Strategy 

type DeployOptions_Strategy int32
const (
	DeployOptions_AUTO    DeployOptions_Strategy = 0
	DeployOptions_FILL    DeployOptions_Strategy = 1
	DeployOptions_EACH    DeployOptions_Strategy = 2
	DeployOptions_GLOBAL  DeployOptions_Strategy = 3
	DeployOptions_DRAINED DeployOptions_Strategy = 4
	DeployOptions_DUMMY   DeployOptions_Strategy = 99
)

func (DeployOptions_Strategy) Descriptor 

func (DeployOptions_Strategy) Descriptor() protoreflect.EnumDescriptor

func (DeployOptions_Strategy) Enum 

func (x DeployOptions_Strategy) Enum() *DeployOptions_Strategy

func (DeployOptions_Strategy) EnumDescriptor deprecated 

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

Deprecated: Use DeployOptions_Strategy.Descriptor instead.

func (DeployOptions_Strategy) Number 

func (x DeployOptions_Strategy) Number() protoreflect.EnumNumber

func (DeployOptions_Strategy) String 

func (x DeployOptions_Strategy) String() string

func (DeployOptions_Strategy) Type 

func (DeployOptions_Strategy) Type() protoreflect.EnumType

type DisconnectNetworkOptions 

type DisconnectNetworkOptions struct {
	Network string `protobuf:"bytes,1001,opt,name=network,proto3" json:"network,omitempty"`
	Target  string `protobuf:"bytes,1002,opt,name=target,proto3" json:"target,omitempty"`
	Force   bool   `protobuf:"varint,1003,opt,name=force,proto3" json:"force,omitempty"`
	// contains filtered or unexported fields
}

func (*DisconnectNetworkOptions) Descriptor deprecated 

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

Deprecated: Use DisconnectNetworkOptions.ProtoReflect.Descriptor instead.

func (*DisconnectNetworkOptions) GetForce 

func (x *DisconnectNetworkOptions) GetForce() bool

func (*DisconnectNetworkOptions) GetNetwork 

func (x *DisconnectNetworkOptions) GetNetwork() string

func (*DisconnectNetworkOptions) GetTarget 

func (x *DisconnectNetworkOptions) GetTarget() string

func (*DisconnectNetworkOptions) ProtoMessage 

func (*DisconnectNetworkOptions) ProtoMessage()

func (*DisconnectNetworkOptions) ProtoReflect 

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

func (*DisconnectNetworkOptions) Reset 

func (x *DisconnectNetworkOptions) Reset()

func (*DisconnectNetworkOptions) String 

func (x *DisconnectNetworkOptions) String() string

type DissociateWorkloadMessage 

type DissociateWorkloadMessage struct {
	Id    string `protobuf:"bytes,1001,opt,name=id,proto3" json:"id,omitempty"`
	Error string `protobuf:"bytes,1002,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*DissociateWorkloadMessage) Descriptor deprecated 

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

Deprecated: Use DissociateWorkloadMessage.ProtoReflect.Descriptor instead.

func (*DissociateWorkloadMessage) GetError 

func (x *DissociateWorkloadMessage) GetError() string

func (*DissociateWorkloadMessage) GetId 

func (x *DissociateWorkloadMessage) GetId() string

func (*DissociateWorkloadMessage) ProtoMessage 

func (*DissociateWorkloadMessage) ProtoMessage()

func (*DissociateWorkloadMessage) ProtoReflect 

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

func (*DissociateWorkloadMessage) Reset 

func (x *DissociateWorkloadMessage) Reset()

func (*DissociateWorkloadMessage) String 

func (x *DissociateWorkloadMessage) String() string

type DissociateWorkloadOptions 

type DissociateWorkloadOptions struct {
	IDs []string `protobuf:"bytes,1001,rep,name=IDs,proto3" json:"IDs,omitempty"`
	// contains filtered or unexported fields
}

func (*DissociateWorkloadOptions) Descriptor deprecated 

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

Deprecated: Use DissociateWorkloadOptions.ProtoReflect.Descriptor instead.

func (*DissociateWorkloadOptions) GetIDs 

func (x *DissociateWorkloadOptions) GetIDs() []string

func (*DissociateWorkloadOptions) ProtoMessage 

func (*DissociateWorkloadOptions) ProtoMessage()

func (*DissociateWorkloadOptions) ProtoReflect 

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

func (*DissociateWorkloadOptions) Reset 

func (x *DissociateWorkloadOptions) Reset()

func (*DissociateWorkloadOptions) String 

func (x *DissociateWorkloadOptions) String() string

type Empty 

type Empty struct {
	// contains filtered or unexported fields
}

func (*Empty) Descriptor deprecated 

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

Deprecated: Use Empty.ProtoReflect.Descriptor instead.

func (*Empty) ProtoMessage 

func (*Empty) ProtoMessage()

func (*Empty) ProtoReflect 

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

func (*Empty) Reset 

func (x *Empty) Reset()

func (*Empty) String 

func (x *Empty) String() string

type Engine 

type Engine struct {
	Type string `protobuf:"bytes,1001,opt,name=type,proto3" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*Engine) Descriptor deprecated 

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

Deprecated: Use Engine.ProtoReflect.Descriptor instead.

func (*Engine) GetType 

func (x *Engine) GetType() string

func (*Engine) ProtoMessage 

func (*Engine) ProtoMessage()

func (*Engine) ProtoReflect 

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

func (*Engine) Reset 

func (x *Engine) Reset()

func (*Engine) String 

func (x *Engine) String() string

type EntrypointOptions 

type EntrypointOptions struct {
	Name string `protobuf:"bytes,1001,opt,name=name,proto3" json:"name,omitempty"`
	// `command` field is to be deprecated in favor of `commands` field
	Command     string              `protobuf:"bytes,1002,opt,name=command,proto3" json:"command,omitempty"`
	Privileged  bool                `protobuf:"varint,1003,opt,name=privileged,proto3" json:"privileged,omitempty"`
	Dir         string              `protobuf:"bytes,1004,opt,name=dir,proto3" json:"dir,omitempty"`
	Log         *LogOptions         `protobuf:"bytes,1005,opt,name=log,proto3" json:"log,omitempty"`
	Publish     []string            `protobuf:"bytes,1006,rep,name=publish,proto3" json:"publish,omitempty"`
	Healthcheck *HealthCheckOptions `protobuf:"bytes,1007,opt,name=healthcheck,proto3" json:"healthcheck,omitempty"`
	Hook        *HookOptions        `protobuf:"bytes,1008,opt,name=hook,proto3" json:"hook,omitempty"`
	Restart     string              `protobuf:"bytes,1009,opt,name=restart,proto3" json:"restart,omitempty"`
	Sysctls     map[string]string   `` /* 158-byte string literal not displayed */
	// `commands` is the new-style and preferable fields to specify process to run
	// to specify shell-like command such as `true && echo a > /dev/null`
	// please state the shell explicitly: ["sh", "-c", "true && echo a > /dev/null"]
	Commands []string `protobuf:"bytes,1011,rep,name=commands,proto3" json:"commands,omitempty"`
	// contains filtered or unexported fields
}

func (*EntrypointOptions) Descriptor deprecated 

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

Deprecated: Use EntrypointOptions.ProtoReflect.Descriptor instead.

func (*EntrypointOptions) GetCommand 

func (x *EntrypointOptions) GetCommand() string

func (*EntrypointOptions) GetCommands 

func (x *EntrypointOptions) GetCommands() []string

func (*EntrypointOptions) GetDir 

func (x *EntrypointOptions) GetDir() string

func (*EntrypointOptions) GetHealthcheck 

func (x *EntrypointOptions) GetHealthcheck() *HealthCheckOptions

func (*EntrypointOptions) GetHook 

func (x *EntrypointOptions) GetHook() *HookOptions

func (*EntrypointOptions) GetLog 

func (x *EntrypointOptions) GetLog() *LogOptions

func (*EntrypointOptions) GetName 

func (x *EntrypointOptions) GetName() string

func (*EntrypointOptions) GetPrivileged 

func (x *EntrypointOptions) GetPrivileged() bool

func (*EntrypointOptions) GetPublish 

func (x *EntrypointOptions) GetPublish() []string

func (*EntrypointOptions) GetRestart 

func (x *EntrypointOptions) GetRestart() string

func (*EntrypointOptions) GetSysctls 

func (x *EntrypointOptions) GetSysctls() map[string]string

func (*EntrypointOptions) ProtoMessage 

func (*EntrypointOptions) ProtoMessage()

func (*EntrypointOptions) ProtoReflect 

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

func (*EntrypointOptions) Reset 

func (x *EntrypointOptions) Reset()

func (*EntrypointOptions) String 

func (x *EntrypointOptions) String() string

type ErrorDetail 

type ErrorDetail struct {
	Code    int64  `protobuf:"varint,1001,opt,name=code,proto3" json:"code,omitempty"`
	Message string `protobuf:"bytes,1002,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*ErrorDetail) Descriptor deprecated 

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

Deprecated: Use ErrorDetail.ProtoReflect.Descriptor instead.

func (*ErrorDetail) GetCode 

func (x *ErrorDetail) GetCode() int64

func (*ErrorDetail) GetMessage 

func (x *ErrorDetail) GetMessage() string

func (*ErrorDetail) ProtoMessage 

func (*ErrorDetail) ProtoMessage()

func (*ErrorDetail) ProtoReflect 

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

func (*ErrorDetail) Reset 

func (x *ErrorDetail) Reset()

func (*ErrorDetail) String 

func (x *ErrorDetail) String() string

type ExecuteWorkloadOptions 

type ExecuteWorkloadOptions struct {
	WorkloadId string   `protobuf:"bytes,1001,opt,name=workload_id,json=workloadId,proto3" json:"workload_id,omitempty"`
	Commands   []string `protobuf:"bytes,1002,rep,name=commands,proto3" json:"commands,omitempty"`
	Envs       []string `protobuf:"bytes,1003,rep,name=envs,proto3" json:"envs,omitempty"`
	Workdir    string   `protobuf:"bytes,1004,opt,name=workdir,proto3" json:"workdir,omitempty"`
	OpenStdin  bool     `protobuf:"varint,1005,opt,name=open_stdin,json=openStdin,proto3" json:"open_stdin,omitempty"`
	ReplCmd    []byte   `protobuf:"bytes,1006,opt,name=repl_cmd,json=replCmd,proto3" json:"repl_cmd,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecuteWorkloadOptions) Descriptor deprecated 

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

Deprecated: Use ExecuteWorkloadOptions.ProtoReflect.Descriptor instead.

func (*ExecuteWorkloadOptions) GetCommands 

func (x *ExecuteWorkloadOptions) GetCommands() []string

func (*ExecuteWorkloadOptions) GetEnvs 

func (x *ExecuteWorkloadOptions) GetEnvs() []string

func (*ExecuteWorkloadOptions) GetOpenStdin 

func (x *ExecuteWorkloadOptions) GetOpenStdin() bool

func (*ExecuteWorkloadOptions) GetReplCmd 

func (x *ExecuteWorkloadOptions) GetReplCmd() []byte

func (*ExecuteWorkloadOptions) GetWorkdir 

func (x *ExecuteWorkloadOptions) GetWorkdir() string

func (*ExecuteWorkloadOptions) GetWorkloadId 

func (x *ExecuteWorkloadOptions) GetWorkloadId() string

func (*ExecuteWorkloadOptions) ProtoMessage 

func (*ExecuteWorkloadOptions) ProtoMessage()

func (*ExecuteWorkloadOptions) ProtoReflect 

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

func (*ExecuteWorkloadOptions) Reset 

func (x *ExecuteWorkloadOptions) Reset()

func (*ExecuteWorkloadOptions) String 

func (x *ExecuteWorkloadOptions) String() string

type FileMode 

type FileMode struct {
	Mode int64 `protobuf:"varint,1001,opt,name=mode,proto3" json:"mode,omitempty"`
	// contains filtered or unexported fields
}

func (*FileMode) Descriptor deprecated 

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

Deprecated: Use FileMode.ProtoReflect.Descriptor instead.

func (*FileMode) GetMode 

func (x *FileMode) GetMode() int64

func (*FileMode) ProtoMessage 

func (*FileMode) ProtoMessage()

func (*FileMode) ProtoReflect 

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

func (*FileMode) Reset 

func (x *FileMode) Reset()

func (*FileMode) String 

func (x *FileMode) String() string

type FileOptions 

type FileOptions struct {
	Ids   []string   `protobuf:"bytes,1,rep,name=ids,proto3" json:"ids,omitempty"`
	Dst   string     `protobuf:"bytes,2,opt,name=dst,proto3" json:"dst,omitempty"`
	Size  int64      `protobuf:"varint,3,opt,name=size,proto3" json:"size,omitempty"`
	Mode  *FileMode  `protobuf:"bytes,4,opt,name=mode,proto3" json:"mode,omitempty"`
	Owner *FileOwner `protobuf:"bytes,5,opt,name=owner,proto3" json:"owner,omitempty"`
	Chunk []byte     `protobuf:"bytes,6,opt,name=chunk,proto3" json:"chunk,omitempty"`
	// contains filtered or unexported fields
}

func (*FileOptions) Descriptor deprecated 

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

Deprecated: Use FileOptions.ProtoReflect.Descriptor instead.

func (*FileOptions) GetChunk 

func (x *FileOptions) GetChunk() []byte

func (*FileOptions) GetDst 

func (x *FileOptions) GetDst() string

func (*FileOptions) GetIds 

func (x *FileOptions) GetIds() []string

func (*FileOptions) GetMode 

func (x *FileOptions) GetMode() *FileMode

func (*FileOptions) GetOwner 

func (x *FileOptions) GetOwner() *FileOwner

func (*FileOptions) GetSize 

func (x *FileOptions) GetSize() int64

func (*FileOptions) ProtoMessage 

func (*FileOptions) ProtoMessage()

func (*FileOptions) ProtoReflect 

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

func (*FileOptions) Reset 

func (x *FileOptions) Reset()

func (*FileOptions) String 

func (x *FileOptions) String() string

type FileOwner 

type FileOwner struct {
	Uid int32 `protobuf:"varint,1001,opt,name=uid,proto3" json:"uid,omitempty"`
	Gid int32 `protobuf:"varint,1002,opt,name=gid,proto3" json:"gid,omitempty"`
	// contains filtered or unexported fields
}

func (*FileOwner) Descriptor deprecated 

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

Deprecated: Use FileOwner.ProtoReflect.Descriptor instead.

func (*FileOwner) GetGid 

func (x *FileOwner) GetGid() int32

func (*FileOwner) GetUid 

func (x *FileOwner) GetUid() int32

func (*FileOwner) ProtoMessage 

func (*FileOwner) ProtoMessage()

func (*FileOwner) ProtoReflect 

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

func (*FileOwner) Reset 

func (x *FileOwner) Reset()

func (*FileOwner) String 

func (x *FileOwner) String() string

type GetNodeOptions 

type GetNodeOptions struct {
	Nodename string            `protobuf:"bytes,1001,opt,name=nodename,proto3" json:"nodename,omitempty"`
	Labels   map[string]string `` /* 156-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*GetNodeOptions) Descriptor deprecated 

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

Deprecated: Use GetNodeOptions.ProtoReflect.Descriptor instead.

func (*GetNodeOptions) GetLabels 

func (x *GetNodeOptions) GetLabels() map[string]string

func (*GetNodeOptions) GetNodename 

func (x *GetNodeOptions) GetNodename() string

func (*GetNodeOptions) ProtoMessage 

func (*GetNodeOptions) ProtoMessage()

func (*GetNodeOptions) ProtoReflect 

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

func (*GetNodeOptions) Reset 

func (x *GetNodeOptions) Reset()

func (*GetNodeOptions) String 

func (x *GetNodeOptions) String() string

type GetNodeResourceOptions 

type GetNodeResourceOptions struct {
	Opts *GetNodeOptions `protobuf:"bytes,1001,opt,name=opts,proto3" json:"opts,omitempty"`
	Fix  bool            `protobuf:"varint,1002,opt,name=fix,proto3" json:"fix,omitempty"`
	// contains filtered or unexported fields
}

func (*GetNodeResourceOptions) Descriptor deprecated 

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

Deprecated: Use GetNodeResourceOptions.ProtoReflect.Descriptor instead.

func (*GetNodeResourceOptions) GetFix 

func (x *GetNodeResourceOptions) GetFix() bool

func (*GetNodeResourceOptions) GetOpts 

func (x *GetNodeResourceOptions) GetOpts() *GetNodeOptions

func (*GetNodeResourceOptions) ProtoMessage 

func (*GetNodeResourceOptions) ProtoMessage()

func (*GetNodeResourceOptions) ProtoReflect 

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

func (*GetNodeResourceOptions) Reset 

func (x *GetNodeResourceOptions) Reset()

func (*GetNodeResourceOptions) String 

func (x *GetNodeResourceOptions) String() string

type GetNodeStatusOptions 

type GetNodeStatusOptions struct {
	Nodename string `protobuf:"bytes,1001,opt,name=nodename,proto3" json:"nodename,omitempty"`
	// contains filtered or unexported fields
}

func (*GetNodeStatusOptions) Descriptor deprecated 

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

Deprecated: Use GetNodeStatusOptions.ProtoReflect.Descriptor instead.

func (*GetNodeStatusOptions) GetNodename 

func (x *GetNodeStatusOptions) GetNodename() string

func (*GetNodeStatusOptions) ProtoMessage 

func (*GetNodeStatusOptions) ProtoMessage()

func (*GetNodeStatusOptions) ProtoReflect 

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

func (*GetNodeStatusOptions) Reset 

func (x *GetNodeStatusOptions) Reset()

func (*GetNodeStatusOptions) String 

func (x *GetNodeStatusOptions) String() string

type GetPodOptions 

type GetPodOptions struct {
	Name string `protobuf:"bytes,1001,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*GetPodOptions) Descriptor deprecated 

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

Deprecated: Use GetPodOptions.ProtoReflect.Descriptor instead.

func (*GetPodOptions) GetName 

func (x *GetPodOptions) GetName() string

func (*GetPodOptions) ProtoMessage 

func (*GetPodOptions) ProtoMessage()

func (*GetPodOptions) ProtoReflect 

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

func (*GetPodOptions) Reset 

func (x *GetPodOptions) Reset()

func (*GetPodOptions) String 

func (x *GetPodOptions) String() string

type HealthCheckOptions 

type HealthCheckOptions struct {
	TcpPorts []string `protobuf:"bytes,1001,rep,name=tcp_ports,json=tcpPorts,proto3" json:"tcp_ports,omitempty"`
	HttpPort string   `protobuf:"bytes,1002,opt,name=http_port,json=httpPort,proto3" json:"http_port,omitempty"`
	Url      string   `protobuf:"bytes,1003,opt,name=url,proto3" json:"url,omitempty"`
	Code     int32    `protobuf:"varint,1004,opt,name=code,proto3" json:"code,omitempty"`
	// contains filtered or unexported fields
}

func (*HealthCheckOptions) Descriptor deprecated 

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

Deprecated: Use HealthCheckOptions.ProtoReflect.Descriptor instead.

func (*HealthCheckOptions) GetCode 

func (x *HealthCheckOptions) GetCode() int32

func (*HealthCheckOptions) GetHttpPort 

func (x *HealthCheckOptions) GetHttpPort() string

func (*HealthCheckOptions) GetTcpPorts 

func (x *HealthCheckOptions) GetTcpPorts() []string

func (*HealthCheckOptions) GetUrl 

func (x *HealthCheckOptions) GetUrl() string

func (*HealthCheckOptions) ProtoMessage 

func (*HealthCheckOptions) ProtoMessage()

func (*HealthCheckOptions) ProtoReflect 

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

func (*HealthCheckOptions) Reset 

func (x *HealthCheckOptions) Reset()

func (*HealthCheckOptions) String 

func (x *HealthCheckOptions) String() string

type HookOptions 

type HookOptions struct {
	AfterStart []string `protobuf:"bytes,1001,rep,name=after_start,json=afterStart,proto3" json:"after_start,omitempty"`
	BeforeStop []string `protobuf:"bytes,1002,rep,name=before_stop,json=beforeStop,proto3" json:"before_stop,omitempty"`
	Force      bool     `protobuf:"varint,1003,opt,name=force,proto3" json:"force,omitempty"`
	// contains filtered or unexported fields
}

func (*HookOptions) Descriptor deprecated 

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

Deprecated: Use HookOptions.ProtoReflect.Descriptor instead.

func (*HookOptions) GetAfterStart 

func (x *HookOptions) GetAfterStart() []string

func (*HookOptions) GetBeforeStop 

func (x *HookOptions) GetBeforeStop() []string

func (*HookOptions) GetForce 

func (x *HookOptions) GetForce() bool

func (*HookOptions) ProtoMessage 

func (*HookOptions) ProtoMessage()

func (*HookOptions) ProtoReflect 

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

func (*HookOptions) Reset 

func (x *HookOptions) Reset()

func (*HookOptions) String 

func (x *HookOptions) String() string

type ImageItem 

type ImageItem struct {
	Id   string   `protobuf:"bytes,1001,opt,name=id,proto3" json:"id,omitempty"`
	Tags []string `protobuf:"bytes,1002,rep,name=tags,proto3" json:"tags,omitempty"`
	// contains filtered or unexported fields
}

func (*ImageItem) Descriptor deprecated 

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

Deprecated: Use ImageItem.ProtoReflect.Descriptor instead.

func (*ImageItem) GetId 

func (x *ImageItem) GetId() string

func (*ImageItem) GetTags 

func (x *ImageItem) GetTags() []string

func (*ImageItem) ProtoMessage 

func (*ImageItem) ProtoMessage()

func (*ImageItem) ProtoReflect 

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

func (*ImageItem) Reset 

func (x *ImageItem) Reset()

func (*ImageItem) String 

func (x *ImageItem) String() string

type ListImageMessage 

type ListImageMessage struct {
	Images   []*ImageItem `protobuf:"bytes,1001,rep,name=images,proto3" json:"images,omitempty"`
	Nodename string       `protobuf:"bytes,1002,opt,name=nodename,proto3" json:"nodename,omitempty"`
	Err      string       `protobuf:"bytes,1003,opt,name=err,proto3" json:"err,omitempty"`
	// contains filtered or unexported fields
}

func (*ListImageMessage) Descriptor deprecated 

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

Deprecated: Use ListImageMessage.ProtoReflect.Descriptor instead.

func (*ListImageMessage) GetErr 

func (x *ListImageMessage) GetErr() string

func (*ListImageMessage) GetImages 

func (x *ListImageMessage) GetImages() []*ImageItem

func (*ListImageMessage) GetNodename 

func (x *ListImageMessage) GetNodename() string

func (*ListImageMessage) ProtoMessage 

func (*ListImageMessage) ProtoMessage()

func (*ListImageMessage) ProtoReflect 

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

func (*ListImageMessage) Reset 

func (x *ListImageMessage) Reset()

func (*ListImageMessage) String 

func (x *ListImageMessage) String() string

type ListImageOptions 

type ListImageOptions struct {
	Podname   string   `protobuf:"bytes,1001,opt,name=podname,proto3" json:"podname,omitempty"`
	Nodenames []string `protobuf:"bytes,1002,rep,name=nodenames,proto3" json:"nodenames,omitempty"`
	Filter    string   `protobuf:"bytes,1003,opt,name=filter,proto3" json:"filter,omitempty"`
	// contains filtered or unexported fields
}

func (*ListImageOptions) Descriptor deprecated 

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

Deprecated: Use ListImageOptions.ProtoReflect.Descriptor instead.

func (*ListImageOptions) GetFilter 

func (x *ListImageOptions) GetFilter() string

func (*ListImageOptions) GetNodenames 

func (x *ListImageOptions) GetNodenames() []string

func (*ListImageOptions) GetPodname 

func (x *ListImageOptions) GetPodname() string

func (*ListImageOptions) ProtoMessage 

func (*ListImageOptions) ProtoMessage()

func (*ListImageOptions) ProtoReflect 

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

func (*ListImageOptions) Reset 

func (x *ListImageOptions) Reset()

func (*ListImageOptions) String 

func (x *ListImageOptions) String() string

type ListNetworkOptions 

type ListNetworkOptions struct {
	Podname string `protobuf:"bytes,1001,opt,name=podname,proto3" json:"podname,omitempty"`
	Driver  string `protobuf:"bytes,1002,opt,name=driver,proto3" json:"driver,omitempty"`
	// contains filtered or unexported fields
}

func (*ListNetworkOptions) Descriptor deprecated 

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

Deprecated: Use ListNetworkOptions.ProtoReflect.Descriptor instead.

func (*ListNetworkOptions) GetDriver 

func (x *ListNetworkOptions) GetDriver() string

func (*ListNetworkOptions) GetPodname 

func (x *ListNetworkOptions) GetPodname() string

func (*ListNetworkOptions) ProtoMessage 

func (*ListNetworkOptions) ProtoMessage()

func (*ListNetworkOptions) ProtoReflect 

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

func (*ListNetworkOptions) Reset 

func (x *ListNetworkOptions) Reset()

func (*ListNetworkOptions) String 

func (x *ListNetworkOptions) String() string

type ListNodesOptions 

type ListNodesOptions struct {
	Podname         string            `protobuf:"bytes,1001,opt,name=podname,proto3" json:"podname,omitempty"`
	All             bool              `protobuf:"varint,1002,opt,name=all,proto3" json:"all,omitempty"`
	Labels          map[string]string `` /* 156-byte string literal not displayed */
	TimeoutInSecond int32             `protobuf:"varint,1004,opt,name=timeout_in_second,json=timeoutInSecond,proto3" json:"timeout_in_second,omitempty"`
	SkipInfo        bool              `protobuf:"varint,1005,opt,name=skip_info,json=skipInfo,proto3" json:"skip_info,omitempty"`
	// contains filtered or unexported fields
}

func (*ListNodesOptions) Descriptor deprecated 

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

Deprecated: Use ListNodesOptions.ProtoReflect.Descriptor instead.

func (*ListNodesOptions) GetAll 

func (x *ListNodesOptions) GetAll() bool

func (*ListNodesOptions) GetLabels 

func (x *ListNodesOptions) GetLabels() map[string]string

func (*ListNodesOptions) GetPodname 

func (x *ListNodesOptions) GetPodname() string

func (*ListNodesOptions) GetSkipInfo 

func (x *ListNodesOptions) GetSkipInfo() bool

func (*ListNodesOptions) GetTimeoutInSecond 

func (x *ListNodesOptions) GetTimeoutInSecond() int32

func (*ListNodesOptions) ProtoMessage 

func (*ListNodesOptions) ProtoMessage()

func (*ListNodesOptions) ProtoReflect 

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

func (*ListNodesOptions) Reset 

func (x *ListNodesOptions) Reset()

func (*ListNodesOptions) String 

func (x *ListNodesOptions) String() string

type ListWorkloadsOptions 

type ListWorkloadsOptions struct {
	Appname    string            `protobuf:"bytes,1001,opt,name=appname,proto3" json:"appname,omitempty"`
	Entrypoint string            `protobuf:"bytes,1002,opt,name=entrypoint,proto3" json:"entrypoint,omitempty"`
	Nodename   string            `protobuf:"bytes,1003,opt,name=nodename,proto3" json:"nodename,omitempty"`
	Labels     map[string]string `` /* 156-byte string literal not displayed */
	Limit      int64             `protobuf:"varint,1005,opt,name=limit,proto3" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

func (*ListWorkloadsOptions) Descriptor deprecated 

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

Deprecated: Use ListWorkloadsOptions.ProtoReflect.Descriptor instead.

func (*ListWorkloadsOptions) GetAppname 

func (x *ListWorkloadsOptions) GetAppname() string

func (*ListWorkloadsOptions) GetEntrypoint 

func (x *ListWorkloadsOptions) GetEntrypoint() string

func (*ListWorkloadsOptions) GetLabels 

func (x *ListWorkloadsOptions) GetLabels() map[string]string

func (*ListWorkloadsOptions) GetLimit 

func (x *ListWorkloadsOptions) GetLimit() int64

func (*ListWorkloadsOptions) GetNodename 

func (x *ListWorkloadsOptions) GetNodename() string

func (*ListWorkloadsOptions) ProtoMessage 

func (*ListWorkloadsOptions) ProtoMessage()

func (*ListWorkloadsOptions) ProtoReflect 

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

func (*ListWorkloadsOptions) Reset 

func (x *ListWorkloadsOptions) Reset()

func (*ListWorkloadsOptions) String 

func (x *ListWorkloadsOptions) String() string

type LogOptions 

type LogOptions struct {
	Type   string            `protobuf:"bytes,1001,opt,name=type,proto3" json:"type,omitempty"`
	Config map[string]string `` /* 156-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*LogOptions) Descriptor deprecated 

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

Deprecated: Use LogOptions.ProtoReflect.Descriptor instead.

func (*LogOptions) GetConfig 

func (x *LogOptions) GetConfig() map[string]string

func (*LogOptions) GetType 

func (x *LogOptions) GetType() string

func (*LogOptions) ProtoMessage 

func (*LogOptions) ProtoMessage()

func (*LogOptions) ProtoReflect 

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

func (*LogOptions) Reset 

func (x *LogOptions) Reset()

func (*LogOptions) String 

func (x *LogOptions) String() string

type LogStreamMessage 

type LogStreamMessage struct {
	Id            string        `protobuf:"bytes,1001,opt,name=id,proto3" json:"id,omitempty"`
	Error         string        `protobuf:"bytes,1002,opt,name=error,proto3" json:"error,omitempty"`
	Data          []byte        `protobuf:"bytes,1003,opt,name=data,proto3" json:"data,omitempty"`
	StdStreamType StdStreamType `` /* 128-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*LogStreamMessage) Descriptor deprecated 

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

Deprecated: Use LogStreamMessage.ProtoReflect.Descriptor instead.

func (*LogStreamMessage) GetData 

func (x *LogStreamMessage) GetData() []byte

func (*LogStreamMessage) GetError 

func (x *LogStreamMessage) GetError() string

func (*LogStreamMessage) GetId 

func (x *LogStreamMessage) GetId() string

func (*LogStreamMessage) GetStdStreamType 

func (x *LogStreamMessage) GetStdStreamType() StdStreamType

func (*LogStreamMessage) ProtoMessage 

func (*LogStreamMessage) ProtoMessage()

func (*LogStreamMessage) ProtoReflect 

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

func (*LogStreamMessage) Reset 

func (x *LogStreamMessage) Reset()

func (*LogStreamMessage) String 

func (x *LogStreamMessage) String() string

type LogStreamOptions 

type LogStreamOptions struct {
	Id     string `protobuf:"bytes,1001,opt,name=id,proto3" json:"id,omitempty"`
	Tail   string `protobuf:"bytes,1002,opt,name=tail,proto3" json:"tail,omitempty"`
	Since  string `protobuf:"bytes,1003,opt,name=since,proto3" json:"since,omitempty"`
	Until  string `protobuf:"bytes,1004,opt,name=until,proto3" json:"until,omitempty"`
	Follow bool   `protobuf:"varint,1005,opt,name=follow,proto3" json:"follow,omitempty"`
	// contains filtered or unexported fields
}

func (*LogStreamOptions) Descriptor deprecated 

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

Deprecated: Use LogStreamOptions.ProtoReflect.Descriptor instead.

func (*LogStreamOptions) GetFollow 

func (x *LogStreamOptions) GetFollow() bool

func (*LogStreamOptions) GetId 

func (x *LogStreamOptions) GetId() string

func (*LogStreamOptions) GetSince 

func (x *LogStreamOptions) GetSince() string

func (*LogStreamOptions) GetTail 

func (x *LogStreamOptions) GetTail() string

func (*LogStreamOptions) GetUntil 

func (x *LogStreamOptions) GetUntil() string

func (*LogStreamOptions) ProtoMessage 

func (*LogStreamOptions) ProtoMessage()

func (*LogStreamOptions) ProtoReflect 

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

func (*LogStreamOptions) Reset 

func (x *LogStreamOptions) Reset()

func (*LogStreamOptions) String 

func (x *LogStreamOptions) String() string

type Network 

type Network struct {
	Name    string   `protobuf:"bytes,1001,opt,name=name,proto3" json:"name,omitempty"`
	Subnets []string `protobuf:"bytes,1002,rep,name=subnets,proto3" json:"subnets,omitempty"`
	// contains filtered or unexported fields
}

func (*Network) Descriptor deprecated 

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

Deprecated: Use Network.ProtoReflect.Descriptor instead.

func (*Network) GetName 

func (x *Network) GetName() string

func (*Network) GetSubnets 

func (x *Network) GetSubnets() []string

func (*Network) ProtoMessage 

func (*Network) ProtoMessage()

func (*Network) ProtoReflect 

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

func (*Network) Reset 

func (x *Network) Reset()

func (*Network) String 

func (x *Network) String() string

type Networks 

type Networks struct {
	Networks []*Network `protobuf:"bytes,1001,rep,name=networks,proto3" json:"networks,omitempty"`
	// contains filtered or unexported fields
}

func (*Networks) Descriptor deprecated 

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

Deprecated: Use Networks.ProtoReflect.Descriptor instead.

func (*Networks) GetNetworks 

func (x *Networks) GetNetworks() []*Network

func (*Networks) ProtoMessage 

func (*Networks) ProtoMessage()

func (*Networks) ProtoReflect 

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

func (*Networks) Reset 

func (x *Networks) Reset()

func (*Networks) String 

func (x *Networks) String() string

type Node 

type Node struct {
	Name             string            `protobuf:"bytes,1001,opt,name=name,proto3" json:"name,omitempty"`
	Endpoint         string            `protobuf:"bytes,1002,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	Podname          string            `protobuf:"bytes,1003,opt,name=podname,proto3" json:"podname,omitempty"`
	Available        bool              `protobuf:"varint,1004,opt,name=available,proto3" json:"available,omitempty"`
	Bypass           bool              `protobuf:"varint,1005,opt,name=bypass,proto3" json:"bypass,omitempty"`
	Labels           map[string]string `` /* 156-byte string literal not displayed */
	Info             string            `protobuf:"bytes,1007,opt,name=info,proto3" json:"info,omitempty"`
	ResourceCapacity string            `protobuf:"bytes,1008,opt,name=resource_capacity,json=resourceCapacity,proto3" json:"resource_capacity,omitempty"`
	ResourceUsage    string            `protobuf:"bytes,1009,opt,name=resource_usage,json=resourceUsage,proto3" json:"resource_usage,omitempty"`
	Test             bool              `protobuf:"varint,1010,opt,name=test,proto3" json:"test,omitempty"`
	// contains filtered or unexported fields
}

func (*Node) Descriptor deprecated 

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

Deprecated: Use Node.ProtoReflect.Descriptor instead.

func (*Node) GetAvailable 

func (x *Node) GetAvailable() bool

func (*Node) GetBypass 

func (x *Node) GetBypass() bool

func (*Node) GetEndpoint 

func (x *Node) GetEndpoint() string

func (*Node) GetInfo 

func (x *Node) GetInfo() string

func (*Node) GetLabels 

func (x *Node) GetLabels() map[string]string

func (*Node) GetName 

func (x *Node) GetName() string

func (*Node) GetPodname 

func (x *Node) GetPodname() string

func (*Node) GetResourceCapacity 

func (x *Node) GetResourceCapacity() string

func (*Node) GetResourceUsage 

func (x *Node) GetResourceUsage() string

func (*Node) GetTest 

func (x *Node) GetTest() bool

func (*Node) ProtoMessage 

func (*Node) ProtoMessage()

func (*Node) ProtoReflect 

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

func (*Node) Reset 

func (x *Node) Reset()

func (*Node) String 

func (x *Node) String() string

type NodeFilter 

type NodeFilter struct {
	Includes []string          `protobuf:"bytes,1001,rep,name=includes,proto3" json:"includes,omitempty"`
	Excludes []string          `protobuf:"bytes,1002,rep,name=excludes,proto3" json:"excludes,omitempty"`
	Labels   map[string]string `` /* 156-byte string literal not displayed */
	All      bool              `protobuf:"varint,1004,opt,name=all,proto3" json:"all,omitempty"`
	// contains filtered or unexported fields
}

func (*NodeFilter) Descriptor deprecated 

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

Deprecated: Use NodeFilter.ProtoReflect.Descriptor instead.

func (*NodeFilter) GetAll 

func (x *NodeFilter) GetAll() bool

func (*NodeFilter) GetExcludes 

func (x *NodeFilter) GetExcludes() []string

func (*NodeFilter) GetIncludes 

func (x *NodeFilter) GetIncludes() []string

func (*NodeFilter) GetLabels 

func (x *NodeFilter) GetLabels() map[string]string

func (*NodeFilter) ProtoMessage 

func (*NodeFilter) ProtoMessage()

func (*NodeFilter) ProtoReflect 

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

func (*NodeFilter) Reset 

func (x *NodeFilter) Reset()

func (*NodeFilter) String 

func (x *NodeFilter) String() string

type NodeResource 

type NodeResource struct {
	Name             string   `protobuf:"bytes,1001,opt,name=name,proto3" json:"name,omitempty"`
	Diffs            []string `protobuf:"bytes,1002,rep,name=diffs,proto3" json:"diffs,omitempty"`
	ResourceCapacity string   `protobuf:"bytes,1003,opt,name=resource_capacity,json=resourceCapacity,proto3" json:"resource_capacity,omitempty"`
	ResourceUsage    string   `protobuf:"bytes,1004,opt,name=resource_usage,json=resourceUsage,proto3" json:"resource_usage,omitempty"`
	// contains filtered or unexported fields
}

func (*NodeResource) Descriptor deprecated 

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

Deprecated: Use NodeResource.ProtoReflect.Descriptor instead.

func (*NodeResource) GetDiffs 

func (x *NodeResource) GetDiffs() []string

func (*NodeResource) GetName 

func (x *NodeResource) GetName() string

func (*NodeResource) GetResourceCapacity 

func (x *NodeResource) GetResourceCapacity() string

func (*NodeResource) GetResourceUsage 

func (x *NodeResource) GetResourceUsage() string

func (*NodeResource) ProtoMessage 

func (*NodeResource) ProtoMessage()

func (*NodeResource) ProtoReflect 

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

func (*NodeResource) Reset 

func (x *NodeResource) Reset()

func (*NodeResource) String 

func (x *NodeResource) String() string

type NodeStatusStreamMessage 

type NodeStatusStreamMessage struct {
	Nodename string `protobuf:"bytes,1001,opt,name=nodename,proto3" json:"nodename,omitempty"`
	Podname  string `protobuf:"bytes,1002,opt,name=podname,proto3" json:"podname,omitempty"`
	Alive    bool   `protobuf:"varint,1003,opt,name=alive,proto3" json:"alive,omitempty"`
	Error    string `protobuf:"bytes,1004,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*NodeStatusStreamMessage) Descriptor deprecated 

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

Deprecated: Use NodeStatusStreamMessage.ProtoReflect.Descriptor instead.

func (*NodeStatusStreamMessage) GetAlive 

func (x *NodeStatusStreamMessage) GetAlive() bool

func (*NodeStatusStreamMessage) GetError 

func (x *NodeStatusStreamMessage) GetError() string

func (*NodeStatusStreamMessage) GetNodename 

func (x *NodeStatusStreamMessage) GetNodename() string

func (*NodeStatusStreamMessage) GetPodname 

func (x *NodeStatusStreamMessage) GetPodname() string

func (*NodeStatusStreamMessage) ProtoMessage 

func (*NodeStatusStreamMessage) ProtoMessage()

func (*NodeStatusStreamMessage) ProtoReflect 

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

func (*NodeStatusStreamMessage) Reset 

func (x *NodeStatusStreamMessage) Reset()

func (*NodeStatusStreamMessage) String 

func (x *NodeStatusStreamMessage) String() string

type Pod 

type Pod struct {
	Name string `protobuf:"bytes,1001,opt,name=name,proto3" json:"name,omitempty"`
	Desc string `protobuf:"bytes,1002,opt,name=desc,proto3" json:"desc,omitempty"`
	// contains filtered or unexported fields
}

对的, protobuf 就是这样...

func (*Pod) Descriptor deprecated 

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

Deprecated: Use Pod.ProtoReflect.Descriptor instead.

func (*Pod) GetDesc 

func (x *Pod) GetDesc() string

func (*Pod) GetName 

func (x *Pod) GetName() string

func (*Pod) ProtoMessage 

func (*Pod) ProtoMessage()

func (*Pod) ProtoReflect 

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

func (*Pod) Reset 

func (x *Pod) Reset()

func (*Pod) String 

func (x *Pod) String() string

type Pods 

type Pods struct {
	Pods []*Pod `protobuf:"bytes,1001,rep,name=pods,proto3" json:"pods,omitempty"`
	// contains filtered or unexported fields
}

func (*Pods) Descriptor deprecated 

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

Deprecated: Use Pods.ProtoReflect.Descriptor instead.

func (*Pods) GetPods 

func (x *Pods) GetPods() []*Pod

func (*Pods) ProtoMessage 

func (*Pods) ProtoMessage()

func (*Pods) ProtoReflect 

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

func (*Pods) Reset 

func (x *Pods) Reset()

func (*Pods) String 

func (x *Pods) String() string

type RawEngineMessage 

type RawEngineMessage struct {
	Id   string `protobuf:"bytes,1001,opt,name=id,proto3" json:"id,omitempty"`
	Data []byte `protobuf:"bytes,1002,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*RawEngineMessage) Descriptor deprecated 

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

Deprecated: Use RawEngineMessage.ProtoReflect.Descriptor instead.

func (*RawEngineMessage) GetData 

func (x *RawEngineMessage) GetData() []byte

func (*RawEngineMessage) GetId 

func (x *RawEngineMessage) GetId() string

func (*RawEngineMessage) ProtoMessage 

func (*RawEngineMessage) ProtoMessage()

func (*RawEngineMessage) ProtoReflect 

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

func (*RawEngineMessage) Reset 

func (x *RawEngineMessage) Reset()

func (*RawEngineMessage) String 

func (x *RawEngineMessage) String() string

type RawEngineOptions 

type RawEngineOptions struct {
	Id         string `protobuf:"bytes,1001,opt,name=id,proto3" json:"id,omitempty"`
	Op         string `protobuf:"bytes,1002,opt,name=op,proto3" json:"op,omitempty"`
	Params     []byte `protobuf:"bytes,1003,opt,name=params,proto3" json:"params,omitempty"`
	IgnoreLock bool   `protobuf:"varint,1004,opt,name=ignore_lock,json=ignoreLock,proto3" json:"ignore_lock,omitempty"`
	// contains filtered or unexported fields
}

func (*RawEngineOptions) Descriptor deprecated 

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

Deprecated: Use RawEngineOptions.ProtoReflect.Descriptor instead.

func (*RawEngineOptions) GetId 

func (x *RawEngineOptions) GetId() string

func (*RawEngineOptions) GetIgnoreLock 

func (x *RawEngineOptions) GetIgnoreLock() bool

func (*RawEngineOptions) GetOp 

func (x *RawEngineOptions) GetOp() string

func (*RawEngineOptions) GetParams 

func (x *RawEngineOptions) GetParams() []byte

func (*RawEngineOptions) ProtoMessage 

func (*RawEngineOptions) ProtoMessage()

func (*RawEngineOptions) ProtoReflect 

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

func (*RawEngineOptions) Reset 

func (x *RawEngineOptions) Reset()

func (*RawEngineOptions) String 

func (x *RawEngineOptions) String() string

type ReallocOptions 

type ReallocOptions struct {
	Id        string            `protobuf:"bytes,1001,opt,name=id,proto3" json:"id,omitempty"`
	Resources map[string][]byte `` /* 162-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ReallocOptions) Descriptor deprecated 

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

Deprecated: Use ReallocOptions.ProtoReflect.Descriptor instead.

func (*ReallocOptions) GetId 

func (x *ReallocOptions) GetId() string

func (*ReallocOptions) GetResources 

func (x *ReallocOptions) GetResources() map[string][]byte

func (*ReallocOptions) ProtoMessage 

func (*ReallocOptions) ProtoMessage()

func (*ReallocOptions) ProtoReflect 

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

func (*ReallocOptions) Reset 

func (x *ReallocOptions) Reset()

func (*ReallocOptions) String 

func (x *ReallocOptions) String() string

type ReallocResourceMessage 

type ReallocResourceMessage struct {
	Error string `protobuf:"bytes,1001,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*ReallocResourceMessage) Descriptor deprecated 

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

Deprecated: Use ReallocResourceMessage.ProtoReflect.Descriptor instead.

func (*ReallocResourceMessage) GetError 

func (x *ReallocResourceMessage) GetError() string

func (*ReallocResourceMessage) ProtoMessage 

func (*ReallocResourceMessage) ProtoMessage()

func (*ReallocResourceMessage) ProtoReflect 

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

func (*ReallocResourceMessage) Reset 

func (x *ReallocResourceMessage) Reset()

func (*ReallocResourceMessage) String 

func (x *ReallocResourceMessage) String() string

type RemoveImageMessage 

type RemoveImageMessage struct {
	Image    string   `protobuf:"bytes,1001,opt,name=image,proto3" json:"image,omitempty"`
	Success  bool     `protobuf:"varint,1002,opt,name=success,proto3" json:"success,omitempty"`
	Messages []string `protobuf:"bytes,1003,rep,name=messages,proto3" json:"messages,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoveImageMessage) Descriptor deprecated 

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

Deprecated: Use RemoveImageMessage.ProtoReflect.Descriptor instead.

func (*RemoveImageMessage) GetImage 

func (x *RemoveImageMessage) GetImage() string

func (*RemoveImageMessage) GetMessages 

func (x *RemoveImageMessage) GetMessages() []string

func (*RemoveImageMessage) GetSuccess 

func (x *RemoveImageMessage) GetSuccess() bool

func (*RemoveImageMessage) ProtoMessage 

func (*RemoveImageMessage) ProtoMessage()

func (*RemoveImageMessage) ProtoReflect 

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

func (*RemoveImageMessage) Reset 

func (x *RemoveImageMessage) Reset()

func (*RemoveImageMessage) String 

func (x *RemoveImageMessage) String() string

type RemoveImageOptions 

type RemoveImageOptions struct {
	Podname   string   `protobuf:"bytes,1001,opt,name=podname,proto3" json:"podname,omitempty"`
	Nodenames []string `protobuf:"bytes,1002,rep,name=nodenames,proto3" json:"nodenames,omitempty"`
	Images    []string `protobuf:"bytes,1003,rep,name=images,proto3" json:"images,omitempty"`
	Prune     bool     `protobuf:"varint,1005,opt,name=prune,proto3" json:"prune,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoveImageOptions) Descriptor deprecated 

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

Deprecated: Use RemoveImageOptions.ProtoReflect.Descriptor instead.

func (*RemoveImageOptions) GetImages 

func (x *RemoveImageOptions) GetImages() []string

func (*RemoveImageOptions) GetNodenames 

func (x *RemoveImageOptions) GetNodenames() []string

func (*RemoveImageOptions) GetPodname 

func (x *RemoveImageOptions) GetPodname() string

func (*RemoveImageOptions) GetPrune 

func (x *RemoveImageOptions) GetPrune() bool

func (*RemoveImageOptions) ProtoMessage 

func (*RemoveImageOptions) ProtoMessage()

func (*RemoveImageOptions) ProtoReflect 

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

func (*RemoveImageOptions) Reset 

func (x *RemoveImageOptions) Reset()

func (*RemoveImageOptions) String 

func (x *RemoveImageOptions) String() string

type RemoveNodeOptions 

type RemoveNodeOptions struct {
	Nodename string `protobuf:"bytes,1001,opt,name=nodename,proto3" json:"nodename,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoveNodeOptions) Descriptor deprecated 

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

Deprecated: Use RemoveNodeOptions.ProtoReflect.Descriptor instead.

func (*RemoveNodeOptions) GetNodename 

func (x *RemoveNodeOptions) GetNodename() string

func (*RemoveNodeOptions) ProtoMessage 

func (*RemoveNodeOptions) ProtoMessage()

func (*RemoveNodeOptions) ProtoReflect 

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

func (*RemoveNodeOptions) Reset 

func (x *RemoveNodeOptions) Reset()

func (*RemoveNodeOptions) String 

func (x *RemoveNodeOptions) String() string

type RemovePodOptions 

type RemovePodOptions struct {
	Name string `protobuf:"bytes,1001,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*RemovePodOptions) Descriptor deprecated 

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

Deprecated: Use RemovePodOptions.ProtoReflect.Descriptor instead.

func (*RemovePodOptions) GetName 

func (x *RemovePodOptions) GetName() string

func (*RemovePodOptions) ProtoMessage 

func (*RemovePodOptions) ProtoMessage()

func (*RemovePodOptions) ProtoReflect 

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

func (*RemovePodOptions) Reset 

func (x *RemovePodOptions) Reset()

func (*RemovePodOptions) String 

func (x *RemovePodOptions) String() string

type RemoveWorkloadMessage 

type RemoveWorkloadMessage struct {
	Id      string `protobuf:"bytes,1001,opt,name=id,proto3" json:"id,omitempty"`
	Success bool   `protobuf:"varint,1002,opt,name=success,proto3" json:"success,omitempty"`
	Hook    string `protobuf:"bytes,1003,opt,name=hook,proto3" json:"hook,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoveWorkloadMessage) Descriptor deprecated 

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

Deprecated: Use RemoveWorkloadMessage.ProtoReflect.Descriptor instead.

func (*RemoveWorkloadMessage) GetHook 

func (x *RemoveWorkloadMessage) GetHook() string

func (*RemoveWorkloadMessage) GetId 

func (x *RemoveWorkloadMessage) GetId() string

func (*RemoveWorkloadMessage) GetSuccess 

func (x *RemoveWorkloadMessage) GetSuccess() bool

func (*RemoveWorkloadMessage) ProtoMessage 

func (*RemoveWorkloadMessage) ProtoMessage()

func (*RemoveWorkloadMessage) ProtoReflect 

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

func (*RemoveWorkloadMessage) Reset 

func (x *RemoveWorkloadMessage) Reset()

func (*RemoveWorkloadMessage) String 

func (x *RemoveWorkloadMessage) String() string

type RemoveWorkloadOptions 

type RemoveWorkloadOptions struct {
	IDs   []string `protobuf:"bytes,1001,rep,name=IDs,proto3" json:"IDs,omitempty"`
	Force bool     `protobuf:"varint,1002,opt,name=force,proto3" json:"force,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoveWorkloadOptions) Descriptor deprecated 

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

Deprecated: Use RemoveWorkloadOptions.ProtoReflect.Descriptor instead.

func (*RemoveWorkloadOptions) GetForce 

func (x *RemoveWorkloadOptions) GetForce() bool

func (*RemoveWorkloadOptions) GetIDs 

func (x *RemoveWorkloadOptions) GetIDs() []string

func (*RemoveWorkloadOptions) ProtoMessage 

func (*RemoveWorkloadOptions) ProtoMessage()

func (*RemoveWorkloadOptions) ProtoReflect 

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

func (*RemoveWorkloadOptions) Reset 

func (x *RemoveWorkloadOptions) Reset()

func (*RemoveWorkloadOptions) String 

func (x *RemoveWorkloadOptions) String() string

type ReplaceOptions 

type ReplaceOptions struct {
	DeployOpt      *DeployOptions    `protobuf:"bytes,1001,opt,name=deployOpt,proto3" json:"deployOpt,omitempty"`
	Networkinherit bool              `protobuf:"varint,1002,opt,name=networkinherit,proto3" json:"networkinherit,omitempty"`
	FilterLabels   map[string]string `` /* 188-byte string literal not displayed */
	Copy           map[string]string `` /* 152-byte string literal not displayed */
	IDs            []string          `protobuf:"bytes,5100,rep,name=IDs,proto3" json:"IDs,omitempty"`
	// contains filtered or unexported fields
}

func (*ReplaceOptions) Descriptor deprecated 

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

Deprecated: Use ReplaceOptions.ProtoReflect.Descriptor instead.

func (*ReplaceOptions) GetCopy 

func (x *ReplaceOptions) GetCopy() map[string]string

func (*ReplaceOptions) GetDeployOpt 

func (x *ReplaceOptions) GetDeployOpt() *DeployOptions

func (*ReplaceOptions) GetFilterLabels 

func (x *ReplaceOptions) GetFilterLabels() map[string]string

func (*ReplaceOptions) GetIDs 

func (x *ReplaceOptions) GetIDs() []string

func (*ReplaceOptions) GetNetworkinherit 

func (x *ReplaceOptions) GetNetworkinherit() bool

func (*ReplaceOptions) ProtoMessage 

func (*ReplaceOptions) ProtoMessage()

func (*ReplaceOptions) ProtoReflect 

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

func (*ReplaceOptions) Reset 

func (x *ReplaceOptions) Reset()

func (*ReplaceOptions) String 

func (x *ReplaceOptions) String() string

type ReplaceWorkloadMessage 

type ReplaceWorkloadMessage struct {
	Create *CreateWorkloadMessage `protobuf:"bytes,1001,opt,name=create,proto3" json:"create,omitempty"`
	Remove *RemoveWorkloadMessage `protobuf:"bytes,1002,opt,name=remove,proto3" json:"remove,omitempty"`
	Error  string                 `protobuf:"bytes,1003,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*ReplaceWorkloadMessage) Descriptor deprecated 

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

Deprecated: Use ReplaceWorkloadMessage.ProtoReflect.Descriptor instead.

func (*ReplaceWorkloadMessage) GetCreate 

func (x *ReplaceWorkloadMessage) GetCreate() *CreateWorkloadMessage

func (*ReplaceWorkloadMessage) GetError 

func (x *ReplaceWorkloadMessage) GetError() string

func (*ReplaceWorkloadMessage) GetRemove 

func (x *ReplaceWorkloadMessage) GetRemove() *RemoveWorkloadMessage

func (*ReplaceWorkloadMessage) ProtoMessage 

func (*ReplaceWorkloadMessage) ProtoMessage()

func (*ReplaceWorkloadMessage) ProtoReflect 

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

func (*ReplaceWorkloadMessage) Reset 

func (x *ReplaceWorkloadMessage) Reset()

func (*ReplaceWorkloadMessage) String 

func (x *ReplaceWorkloadMessage) String() string

type RunAndWaitOptions 

type RunAndWaitOptions struct {
	DeployOptions *DeployOptions `protobuf:"bytes,1001,opt,name=deploy_options,json=deployOptions,proto3" json:"deploy_options,omitempty"`
	Cmd           []byte         `protobuf:"bytes,1002,opt,name=cmd,proto3" json:"cmd,omitempty"`
	Async         bool           `protobuf:"varint,1003,opt,name=async,proto3" json:"async,omitempty"`
	AsyncTimeout  int32          `protobuf:"varint,1004,opt,name=async_timeout,json=asyncTimeout,proto3" json:"async_timeout,omitempty"`
	// contains filtered or unexported fields
}

func (*RunAndWaitOptions) Descriptor deprecated 

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

Deprecated: Use RunAndWaitOptions.ProtoReflect.Descriptor instead.

func (*RunAndWaitOptions) GetAsync 

func (x *RunAndWaitOptions) GetAsync() bool

func (*RunAndWaitOptions) GetAsyncTimeout 

func (x *RunAndWaitOptions) GetAsyncTimeout() int32

func (*RunAndWaitOptions) GetCmd 

func (x *RunAndWaitOptions) GetCmd() []byte

func (*RunAndWaitOptions) GetDeployOptions 

func (x *RunAndWaitOptions) GetDeployOptions() *DeployOptions

func (*RunAndWaitOptions) ProtoMessage 

func (*RunAndWaitOptions) ProtoMessage()

func (*RunAndWaitOptions) ProtoReflect 

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

func (*RunAndWaitOptions) Reset 

func (x *RunAndWaitOptions) Reset()

func (*RunAndWaitOptions) String 

func (x *RunAndWaitOptions) String() string

type SendMessage 

type SendMessage struct {
	Id    string `protobuf:"bytes,1001,opt,name=id,proto3" json:"id,omitempty"`
	Path  string `protobuf:"bytes,1002,opt,name=path,proto3" json:"path,omitempty"`
	Error string `protobuf:"bytes,1003,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*SendMessage) Descriptor deprecated 

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

Deprecated: Use SendMessage.ProtoReflect.Descriptor instead.

func (*SendMessage) GetError 

func (x *SendMessage) GetError() string

func (*SendMessage) GetId 

func (x *SendMessage) GetId() string

func (*SendMessage) GetPath 

func (x *SendMessage) GetPath() string

func (*SendMessage) ProtoMessage 

func (*SendMessage) ProtoMessage()

func (*SendMessage) ProtoReflect 

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

func (*SendMessage) Reset 

func (x *SendMessage) Reset()

func (*SendMessage) String 

func (x *SendMessage) String() string

type SendOptions 

type SendOptions struct {
	IDs    []string              `protobuf:"bytes,1001,rep,name=IDs,proto3" json:"IDs,omitempty"`
	Data   map[string][]byte     `` /* 152-byte string literal not displayed */
	Modes  map[string]*FileMode  `` /* 154-byte string literal not displayed */
	Owners map[string]*FileOwner `` /* 156-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*SendOptions) Descriptor deprecated 

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

Deprecated: Use SendOptions.ProtoReflect.Descriptor instead.

func (*SendOptions) GetData 

func (x *SendOptions) GetData() map[string][]byte

func (*SendOptions) GetIDs 

func (x *SendOptions) GetIDs() []string

func (*SendOptions) GetModes 

func (x *SendOptions) GetModes() map[string]*FileMode

func (*SendOptions) GetOwners 

func (x *SendOptions) GetOwners() map[string]*FileOwner

func (*SendOptions) ProtoMessage 

func (*SendOptions) ProtoMessage()

func (*SendOptions) ProtoReflect 

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

func (*SendOptions) Reset 

func (x *SendOptions) Reset()

func (*SendOptions) String 

func (x *SendOptions) String() string

type ServiceStatus 

type ServiceStatus struct {
	Addresses        []string `protobuf:"bytes,1001,rep,name=addresses,proto3" json:"addresses,omitempty"`
	IntervalInSecond int64    `protobuf:"varint,1002,opt,name=interval_in_second,json=intervalInSecond,proto3" json:"interval_in_second,omitempty"`
	// contains filtered or unexported fields
}

func (*ServiceStatus) Descriptor deprecated 

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

Deprecated: Use ServiceStatus.ProtoReflect.Descriptor instead.

func (*ServiceStatus) GetAddresses 

func (x *ServiceStatus) GetAddresses() []string

func (*ServiceStatus) GetIntervalInSecond 

func (x *ServiceStatus) GetIntervalInSecond() int64

func (*ServiceStatus) ProtoMessage 

func (*ServiceStatus) ProtoMessage()

func (*ServiceStatus) ProtoReflect 

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

func (*ServiceStatus) Reset 

func (x *ServiceStatus) Reset()

func (*ServiceStatus) String 

func (x *ServiceStatus) String() string

type SetNodeOptions 

type SetNodeOptions struct {
	Nodename      string            `protobuf:"bytes,1001,opt,name=nodename,proto3" json:"nodename,omitempty"`
	Endpoint      string            `protobuf:"bytes,1002,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	Ca            string            `protobuf:"bytes,1003,opt,name=ca,proto3" json:"ca,omitempty"`
	Cert          string            `protobuf:"bytes,1004,opt,name=cert,proto3" json:"cert,omitempty"`
	Key           string            `protobuf:"bytes,1005,opt,name=key,proto3" json:"key,omitempty"`
	Labels        map[string]string `` /* 156-byte string literal not displayed */
	Resources     map[string][]byte `` /* 162-byte string literal not displayed */
	Delta         bool              `protobuf:"varint,1008,opt,name=delta,proto3" json:"delta,omitempty"`
	WorkloadsDown bool              `protobuf:"varint,1009,opt,name=workloads_down,json=workloadsDown,proto3" json:"workloads_down,omitempty"`
	Bypass        TriOpt            `protobuf:"varint,1010,opt,name=bypass,proto3,enum=pb.TriOpt" json:"bypass,omitempty"`
	// contains filtered or unexported fields
}

func (*SetNodeOptions) Descriptor deprecated 

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

Deprecated: Use SetNodeOptions.ProtoReflect.Descriptor instead.

func (*SetNodeOptions) GetBypass 

func (x *SetNodeOptions) GetBypass() TriOpt

func (*SetNodeOptions) GetCa 

func (x *SetNodeOptions) GetCa() string

func (*SetNodeOptions) GetCert 

func (x *SetNodeOptions) GetCert() string

func (*SetNodeOptions) GetDelta 

func (x *SetNodeOptions) GetDelta() bool

func (*SetNodeOptions) GetEndpoint 

func (x *SetNodeOptions) GetEndpoint() string

func (*SetNodeOptions) GetKey 

func (x *SetNodeOptions) GetKey() string

func (*SetNodeOptions) GetLabels 

func (x *SetNodeOptions) GetLabels() map[string]string

func (*SetNodeOptions) GetNodename 

func (x *SetNodeOptions) GetNodename() string

func (*SetNodeOptions) GetResources 

func (x *SetNodeOptions) GetResources() map[string][]byte

func (*SetNodeOptions) GetWorkloadsDown 

func (x *SetNodeOptions) GetWorkloadsDown() bool

func (*SetNodeOptions) ProtoMessage 

func (*SetNodeOptions) ProtoMessage()

func (*SetNodeOptions) ProtoReflect 

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

func (*SetNodeOptions) Reset 

func (x *SetNodeOptions) Reset()

func (*SetNodeOptions) String 

func (x *SetNodeOptions) String() string

type SetNodeStatusOptions 

type SetNodeStatusOptions struct {
	Nodename string `protobuf:"bytes,1001,opt,name=nodename,proto3" json:"nodename,omitempty"`
	Ttl      int64  `protobuf:"varint,1002,opt,name=ttl,proto3" json:"ttl,omitempty"`
	// contains filtered or unexported fields
}

func (*SetNodeStatusOptions) Descriptor deprecated 

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

Deprecated: Use SetNodeStatusOptions.ProtoReflect.Descriptor instead.

func (*SetNodeStatusOptions) GetNodename 

func (x *SetNodeStatusOptions) GetNodename() string

func (*SetNodeStatusOptions) GetTtl 

func (x *SetNodeStatusOptions) GetTtl() int64

func (*SetNodeStatusOptions) ProtoMessage 

func (*SetNodeStatusOptions) ProtoMessage()

func (*SetNodeStatusOptions) ProtoReflect 

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

func (*SetNodeStatusOptions) Reset 

func (x *SetNodeStatusOptions) Reset()

func (*SetNodeStatusOptions) String 

func (x *SetNodeStatusOptions) String() string

type SetWorkloadsStatusOptions 

type SetWorkloadsStatusOptions struct {
	Status []*WorkloadStatus `protobuf:"bytes,1001,rep,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*SetWorkloadsStatusOptions) Descriptor deprecated 

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

Deprecated: Use SetWorkloadsStatusOptions.ProtoReflect.Descriptor instead.

func (*SetWorkloadsStatusOptions) GetStatus 

func (x *SetWorkloadsStatusOptions) GetStatus() []*WorkloadStatus

func (*SetWorkloadsStatusOptions) ProtoMessage 

func (*SetWorkloadsStatusOptions) ProtoMessage()

func (*SetWorkloadsStatusOptions) ProtoReflect 

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

func (*SetWorkloadsStatusOptions) Reset 

func (x *SetWorkloadsStatusOptions) Reset()

func (*SetWorkloadsStatusOptions) String 

func (x *SetWorkloadsStatusOptions) String() string

type StdStreamType 

type StdStreamType int32
const (
	StdStreamType_STDOUT         StdStreamType = 0
	StdStreamType_STDERR         StdStreamType = 1
	StdStreamType_TYPEWORKLOADID StdStreamType = 6
	StdStreamType_ERUERROR       StdStreamType = -1
)

func (StdStreamType) Descriptor 

func (StdStreamType) Descriptor() protoreflect.EnumDescriptor

func (StdStreamType) Enum 

func (x StdStreamType) Enum() *StdStreamType

func (StdStreamType) EnumDescriptor deprecated 

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

Deprecated: Use StdStreamType.Descriptor instead.

func (StdStreamType) Number 

func (x StdStreamType) Number() protoreflect.EnumNumber

func (StdStreamType) String 

func (x StdStreamType) String() string

func (StdStreamType) Type 

func (StdStreamType) Type() protoreflect.EnumType

type TriOpt 

type TriOpt int32
const (
	TriOpt_KEEP  TriOpt = 0
	TriOpt_TRUE  TriOpt = 1
	TriOpt_FALSE TriOpt = 2
)

func (TriOpt) Descriptor 

func (TriOpt) Descriptor() protoreflect.EnumDescriptor

func (TriOpt) Enum 

func (x TriOpt) Enum() *TriOpt

func (TriOpt) EnumDescriptor deprecated 

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

Deprecated: Use TriOpt.Descriptor instead.

func (TriOpt) Number 

func (x TriOpt) Number() protoreflect.EnumNumber

func (TriOpt) String 

func (x TriOpt) String() string

func (TriOpt) Type 

func (TriOpt) Type() protoreflect.EnumType

type UnimplementedCoreRPCServer 

type UnimplementedCoreRPCServer struct {
}

UnimplementedCoreRPCServer should be embedded to have forward compatible implementations.

func (UnimplementedCoreRPCServer) AddNode 

func (UnimplementedCoreRPCServer) AddNode(context.Context, *AddNodeOptions) (*Node, error)

func (UnimplementedCoreRPCServer) AddPod 

func (UnimplementedCoreRPCServer) AddPod(context.Context, *AddPodOptions) (*Pod, error)

func (UnimplementedCoreRPCServer) BuildImage 

func (UnimplementedCoreRPCServer) BuildImage(*BuildImageOptions, CoreRPC_BuildImageServer) error

func (UnimplementedCoreRPCServer) CacheImage 

func (UnimplementedCoreRPCServer) CacheImage(*CacheImageOptions, CoreRPC_CacheImageServer) error

func (UnimplementedCoreRPCServer) CalculateCapacity 

func (UnimplementedCoreRPCServer) CalculateCapacity(context.Context, *DeployOptions) (*CapacityMessage, error)

func (UnimplementedCoreRPCServer) ConnectNetwork 

func (UnimplementedCoreRPCServer) ConnectNetwork(context.Context, *ConnectNetworkOptions) (*Network, error)

func (UnimplementedCoreRPCServer) ControlWorkload 

func (UnimplementedCoreRPCServer) ControlWorkload(*ControlWorkloadOptions, CoreRPC_ControlWorkloadServer) error

func (UnimplementedCoreRPCServer) Copy 

func (UnimplementedCoreRPCServer) Copy(*CopyOptions, CoreRPC_CopyServer) error

func (UnimplementedCoreRPCServer) CreateWorkload 

func (UnimplementedCoreRPCServer) CreateWorkload(*DeployOptions, CoreRPC_CreateWorkloadServer) error

func (UnimplementedCoreRPCServer) DisconnectNetwork 

func (UnimplementedCoreRPCServer) DisconnectNetwork(context.Context, *DisconnectNetworkOptions) (*Empty, error)

func (UnimplementedCoreRPCServer) DissociateWorkload 

func (UnimplementedCoreRPCServer) DissociateWorkload(*DissociateWorkloadOptions, CoreRPC_DissociateWorkloadServer) error

func (UnimplementedCoreRPCServer) ExecuteWorkload 

func (UnimplementedCoreRPCServer) ExecuteWorkload(CoreRPC_ExecuteWorkloadServer) error

func (UnimplementedCoreRPCServer) GetNode 

func (UnimplementedCoreRPCServer) GetNode(context.Context, *GetNodeOptions) (*Node, error)

func (UnimplementedCoreRPCServer) GetNodeEngineInfo 

func (UnimplementedCoreRPCServer) GetNodeEngineInfo(context.Context, *GetNodeOptions) (*Engine, error)

func (UnimplementedCoreRPCServer) GetNodeResource 

func (UnimplementedCoreRPCServer) GetNodeResource(context.Context, *GetNodeResourceOptions) (*NodeResource, error)

func (UnimplementedCoreRPCServer) GetNodeStatus 

func (UnimplementedCoreRPCServer) GetNodeStatus(context.Context, *GetNodeStatusOptions) (*NodeStatusStreamMessage, error)

func (UnimplementedCoreRPCServer) GetPod 

func (UnimplementedCoreRPCServer) GetPod(context.Context, *GetPodOptions) (*Pod, error)

func (UnimplementedCoreRPCServer) GetPodResource 

func (UnimplementedCoreRPCServer) GetPodResource(*GetPodOptions, CoreRPC_GetPodResourceServer) error

func (UnimplementedCoreRPCServer) GetWorkload 

func (UnimplementedCoreRPCServer) GetWorkload(context.Context, *WorkloadID) (*Workload, error)

func (UnimplementedCoreRPCServer) GetWorkloads 

func (UnimplementedCoreRPCServer) GetWorkloads(context.Context, *WorkloadIDs) (*Workloads, error)

func (UnimplementedCoreRPCServer) GetWorkloadsStatus 

func (UnimplementedCoreRPCServer) GetWorkloadsStatus(context.Context, *WorkloadIDs) (*WorkloadsStatus, error)

func (UnimplementedCoreRPCServer) Info 

func (UnimplementedCoreRPCServer) Info(context.Context, *Empty) (*CoreInfo, error)

func (UnimplementedCoreRPCServer) ListImage 

func (UnimplementedCoreRPCServer) ListImage(*ListImageOptions, CoreRPC_ListImageServer) error

func (UnimplementedCoreRPCServer) ListNetworks 

func (UnimplementedCoreRPCServer) ListNetworks(context.Context, *ListNetworkOptions) (*Networks, error)

func (UnimplementedCoreRPCServer) ListNodeWorkloads 

func (UnimplementedCoreRPCServer) ListNodeWorkloads(context.Context, *GetNodeOptions) (*Workloads, error)

func (UnimplementedCoreRPCServer) ListPodNodes 

func (UnimplementedCoreRPCServer) ListPodNodes(*ListNodesOptions, CoreRPC_ListPodNodesServer) error

func (UnimplementedCoreRPCServer) ListPods 

func (UnimplementedCoreRPCServer) ListPods(context.Context, *Empty) (*Pods, error)

func (UnimplementedCoreRPCServer) ListWorkloads 

func (UnimplementedCoreRPCServer) ListWorkloads(*ListWorkloadsOptions, CoreRPC_ListWorkloadsServer) error

func (UnimplementedCoreRPCServer) LogStream 

func (UnimplementedCoreRPCServer) LogStream(*LogStreamOptions, CoreRPC_LogStreamServer) error

func (UnimplementedCoreRPCServer) NodeStatusStream 

func (UnimplementedCoreRPCServer) NodeStatusStream(*Empty, CoreRPC_NodeStatusStreamServer) error

func (UnimplementedCoreRPCServer) RawEngine 

func (UnimplementedCoreRPCServer) RawEngine(context.Context, *RawEngineOptions) (*RawEngineMessage, error)

func (UnimplementedCoreRPCServer) ReallocResource 

func (UnimplementedCoreRPCServer) ReallocResource(context.Context, *ReallocOptions) (*ReallocResourceMessage, error)

func (UnimplementedCoreRPCServer) RemoveImage 

func (UnimplementedCoreRPCServer) RemoveImage(*RemoveImageOptions, CoreRPC_RemoveImageServer) error

func (UnimplementedCoreRPCServer) RemoveNode 

func (UnimplementedCoreRPCServer) RemoveNode(context.Context, *RemoveNodeOptions) (*Empty, error)

func (UnimplementedCoreRPCServer) RemovePod 

func (UnimplementedCoreRPCServer) RemovePod(context.Context, *RemovePodOptions) (*Empty, error)

func (UnimplementedCoreRPCServer) RemoveWorkload 

func (UnimplementedCoreRPCServer) RemoveWorkload(*RemoveWorkloadOptions, CoreRPC_RemoveWorkloadServer) error

func (UnimplementedCoreRPCServer) ReplaceWorkload 

func (UnimplementedCoreRPCServer) ReplaceWorkload(*ReplaceOptions, CoreRPC_ReplaceWorkloadServer) error

func (UnimplementedCoreRPCServer) RunAndWait 

func (UnimplementedCoreRPCServer) RunAndWait(CoreRPC_RunAndWaitServer) error

func (UnimplementedCoreRPCServer) Send 

func (UnimplementedCoreRPCServer) Send(*SendOptions, CoreRPC_SendServer) error

func (UnimplementedCoreRPCServer) SendLargeFile 

func (UnimplementedCoreRPCServer) SendLargeFile(CoreRPC_SendLargeFileServer) error

func (UnimplementedCoreRPCServer) SetNode 

func (UnimplementedCoreRPCServer) SetNode(context.Context, *SetNodeOptions) (*Node, error)

func (UnimplementedCoreRPCServer) SetNodeStatus 

func (UnimplementedCoreRPCServer) SetNodeStatus(context.Context, *SetNodeStatusOptions) (*Empty, error)

func (UnimplementedCoreRPCServer) SetWorkloadsStatus 

func (UnimplementedCoreRPCServer) SetWorkloadsStatus(context.Context, *SetWorkloadsStatusOptions) (*WorkloadsStatus, error)

func (UnimplementedCoreRPCServer) WatchServiceStatus 

func (UnimplementedCoreRPCServer) WatchServiceStatus(*Empty, CoreRPC_WatchServiceStatusServer) error

func (UnimplementedCoreRPCServer) WorkloadStatusStream 

func (UnimplementedCoreRPCServer) WorkloadStatusStream(*WorkloadStatusStreamOptions, CoreRPC_WorkloadStatusStreamServer) error

type UnsafeCoreRPCServer 

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

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

type Volume 

type Volume struct {
	Volume map[string]int64 `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Volume) Descriptor deprecated 

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

Deprecated: Use Volume.ProtoReflect.Descriptor instead.

func (*Volume) GetVolume 

func (x *Volume) GetVolume() map[string]int64

func (*Volume) ProtoMessage 

func (*Volume) ProtoMessage()

func (*Volume) ProtoReflect 

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

func (*Volume) Reset 

func (x *Volume) Reset()

func (*Volume) String 

func (x *Volume) String() string

type Workload 

type Workload struct {
	Id         string            `protobuf:"bytes,1001,opt,name=id,proto3" json:"id,omitempty"`
	Podname    string            `protobuf:"bytes,1002,opt,name=podname,proto3" json:"podname,omitempty"`
	Nodename   string            `protobuf:"bytes,1003,opt,name=nodename,proto3" json:"nodename,omitempty"`
	Name       string            `protobuf:"bytes,1004,opt,name=name,proto3" json:"name,omitempty"`
	Privileged bool              `protobuf:"varint,1005,opt,name=privileged,proto3" json:"privileged,omitempty"`
	Labels     map[string]string `` /* 156-byte string literal not displayed */
	Publish    map[string]string `` /* 158-byte string literal not displayed */
	Image      string            `protobuf:"bytes,1008,opt,name=image,proto3" json:"image,omitempty"`
	Status     *WorkloadStatus   `protobuf:"bytes,1009,opt,name=status,proto3" json:"status,omitempty"`
	CreateTime int64             `protobuf:"varint,1010,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	Env        []string          `protobuf:"bytes,1011,rep,name=env,proto3" json:"env,omitempty"`
	Resources  string            `protobuf:"bytes,1012,opt,name=resources,proto3" json:"resources,omitempty"`
	// contains filtered or unexported fields
}

func (*Workload) Descriptor deprecated 

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

Deprecated: Use Workload.ProtoReflect.Descriptor instead.

func (*Workload) GetCreateTime 

func (x *Workload) GetCreateTime() int64

func (*Workload) GetEnv 

func (x *Workload) GetEnv() []string

func (*Workload) GetId 

func (x *Workload) GetId() string

func (*Workload) GetImage 

func (x *Workload) GetImage() string

func (*Workload) GetLabels 

func (x *Workload) GetLabels() map[string]string

func (*Workload) GetName 

func (x *Workload) GetName() string

func (*Workload) GetNodename 

func (x *Workload) GetNodename() string

func (*Workload) GetPodname 

func (x *Workload) GetPodname() string

func (*Workload) GetPrivileged 

func (x *Workload) GetPrivileged() bool

func (*Workload) GetPublish 

func (x *Workload) GetPublish() map[string]string

func (*Workload) GetResources 

func (x *Workload) GetResources() string

func (*Workload) GetStatus 

func (x *Workload) GetStatus() *WorkloadStatus

func (*Workload) ProtoMessage 

func (*Workload) ProtoMessage()

func (*Workload) ProtoReflect 

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

func (*Workload) Reset 

func (x *Workload) Reset()

func (*Workload) String 

func (x *Workload) String() string

type WorkloadID 

type WorkloadID struct {
	Id string `protobuf:"bytes,1001,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkloadID) Descriptor deprecated 

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

Deprecated: Use WorkloadID.ProtoReflect.Descriptor instead.

func (*WorkloadID) GetId 

func (x *WorkloadID) GetId() string

func (*WorkloadID) ProtoMessage 

func (*WorkloadID) ProtoMessage()

func (*WorkloadID) ProtoReflect 

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

func (*WorkloadID) Reset 

func (x *WorkloadID) Reset()

func (*WorkloadID) String 

func (x *WorkloadID) String() string

type WorkloadIDs 

type WorkloadIDs struct {
	IDs []string `protobuf:"bytes,1001,rep,name=IDs,proto3" json:"IDs,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkloadIDs) Descriptor deprecated 

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

Deprecated: Use WorkloadIDs.ProtoReflect.Descriptor instead.

func (*WorkloadIDs) GetIDs 

func (x *WorkloadIDs) GetIDs() []string

func (*WorkloadIDs) ProtoMessage 

func (*WorkloadIDs) ProtoMessage()

func (*WorkloadIDs) ProtoReflect 

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

func (*WorkloadIDs) Reset 

func (x *WorkloadIDs) Reset()

func (*WorkloadIDs) String 

func (x *WorkloadIDs) String() string

type WorkloadStatus 

type WorkloadStatus struct {
	Id        string            `protobuf:"bytes,1001,opt,name=id,proto3" json:"id,omitempty"`
	Running   bool              `protobuf:"varint,1002,opt,name=running,proto3" json:"running,omitempty"`
	Healthy   bool              `protobuf:"varint,1003,opt,name=healthy,proto3" json:"healthy,omitempty"`
	Networks  map[string]string `` /* 160-byte string literal not displayed */
	Extension []byte            `protobuf:"bytes,1005,opt,name=extension,proto3" json:"extension,omitempty"`
	Ttl       int64             `protobuf:"varint,1006,opt,name=ttl,proto3" json:"ttl,omitempty"`
	// extra fields used to set workload status
	Appname    string `protobuf:"bytes,1007,opt,name=appname,proto3" json:"appname,omitempty"`
	Nodename   string `protobuf:"bytes,1008,opt,name=nodename,proto3" json:"nodename,omitempty"`
	Entrypoint string `protobuf:"bytes,1009,opt,name=entrypoint,proto3" json:"entrypoint,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkloadStatus) Descriptor deprecated 

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

Deprecated: Use WorkloadStatus.ProtoReflect.Descriptor instead.

func (*WorkloadStatus) GetAppname 

func (x *WorkloadStatus) GetAppname() string

func (*WorkloadStatus) GetEntrypoint 

func (x *WorkloadStatus) GetEntrypoint() string

func (*WorkloadStatus) GetExtension 

func (x *WorkloadStatus) GetExtension() []byte

func (*WorkloadStatus) GetHealthy 

func (x *WorkloadStatus) GetHealthy() bool

func (*WorkloadStatus) GetId 

func (x *WorkloadStatus) GetId() string

func (*WorkloadStatus) GetNetworks 

func (x *WorkloadStatus) GetNetworks() map[string]string

func (*WorkloadStatus) GetNodename 

func (x *WorkloadStatus) GetNodename() string

func (*WorkloadStatus) GetRunning 

func (x *WorkloadStatus) GetRunning() bool

func (*WorkloadStatus) GetTtl 

func (x *WorkloadStatus) GetTtl() int64

func (*WorkloadStatus) ProtoMessage 

func (*WorkloadStatus) ProtoMessage()

func (*WorkloadStatus) ProtoReflect 

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

func (*WorkloadStatus) Reset 

func (x *WorkloadStatus) Reset()

func (*WorkloadStatus) String 

func (x *WorkloadStatus) String() string

type WorkloadStatusStreamMessage 

type WorkloadStatusStreamMessage struct {
	Id       string          `protobuf:"bytes,1001,opt,name=id,proto3" json:"id,omitempty"`
	Workload *Workload       `protobuf:"bytes,1002,opt,name=workload,proto3" json:"workload,omitempty"`
	Status   *WorkloadStatus `protobuf:"bytes,1003,opt,name=status,proto3" json:"status,omitempty"`
	Error    string          `protobuf:"bytes,1004,opt,name=error,proto3" json:"error,omitempty"`
	Delete   bool            `protobuf:"varint,1005,opt,name=delete,proto3" json:"delete,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkloadStatusStreamMessage) Descriptor deprecated 

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

Deprecated: Use WorkloadStatusStreamMessage.ProtoReflect.Descriptor instead.

func (*WorkloadStatusStreamMessage) GetDelete 

func (x *WorkloadStatusStreamMessage) GetDelete() bool

func (*WorkloadStatusStreamMessage) GetError 

func (x *WorkloadStatusStreamMessage) GetError() string

func (*WorkloadStatusStreamMessage) GetId 

func (x *WorkloadStatusStreamMessage) GetId() string

func (*WorkloadStatusStreamMessage) GetStatus 

func (x *WorkloadStatusStreamMessage) GetStatus() *WorkloadStatus

func (*WorkloadStatusStreamMessage) GetWorkload 

func (x *WorkloadStatusStreamMessage) GetWorkload() *Workload

func (*WorkloadStatusStreamMessage) ProtoMessage 

func (*WorkloadStatusStreamMessage) ProtoMessage()

func (*WorkloadStatusStreamMessage) ProtoReflect 

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

func (*WorkloadStatusStreamMessage) Reset 

func (x *WorkloadStatusStreamMessage) Reset()

func (*WorkloadStatusStreamMessage) String 

func (x *WorkloadStatusStreamMessage) String() string

type WorkloadStatusStreamOptions 

type WorkloadStatusStreamOptions struct {
	Appname    string            `protobuf:"bytes,1001,opt,name=appname,proto3" json:"appname,omitempty"`
	Entrypoint string            `protobuf:"bytes,1002,opt,name=entrypoint,proto3" json:"entrypoint,omitempty"`
	Nodename   string            `protobuf:"bytes,1003,opt,name=nodename,proto3" json:"nodename,omitempty"`
	Labels     map[string]string `` /* 156-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*WorkloadStatusStreamOptions) Descriptor deprecated 

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

Deprecated: Use WorkloadStatusStreamOptions.ProtoReflect.Descriptor instead.

func (*WorkloadStatusStreamOptions) GetAppname 

func (x *WorkloadStatusStreamOptions) GetAppname() string

func (*WorkloadStatusStreamOptions) GetEntrypoint 

func (x *WorkloadStatusStreamOptions) GetEntrypoint() string

func (*WorkloadStatusStreamOptions) GetLabels 

func (x *WorkloadStatusStreamOptions) GetLabels() map[string]string

func (*WorkloadStatusStreamOptions) GetNodename 

func (x *WorkloadStatusStreamOptions) GetNodename() string

func (*WorkloadStatusStreamOptions) ProtoMessage 

func (*WorkloadStatusStreamOptions) ProtoMessage()

func (*WorkloadStatusStreamOptions) ProtoReflect 

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

func (*WorkloadStatusStreamOptions) Reset 

func (x *WorkloadStatusStreamOptions) Reset()

func (*WorkloadStatusStreamOptions) String 

func (x *WorkloadStatusStreamOptions) String() string

type Workloads 

type Workloads struct {
	Workloads []*Workload `protobuf:"bytes,1001,rep,name=workloads,proto3" json:"workloads,omitempty"`
	// contains filtered or unexported fields
}

func (*Workloads) Descriptor deprecated 

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

Deprecated: Use Workloads.ProtoReflect.Descriptor instead.

func (*Workloads) GetWorkloads 

func (x *Workloads) GetWorkloads() []*Workload

func (*Workloads) ProtoMessage 

func (*Workloads) ProtoMessage()

func (*Workloads) ProtoReflect 

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

func (*Workloads) Reset 

func (x *Workloads) Reset()

func (*Workloads) String 

func (x *Workloads) String() string

type WorkloadsStatus 

type WorkloadsStatus struct {
	Status []*WorkloadStatus `protobuf:"bytes,1001,rep,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkloadsStatus) Descriptor deprecated 

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

Deprecated: Use WorkloadsStatus.ProtoReflect.Descriptor instead.

func (*WorkloadsStatus) GetStatus 

func (x *WorkloadsStatus) GetStatus() []*WorkloadStatus

func (*WorkloadsStatus) ProtoMessage 

func (*WorkloadsStatus) ProtoMessage()

func (*WorkloadsStatus) ProtoReflect 

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

func (*WorkloadsStatus) Reset 

func (x *WorkloadsStatus) Reset()

func (*WorkloadsStatus) String 

func (x *WorkloadsStatus) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.