proto

package
v0.0.0-...-502bd87 Latest Latest
Warning

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

Go to latest
Published: Jul 7, 2020 License: MIT Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var Action_name = map[int32]string{
	0: "continue",
	1: "rollback",
	2: "pause",
}
View Source
var Action_value = map[string]int32{
	"continue": 0,
	"rollback": 1,
	"pause":    2,
}
View Source
var Code_name = map[int32]string{
	0: "success",
	1: "fail",
}
View Source
var Code_value = map[string]int32{
	"success": 0,
	"fail":    1,
}
View Source
var Condition_name = map[int32]string{
	0: "none",
	1: "onFailure",
	2: "any",
}
View Source
var Condition_value = map[string]int32{
	"none":      0,
	"onFailure": 1,
	"any":       2,
}
View Source
var ContainerState_name = map[int32]string{
	0: "running",
	1: "shutdown",
	2: "accepted",
}
View Source
var ContainerState_value = map[string]int32{
	"running":  0,
	"shutdown": 1,
	"accepted": 2,
}
View Source
var Driver_name = map[int32]string{
	0: "host",
	1: "bridge",
	2: "overlay",
}
View Source
var Driver_value = map[string]int32{
	"host":    0,
	"bridge":  1,
	"overlay": 2,
}
View Source
var EndpointMode_name = map[int32]string{
	0: "vip",
	1: "dnsrr",
}
View Source
var EndpointMode_value = map[string]int32{
	"vip":   0,
	"dnsrr": 1,
}
View Source
var Mode_name = map[int32]string{
	0: "global",
	1: "replicated",
}
View Source
var Mode_value = map[string]int32{
	"global":     0,
	"replicated": 1,
}
View Source
var Order_name = map[int32]string{
	0: "stopFirst",
	1: "startFirst",
}
View Source
var Order_value = map[string]int32{
	"stopFirst":  0,
	"startFirst": 1,
}

Functions

func RegisterContainerServerServer

func RegisterContainerServerServer(s *grpc.Server, srv ContainerServerServer)

func RegisterImageServerServer

func RegisterImageServerServer(s *grpc.Server, srv ImageServerServer)

func RegisterProcServerServer

func RegisterProcServerServer(s *grpc.Server, srv ProcServerServer)

func RegisterProjectServerServer

func RegisterProjectServerServer(s *grpc.Server, srv ProjectServerServer)

func RegisterResourceServerServer

func RegisterResourceServerServer(s *grpc.Server, srv ResourceServerServer)

func RegisterServiceServerServer

func RegisterServiceServerServer(s *grpc.Server, srv ServiceServerServer)

func RegisterStackServerServer

func RegisterStackServerServer(s *grpc.Server, srv StackServerServer)

Types

type Action

type Action int32

升级/回滚失败后的动作

const (
	// 升级/回滚失败后继续操作
	Action_continue Action = 0
	// 升级失败后回滚当前操作
	Action_rollback Action = 1
	// 升级/回滚失败后暂停操作
	Action_pause Action = 2
)

func (Action) EnumDescriptor

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

func (Action) String

func (x Action) String() string

type Annotations

type Annotations struct {
	Name                 string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Labels               map[string]string `` /* 153-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

Annotations represents how to describe an object.

func (*Annotations) Descriptor

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

func (*Annotations) GetLabels

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

func (*Annotations) GetName

func (m *Annotations) GetName() string

func (*Annotations) ProtoMessage

func (*Annotations) ProtoMessage()

func (*Annotations) Reset

func (m *Annotations) Reset()

func (*Annotations) String

func (m *Annotations) String() string

func (*Annotations) XXX_DiscardUnknown

func (m *Annotations) XXX_DiscardUnknown()

func (*Annotations) XXX_Marshal

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

func (*Annotations) XXX_Merge

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

func (*Annotations) XXX_Size

func (m *Annotations) XXX_Size() int

func (*Annotations) XXX_Unmarshal

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

type Code

type Code int32
const (
	Code_success Code = 0
	Code_fail    Code = 1
)

func (Code) EnumDescriptor

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

func (Code) String

func (x Code) String() string

type Compose

type Compose struct {
	// 启动期望服务集合
	Services map[string]*Task `` /* 157-byte string literal not displayed */
	// 启动所需网络集合
	Networks             map[string]*ComposeNetwork `` /* 157-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

compose stack启动配置文件信息

func (*Compose) Descriptor

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

func (*Compose) GetNetworks

func (m *Compose) GetNetworks() map[string]*ComposeNetwork

func (*Compose) GetServices

func (m *Compose) GetServices() map[string]*Task

func (*Compose) ProtoMessage

func (*Compose) ProtoMessage()

func (*Compose) Reset

func (m *Compose) Reset()

func (*Compose) String

func (m *Compose) String() string

func (*Compose) XXX_DiscardUnknown

func (m *Compose) XXX_DiscardUnknown()

func (*Compose) XXX_Marshal

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

func (*Compose) XXX_Merge

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

func (*Compose) XXX_Size

func (m *Compose) XXX_Size() int

func (*Compose) XXX_Unmarshal

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

type ComposeNetwork

type ComposeNetwork struct {
	// 网络驱动类型:host、bridge、overlay
	Driver               Driver   `protobuf:"varint,1,opt,name=driver,proto3,enum=proto.Driver" json:"driver,omitempty"`
	Attachable           bool     `protobuf:"varint,2,opt,name=attachable,proto3" json:"attachable,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

swarm独立网络

func (*ComposeNetwork) Descriptor

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

func (*ComposeNetwork) GetAttachable

func (m *ComposeNetwork) GetAttachable() bool

func (*ComposeNetwork) GetDriver

func (m *ComposeNetwork) GetDriver() Driver

func (*ComposeNetwork) ProtoMessage

func (*ComposeNetwork) ProtoMessage()

func (*ComposeNetwork) Reset

func (m *ComposeNetwork) Reset()

func (*ComposeNetwork) String

func (m *ComposeNetwork) String() string

func (*ComposeNetwork) XXX_DiscardUnknown

func (m *ComposeNetwork) XXX_DiscardUnknown()

func (*ComposeNetwork) XXX_Marshal

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

func (*ComposeNetwork) XXX_Merge

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

func (*ComposeNetwork) XXX_Size

func (m *ComposeNetwork) XXX_Size() int

func (*ComposeNetwork) XXX_Unmarshal

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

type ComposeVolume

type ComposeVolume struct {
	// bind / volume
	Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	// 本地服务器目录或文件地址,待挂载使用
	Local string `protobuf:"bytes,2,opt,name=local,proto3" json:"local,omitempty"`
	// 容器内目录,挂载到local
	Mount                string   `protobuf:"bytes,3,opt,name=mount,proto3" json:"mount,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

挂载服务

func (*ComposeVolume) Descriptor

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

func (*ComposeVolume) GetLocal

func (m *ComposeVolume) GetLocal() string

func (*ComposeVolume) GetMount

func (m *ComposeVolume) GetMount() string

func (*ComposeVolume) GetType

func (m *ComposeVolume) GetType() string

func (*ComposeVolume) ProtoMessage

func (*ComposeVolume) ProtoMessage()

func (*ComposeVolume) Reset

func (m *ComposeVolume) Reset()

func (*ComposeVolume) String

func (m *ComposeVolume) String() string

func (*ComposeVolume) XXX_DiscardUnknown

func (m *ComposeVolume) XXX_DiscardUnknown()

func (*ComposeVolume) XXX_Marshal

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

func (*ComposeVolume) XXX_Merge

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

func (*ComposeVolume) XXX_Size

func (m *ComposeVolume) XXX_Size() int

func (*ComposeVolume) XXX_Unmarshal

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

type Condition

type Condition int32

重启判定条件

const (
	// 默认的重新启动策略,它在任何情况下都不会重新启动容器
	Condition_none Condition = 0
	// 如果退出码指示出现on-failure错误,on-failure策略将重新启动容器
	Condition_onFailure Condition = 1
	// 容器总是会重新启动
	Condition_any Condition = 2
)

func (Condition) EnumDescriptor

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

func (Condition) String

func (x Condition) String() string

type Container

type Container struct {
	// e1148d2e4faaeb26542757923cbdd7adaeb6088e30465400f03f7970e98c2a88
	ID string `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	// nginx:1.18.0@sha256:159aedcc6acb8147c524ec2d11f02112bc21f9e8eb33e328fb7c04b05fc44e1c
	Image string `protobuf:"bytes,2,opt,name=image,proto3" json:"image,omitempty"`
	// sha256:9fc56f7e4c117b9a726cbee19a61b910cbcb55481f8b7de5a282a034dfb7f761
	ImageID string `protobuf:"bytes,3,opt,name=imageID,proto3" json:"imageID,omitempty"`
	// kaatxwrxdc1u0dcut5ij88jqp
	NodeID string `protobuf:"bytes,4,opt,name=nodeID,proto3" json:"nodeID,omitempty"`
	// p5cxcpr7yu3zhymm0hfig4owt
	ServiceID string `protobuf:"bytes,5,opt,name=serviceID,proto3" json:"serviceID,omitempty"`
	// nginx
	ServiceName string `protobuf:"bytes,6,opt,name=serviceName,proto3" json:"serviceName,omitempty"`
	// running
	State string `protobuf:"bytes,7,opt,name=state,proto3" json:"state,omitempty"`
	// Up 5 minutes
	Status string `protobuf:"bytes,8,opt,name=status,proto3" json:"status,omitempty"`
	// 2020-06-23T08:23:14.6105524Z
	Read     string `protobuf:"bytes,9,opt,name=read,proto3" json:"read,omitempty"`
	CpuCount uint32 `protobuf:"varint,10,opt,name=cpuCount,proto3" json:"cpuCount,omitempty"`
	// 24652610
	CpuUsage float32 `protobuf:"fixed32,11,opt,name=cpuUsage,proto3" json:"cpuUsage,omitempty"`
	// 307200
	MemUsage             float32  `protobuf:"fixed32,12,opt,name=memUsage,proto3" json:"memUsage,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Container) Descriptor

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

func (*Container) GetCpuCount

func (m *Container) GetCpuCount() uint32

func (*Container) GetCpuUsage

func (m *Container) GetCpuUsage() float32

func (*Container) GetID

func (m *Container) GetID() string

func (*Container) GetImage

func (m *Container) GetImage() string

func (*Container) GetImageID

func (m *Container) GetImageID() string

func (*Container) GetMemUsage

func (m *Container) GetMemUsage() float32

func (*Container) GetNodeID

func (m *Container) GetNodeID() string

func (*Container) GetRead

func (m *Container) GetRead() string

func (*Container) GetServiceID

func (m *Container) GetServiceID() string

func (*Container) GetServiceName

func (m *Container) GetServiceName() string

func (*Container) GetState

func (m *Container) GetState() string

func (*Container) GetStatus

func (m *Container) GetStatus() string

func (*Container) ProtoMessage

func (*Container) ProtoMessage()

func (*Container) Reset

func (m *Container) Reset()

func (*Container) String

func (m *Container) String() string

func (*Container) XXX_DiscardUnknown

func (m *Container) XXX_DiscardUnknown()

func (*Container) XXX_Marshal

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

func (*Container) XXX_Merge

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

func (*Container) XXX_Size

func (m *Container) XXX_Size() int

func (*Container) XXX_Unmarshal

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

type ContainerServerClient

ContainerServerClient is the client API for ContainerServer service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

type ContainerServerServer

ContainerServerServer is the server API for ContainerServer service.

type ContainerState

type ContainerState int32

ContainerState 容器运行状态

const (
	// ContainerRunning 容器运行中
	ContainerState_running ContainerState = 0
	// ContainerShutdown 容器已关闭
	ContainerState_shutdown ContainerState = 1
	// ContainerAccepted accepted
	ContainerState_accepted ContainerState = 2
)

func (ContainerState) EnumDescriptor

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

func (ContainerState) String

func (x ContainerState) String() string

type Deploy

type Deploy struct {
	// 服务部署模式
	Mode Mode `protobuf:"varint,1,opt,name=mode,proto3,enum=proto.Mode" json:"mode,omitempty"`
	// 如果服务是副本模式(默认模式),可以指定该服务运行的容器数量
	Replicas uint64 `protobuf:"varint,2,opt,name=replicas,proto3" json:"replicas,omitempty"`
	// 指定swarm服务发现的模式
	//
	// endpoint_mode: vip - Docker为swarm集群服务分配一个虚拟IP(VIP),作为客户端到达集群服务的“前端”。
	// Docker 在客户端和可用工作节点之间对服务的请求进行路由。而客户端不用知道有多少节点参与服务或者是这些节点的IP/端口。(这是默认模式)
	//
	// endpoint_mode: dnsrr - DNS轮询(DNSRR)服务发现不使用单个虚拟IP。
	// Docker为服务设置DNS条目,使得服务名称的DNS查询返回一个IP地址列表,并且客户端直接连接到其中的一个。
	// 如果想使用自己的负载平衡器,或者混合Windows和Linux应用程序,则DNS轮询功能非常有用。
	EndpointMode EndpointMode `protobuf:"varint,3,opt,name=endpointMode,proto3,enum=proto.EndpointMode" json:"endpointMode,omitempty"`
	// 资源配置策略
	Resources *Resources `protobuf:"bytes,4,opt,name=resources,proto3" json:"resources,omitempty"`
	// 指定服务的标签。这些标签仅在服务上设置,而不在服务的任何容器上设置
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// 指定约束和偏好设置
	Placement *Placement `protobuf:"bytes,6,opt,name=placement,proto3" json:"placement,omitempty"`
	// 配置在容器退出时是否并如何重启容器。取代restart指令
	RestartPolicy *RestartPolicy `protobuf:"bytes,7,opt,name=restartPolicy,proto3" json:"restartPolicy,omitempty"`
	// 配置服务如何升级
	UpdateConfig *UpdateConfig `protobuf:"bytes,8,opt,name=updateConfig,proto3" json:"updateConfig,omitempty"`
	// 配置在更新失败的情况下应如何回滚服务
	RollbackConfig       *UpdateConfig `protobuf:"bytes,9,opt,name=rollbackConfig,proto3" json:"rollbackConfig,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

指定swarm服务部署和运行时的相关配置

func (*Deploy) Descriptor

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

func (*Deploy) GetEndpointMode

func (m *Deploy) GetEndpointMode() EndpointMode

func (*Deploy) GetLabels

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

func (*Deploy) GetMode

func (m *Deploy) GetMode() Mode

func (*Deploy) GetPlacement

func (m *Deploy) GetPlacement() *Placement

func (*Deploy) GetReplicas

func (m *Deploy) GetReplicas() uint64

func (*Deploy) GetResources

func (m *Deploy) GetResources() *Resources

func (*Deploy) GetRestartPolicy

func (m *Deploy) GetRestartPolicy() *RestartPolicy

func (*Deploy) GetRollbackConfig

func (m *Deploy) GetRollbackConfig() *UpdateConfig

func (*Deploy) GetUpdateConfig

func (m *Deploy) GetUpdateConfig() *UpdateConfig

func (*Deploy) ProtoMessage

func (*Deploy) ProtoMessage()

func (*Deploy) Reset

func (m *Deploy) Reset()

func (*Deploy) String

func (m *Deploy) String() string

func (*Deploy) XXX_DiscardUnknown

func (m *Deploy) XXX_DiscardUnknown()

func (*Deploy) XXX_Marshal

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

func (*Deploy) XXX_Merge

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

func (*Deploy) XXX_Size

func (m *Deploy) XXX_Size() int

func (*Deploy) XXX_Unmarshal

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

type DockerInfo

type DockerInfo struct {
	ID                   string           `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	Containers           uint32           `protobuf:"varint,2,opt,name=containers,proto3" json:"containers,omitempty"`
	ContainersRunning    uint32           `protobuf:"varint,3,opt,name=containersRunning,proto3" json:"containersRunning,omitempty"`
	ContainersPaused     uint32           `protobuf:"varint,4,opt,name=containersPaused,proto3" json:"containersPaused,omitempty"`
	ContainersStopped    uint32           `protobuf:"varint,5,opt,name=containersStopped,proto3" json:"containersStopped,omitempty"`
	Images               uint32           `protobuf:"varint,6,opt,name=images,proto3" json:"images,omitempty"`
	OSType               string           `protobuf:"bytes,7,opt,name=OSType,proto3" json:"OSType,omitempty"`
	Architecture         string           `protobuf:"bytes,8,opt,name=architecture,proto3" json:"architecture,omitempty"`
	CpuCount             uint32           `protobuf:"varint,9,opt,name=cpuCount,proto3" json:"cpuCount,omitempty"`
	CpuTotal             int64            `protobuf:"varint,10,opt,name=cpuTotal,proto3" json:"cpuTotal,omitempty"`
	MemTotal             uint64           `protobuf:"varint,11,opt,name=memTotal,proto3" json:"memTotal,omitempty"`
	NodeID               string           `protobuf:"bytes,12,opt,name=nodeID,proto3" json:"nodeID,omitempty"`
	LocalNodeState       string           `protobuf:"bytes,13,opt,name=localNodeState,proto3" json:"localNodeState,omitempty"`
	Error                string           `protobuf:"bytes,14,opt,name=error,proto3" json:"error,omitempty"`
	CreateAT             string           `protobuf:"bytes,15,opt,name=createAT,proto3" json:"createAT,omitempty"`
	UpdatedAt            string           `protobuf:"bytes,16,opt,name=updatedAt,proto3" json:"updatedAt,omitempty"`
	RemoteManagers       []*RemoteManager `protobuf:"bytes,17,rep,name=remoteManagers,proto3" json:"remoteManagers,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*DockerInfo) Descriptor

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

func (*DockerInfo) GetArchitecture

func (m *DockerInfo) GetArchitecture() string

func (*DockerInfo) GetContainers

func (m *DockerInfo) GetContainers() uint32

func (*DockerInfo) GetContainersPaused

func (m *DockerInfo) GetContainersPaused() uint32

func (*DockerInfo) GetContainersRunning

func (m *DockerInfo) GetContainersRunning() uint32

func (*DockerInfo) GetContainersStopped

func (m *DockerInfo) GetContainersStopped() uint32

func (*DockerInfo) GetCpuCount

func (m *DockerInfo) GetCpuCount() uint32

func (*DockerInfo) GetCpuTotal

func (m *DockerInfo) GetCpuTotal() int64

func (*DockerInfo) GetCreateAT

func (m *DockerInfo) GetCreateAT() string

func (*DockerInfo) GetError

func (m *DockerInfo) GetError() string

func (*DockerInfo) GetID

func (m *DockerInfo) GetID() string

func (*DockerInfo) GetImages

func (m *DockerInfo) GetImages() uint32

func (*DockerInfo) GetLocalNodeState

func (m *DockerInfo) GetLocalNodeState() string

func (*DockerInfo) GetMemTotal

func (m *DockerInfo) GetMemTotal() uint64

func (*DockerInfo) GetNodeID

func (m *DockerInfo) GetNodeID() string

func (*DockerInfo) GetOSType

func (m *DockerInfo) GetOSType() string

func (*DockerInfo) GetRemoteManagers

func (m *DockerInfo) GetRemoteManagers() []*RemoteManager

func (*DockerInfo) GetUpdatedAt

func (m *DockerInfo) GetUpdatedAt() string

func (*DockerInfo) ProtoMessage

func (*DockerInfo) ProtoMessage()

func (*DockerInfo) Reset

func (m *DockerInfo) Reset()

func (*DockerInfo) String

func (m *DockerInfo) String() string

func (*DockerInfo) XXX_DiscardUnknown

func (m *DockerInfo) XXX_DiscardUnknown()

func (*DockerInfo) XXX_Marshal

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

func (*DockerInfo) XXX_Merge

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

func (*DockerInfo) XXX_Size

func (m *DockerInfo) XXX_Size() int

func (*DockerInfo) XXX_Unmarshal

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

type Driver

type Driver int32

网络驱动类型

const (
	Driver_host    Driver = 0
	Driver_bridge  Driver = 1
	Driver_overlay Driver = 2
)

func (Driver) EnumDescriptor

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

func (Driver) String

func (x Driver) String() string

type EndpointMode

type EndpointMode int32

服务发现的模式

const (
	// Docker为swarm集群服务分配一个虚拟IP
	EndpointMode_vip EndpointMode = 0
	// DNS轮询(DNSRR)服务发现不使用单个虚拟IP
	EndpointMode_dnsrr EndpointMode = 1
)

func (EndpointMode) EnumDescriptor

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

func (EndpointMode) String

func (x EndpointMode) String() string

type Environment

type Environment struct {
	// 环境变量key
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// 环境变量value
	Value                string   `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

环境变量

func (*Environment) Descriptor

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

func (*Environment) GetKey

func (m *Environment) GetKey() string

func (*Environment) GetValue

func (m *Environment) GetValue() string

func (*Environment) ProtoMessage

func (*Environment) ProtoMessage()

func (*Environment) Reset

func (m *Environment) Reset()

func (*Environment) String

func (m *Environment) String() string

func (*Environment) XXX_DiscardUnknown

func (m *Environment) XXX_DiscardUnknown()

func (*Environment) XXX_Marshal

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

func (*Environment) XXX_Merge

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

func (*Environment) XXX_Size

func (m *Environment) XXX_Size() int

func (*Environment) XXX_Unmarshal

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

type ExtraHost

type ExtraHost struct {
	// 期望访问的地址,一般即代码中约定的访问地址
	Host string `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
	// 映射的真实地址
	HostMap              string   `protobuf:"bytes,2,opt,name=hostMap,proto3" json:"hostMap,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

dns服务

func (*ExtraHost) Descriptor

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

func (*ExtraHost) GetHost

func (m *ExtraHost) GetHost() string

func (*ExtraHost) GetHostMap

func (m *ExtraHost) GetHostMap() string

func (*ExtraHost) ProtoMessage

func (*ExtraHost) ProtoMessage()

func (*ExtraHost) Reset

func (m *ExtraHost) Reset()

func (*ExtraHost) String

func (m *ExtraHost) String() string

func (*ExtraHost) XXX_DiscardUnknown

func (m *ExtraHost) XXX_DiscardUnknown()

func (*ExtraHost) XXX_Marshal

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

func (*ExtraHost) XXX_Merge

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

func (*ExtraHost) XXX_Size

func (m *ExtraHost) XXX_Size() int

func (*ExtraHost) XXX_Unmarshal

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

type Image

type Image struct {
	// 镜像名称
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// 镜像版本号
	Version              string   `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

镜像服务

func (*Image) Descriptor

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

func (*Image) GetName

func (m *Image) GetName() string

func (*Image) GetVersion

func (m *Image) GetVersion() string

func (*Image) ProtoMessage

func (*Image) ProtoMessage()

func (*Image) Reset

func (m *Image) Reset()

func (*Image) String

func (m *Image) String() string

func (*Image) XXX_DiscardUnknown

func (m *Image) XXX_DiscardUnknown()

func (*Image) XXX_Marshal

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

func (*Image) XXX_Merge

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

func (*Image) XXX_Size

func (m *Image) XXX_Size() int

func (*Image) XXX_Unmarshal

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

type ImageServerClient

type ImageServerClient interface {
	List(ctx context.Context, in *ReqImageList, opts ...grpc.CallOption) (*RespImageList, error)
	Pull(ctx context.Context, in *ReqImagePull, opts ...grpc.CallOption) (*RespImagePull, error)
	Remove(ctx context.Context, in *ReqImageRemove, opts ...grpc.CallOption) (*RespImageRemove, error)
	Tag(ctx context.Context, in *ReqImageTag, opts ...grpc.CallOption) (*RespImageTag, error)
}

ImageServerClient is the client API for ImageServer service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

type ImageServerServer

ImageServerServer is the server API for ImageServer service.

type Meta

type Meta struct {
	Version              *Version `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	CreatedAt            *Time    `protobuf:"bytes,2,opt,name=createdAt,proto3" json:"createdAt,omitempty"`
	UpdatedAt            *Time    `protobuf:"bytes,3,opt,name=updatedAt,proto3" json:"updatedAt,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Meta is a base object inherited by most of the other once.

func (*Meta) Descriptor

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

func (*Meta) GetCreatedAt

func (m *Meta) GetCreatedAt() *Time

func (*Meta) GetUpdatedAt

func (m *Meta) GetUpdatedAt() *Time

func (*Meta) GetVersion

func (m *Meta) GetVersion() *Version

func (*Meta) ProtoMessage

func (*Meta) ProtoMessage()

func (*Meta) Reset

func (m *Meta) Reset()

func (*Meta) String

func (m *Meta) String() string

func (*Meta) XXX_DiscardUnknown

func (m *Meta) XXX_DiscardUnknown()

func (*Meta) XXX_Marshal

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

func (*Meta) XXX_Merge

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

func (*Meta) XXX_Size

func (m *Meta) XXX_Size() int

func (*Meta) XXX_Unmarshal

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

type Mode

type Mode int32

服务部署模式

const (
	// 全局(每个群集节点只有一个容器)
	Mode_global Mode = 0
	// 副本(指定容器的数量)
	Mode_replicated Mode = 1
)

func (Mode) EnumDescriptor

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

func (Mode) String

func (x Mode) String() string

type Network

type Network struct {
	Name                 string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Driver               string            `protobuf:"bytes,2,opt,name=driver,proto3" json:"driver,omitempty"`
	Scope                string            `protobuf:"bytes,3,opt,name=scope,proto3" json:"scope,omitempty"`
	Attachable           bool              `protobuf:"varint,4,opt,name=attachable,proto3" json:"attachable,omitempty"`
	Labels               map[string]string `` /* 153-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*Network) Descriptor

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

func (*Network) GetAttachable

func (m *Network) GetAttachable() bool

func (*Network) GetDriver

func (m *Network) GetDriver() string

func (*Network) GetLabels

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

func (*Network) GetName

func (m *Network) GetName() string

func (*Network) GetScope

func (m *Network) GetScope() string

func (*Network) ProtoMessage

func (*Network) ProtoMessage()

func (*Network) Reset

func (m *Network) Reset()

func (*Network) String

func (m *Network) String() string

func (*Network) XXX_DiscardUnknown

func (m *Network) XXX_DiscardUnknown()

func (*Network) XXX_Marshal

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

func (*Network) XXX_Merge

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

func (*Network) XXX_Size

func (m *Network) XXX_Size() int

func (*Network) XXX_Unmarshal

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

type Node

type Node struct {
	// kaatxwrxdc1u0dcut5ij88jqp
	ID string `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	// "2020-05-18T02:25:51.0499467Z"
	CreateAt string `protobuf:"bytes,2,opt,name=createAt,proto3" json:"createAt,omitempty"`
	// "2020-05-18T02:25:51.0499467Z"
	UpdateAt             string             `protobuf:"bytes,3,opt,name=updateAt,proto3" json:"updateAt,omitempty"`
	Spec                 *NodeSpec          `protobuf:"bytes,4,opt,name=spec,proto3" json:"spec,omitempty"`
	Description          *NodeDescription   `protobuf:"bytes,5,opt,name=description,proto3" json:"description,omitempty"`
	Status               *NodeStatus        `protobuf:"bytes,6,opt,name=status,proto3" json:"status,omitempty"`
	ManagerStatus        *NodeManagerStatus `protobuf:"bytes,7,opt,name=managerStatus,proto3" json:"managerStatus,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*Node) Descriptor

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

func (*Node) GetCreateAt

func (m *Node) GetCreateAt() string

func (*Node) GetDescription

func (m *Node) GetDescription() *NodeDescription

func (*Node) GetID

func (m *Node) GetID() string

func (*Node) GetManagerStatus

func (m *Node) GetManagerStatus() *NodeManagerStatus

func (*Node) GetSpec

func (m *Node) GetSpec() *NodeSpec

func (*Node) GetStatus

func (m *Node) GetStatus() *NodeStatus

func (*Node) GetUpdateAt

func (m *Node) GetUpdateAt() string

func (*Node) ProtoMessage

func (*Node) ProtoMessage()

func (*Node) Reset

func (m *Node) Reset()

func (*Node) String

func (m *Node) String() string

func (*Node) XXX_DiscardUnknown

func (m *Node) XXX_DiscardUnknown()

func (*Node) XXX_Marshal

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

func (*Node) XXX_Merge

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

func (*Node) XXX_Size

func (m *Node) XXX_Size() int

func (*Node) XXX_Unmarshal

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

type NodeDescription

type NodeDescription struct {
	// docker-desktop
	Hostname             string                    `protobuf:"bytes,1,opt,name=hostname,proto3" json:"hostname,omitempty"`
	Platform             *NodeDescriptionPlatform  `protobuf:"bytes,2,opt,name=platform,proto3" json:"platform,omitempty"`
	Resource             *NodeDescriptionResources `protobuf:"bytes,3,opt,name=resource,proto3" json:"resource,omitempty"`
	Engine               *NodeDescriptionEngine    `protobuf:"bytes,4,opt,name=engine,proto3" json:"engine,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (*NodeDescription) Descriptor

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

func (*NodeDescription) GetEngine

func (m *NodeDescription) GetEngine() *NodeDescriptionEngine

func (*NodeDescription) GetHostname

func (m *NodeDescription) GetHostname() string

func (*NodeDescription) GetPlatform

func (m *NodeDescription) GetPlatform() *NodeDescriptionPlatform

func (*NodeDescription) GetResource

func (m *NodeDescription) GetResource() *NodeDescriptionResources

func (*NodeDescription) ProtoMessage

func (*NodeDescription) ProtoMessage()

func (*NodeDescription) Reset

func (m *NodeDescription) Reset()

func (*NodeDescription) String

func (m *NodeDescription) String() string

func (*NodeDescription) XXX_DiscardUnknown

func (m *NodeDescription) XXX_DiscardUnknown()

func (*NodeDescription) XXX_Marshal

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

func (*NodeDescription) XXX_Merge

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

func (*NodeDescription) XXX_Size

func (m *NodeDescription) XXX_Size() int

func (*NodeDescription) XXX_Unmarshal

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

type NodeDescriptionEngine

type NodeDescriptionEngine struct {
	// 19.03.8
	Version              string   `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NodeDescriptionEngine) Descriptor

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

func (*NodeDescriptionEngine) GetVersion

func (m *NodeDescriptionEngine) GetVersion() string

func (*NodeDescriptionEngine) ProtoMessage

func (*NodeDescriptionEngine) ProtoMessage()

func (*NodeDescriptionEngine) Reset

func (m *NodeDescriptionEngine) Reset()

func (*NodeDescriptionEngine) String

func (m *NodeDescriptionEngine) String() string

func (*NodeDescriptionEngine) XXX_DiscardUnknown

func (m *NodeDescriptionEngine) XXX_DiscardUnknown()

func (*NodeDescriptionEngine) XXX_Marshal

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

func (*NodeDescriptionEngine) XXX_Merge

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

func (*NodeDescriptionEngine) XXX_Size

func (m *NodeDescriptionEngine) XXX_Size() int

func (*NodeDescriptionEngine) XXX_Unmarshal

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

type NodeDescriptionPlatform

type NodeDescriptionPlatform struct {
	// x86_64
	Architecture string `protobuf:"bytes,1,opt,name=architecture,proto3" json:"architecture,omitempty"`
	// linux
	OS                   string   `protobuf:"bytes,2,opt,name=OS,proto3" json:"OS,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NodeDescriptionPlatform) Descriptor

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

func (*NodeDescriptionPlatform) GetArchitecture

func (m *NodeDescriptionPlatform) GetArchitecture() string

func (*NodeDescriptionPlatform) GetOS

func (m *NodeDescriptionPlatform) GetOS() string

func (*NodeDescriptionPlatform) ProtoMessage

func (*NodeDescriptionPlatform) ProtoMessage()

func (*NodeDescriptionPlatform) Reset

func (m *NodeDescriptionPlatform) Reset()

func (*NodeDescriptionPlatform) String

func (m *NodeDescriptionPlatform) String() string

func (*NodeDescriptionPlatform) XXX_DiscardUnknown

func (m *NodeDescriptionPlatform) XXX_DiscardUnknown()

func (*NodeDescriptionPlatform) XXX_Marshal

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

func (*NodeDescriptionPlatform) XXX_Merge

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

func (*NodeDescriptionPlatform) XXX_Size

func (m *NodeDescriptionPlatform) XXX_Size() int

func (*NodeDescriptionPlatform) XXX_Unmarshal

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

type NodeDescriptionResources

type NodeDescriptionResources struct {
	CpuCount uint32 `protobuf:"varint,1,opt,name=cpuCount,proto3" json:"cpuCount,omitempty"`
	// 6000000000
	NanoCPUs int64 `protobuf:"varint,2,opt,name=nanoCPUs,proto3" json:"nanoCPUs,omitempty"`
	// 4129218560
	MemoryBytes          int64    `protobuf:"varint,3,opt,name=memoryBytes,proto3" json:"memoryBytes,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NodeDescriptionResources) Descriptor

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

func (*NodeDescriptionResources) GetCpuCount

func (m *NodeDescriptionResources) GetCpuCount() uint32

func (*NodeDescriptionResources) GetMemoryBytes

func (m *NodeDescriptionResources) GetMemoryBytes() int64

func (*NodeDescriptionResources) GetNanoCPUs

func (m *NodeDescriptionResources) GetNanoCPUs() int64

func (*NodeDescriptionResources) ProtoMessage

func (*NodeDescriptionResources) ProtoMessage()

func (*NodeDescriptionResources) Reset

func (m *NodeDescriptionResources) Reset()

func (*NodeDescriptionResources) String

func (m *NodeDescriptionResources) String() string

func (*NodeDescriptionResources) XXX_DiscardUnknown

func (m *NodeDescriptionResources) XXX_DiscardUnknown()

func (*NodeDescriptionResources) XXX_Marshal

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

func (*NodeDescriptionResources) XXX_Merge

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

func (*NodeDescriptionResources) XXX_Size

func (m *NodeDescriptionResources) XXX_Size() int

func (*NodeDescriptionResources) XXX_Unmarshal

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

type NodeManagerStatus

type NodeManagerStatus struct {
	// true
	Leader bool `protobuf:"varint,1,opt,name=leader,proto3" json:"leader,omitempty"`
	// reachable
	Reachability string `protobuf:"bytes,2,opt,name=reachability,proto3" json:"reachability,omitempty"`
	// 192.168.65.3:2377
	Addr                 string   `protobuf:"bytes,3,opt,name=addr,proto3" json:"addr,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NodeManagerStatus) Descriptor

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

func (*NodeManagerStatus) GetAddr

func (m *NodeManagerStatus) GetAddr() string

func (*NodeManagerStatus) GetLeader

func (m *NodeManagerStatus) GetLeader() bool

func (*NodeManagerStatus) GetReachability

func (m *NodeManagerStatus) GetReachability() string

func (*NodeManagerStatus) ProtoMessage

func (*NodeManagerStatus) ProtoMessage()

func (*NodeManagerStatus) Reset

func (m *NodeManagerStatus) Reset()

func (*NodeManagerStatus) String

func (m *NodeManagerStatus) String() string

func (*NodeManagerStatus) XXX_DiscardUnknown

func (m *NodeManagerStatus) XXX_DiscardUnknown()

func (*NodeManagerStatus) XXX_Marshal

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

func (*NodeManagerStatus) XXX_Merge

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

func (*NodeManagerStatus) XXX_Size

func (m *NodeManagerStatus) XXX_Size() int

func (*NodeManagerStatus) XXX_Unmarshal

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

type NodeSpec

type NodeSpec struct {
	// manager
	Role string `protobuf:"bytes,1,opt,name=role,proto3" json:"role,omitempty"`
	// active
	Availability         string   `protobuf:"bytes,2,opt,name=availability,proto3" json:"availability,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NodeSpec) Descriptor

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

func (*NodeSpec) GetAvailability

func (m *NodeSpec) GetAvailability() string

func (*NodeSpec) GetRole

func (m *NodeSpec) GetRole() string

func (*NodeSpec) ProtoMessage

func (*NodeSpec) ProtoMessage()

func (*NodeSpec) Reset

func (m *NodeSpec) Reset()

func (*NodeSpec) String

func (m *NodeSpec) String() string

func (*NodeSpec) XXX_DiscardUnknown

func (m *NodeSpec) XXX_DiscardUnknown()

func (*NodeSpec) XXX_Marshal

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

func (*NodeSpec) XXX_Merge

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

func (*NodeSpec) XXX_Size

func (m *NodeSpec) XXX_Size() int

func (*NodeSpec) XXX_Unmarshal

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

type NodeStatus

type NodeStatus struct {
	// ready
	State string `protobuf:"bytes,1,opt,name=state,proto3" json:"state,omitempty"`
	// 192.168.65.3
	Addr                 string   `protobuf:"bytes,2,opt,name=addr,proto3" json:"addr,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NodeStatus) Descriptor

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

func (*NodeStatus) GetAddr

func (m *NodeStatus) GetAddr() string

func (*NodeStatus) GetState

func (m *NodeStatus) GetState() string

func (*NodeStatus) ProtoMessage

func (*NodeStatus) ProtoMessage()

func (*NodeStatus) Reset

func (m *NodeStatus) Reset()

func (*NodeStatus) String

func (m *NodeStatus) String() string

func (*NodeStatus) XXX_DiscardUnknown

func (m *NodeStatus) XXX_DiscardUnknown()

func (*NodeStatus) XXX_Marshal

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

func (*NodeStatus) XXX_Merge

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

func (*NodeStatus) XXX_Size

func (m *NodeStatus) XXX_Size() int

func (*NodeStatus) XXX_Unmarshal

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

type Order

type Order int32

更新期间的操作顺序

const (
	// 旧任务在开始新任务之前停止
	Order_stopFirst Order = 0
	// 首先启动新任务,并且正在运行的任务短暂重叠
	Order_startFirst Order = 1
)

func (Order) EnumDescriptor

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

func (Order) String

func (x Order) String() string

type Placement

type Placement struct {
	// 约定服务运行位置
	//
	// node.role==manager
	//
	// node.hostname == test1.spuddy.org
	//
	// node.labels.Tomcat == true
	//
	// engine.labels.operatingsystem==ubuntu 18.04
	Constraints []string `protobuf:"bytes,1,rep,name=constraints,proto3" json:"constraints,omitempty"`
	// 可以通过设置服务将任务均匀地划分到不同类别的节点上
	//
	// 如在一组数据中心或可用性区域上平衡任务
	//
	// spread=node.labels.datacenter
	Preferences          []*Preference `protobuf:"bytes,2,rep,name=preferences,proto3" json:"preferences,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

指定约束和偏好设置

func (*Placement) Descriptor

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

func (*Placement) GetConstraints

func (m *Placement) GetConstraints() []string

func (*Placement) GetPreferences

func (m *Placement) GetPreferences() []*Preference

func (*Placement) ProtoMessage

func (*Placement) ProtoMessage()

func (*Placement) Reset

func (m *Placement) Reset()

func (*Placement) String

func (m *Placement) String() string

func (*Placement) XXX_DiscardUnknown

func (m *Placement) XXX_DiscardUnknown()

func (*Placement) XXX_Marshal

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

func (*Placement) XXX_Merge

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

func (*Placement) XXX_Size

func (m *Placement) XXX_Size() int

func (*Placement) XXX_Unmarshal

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

type Port

type Port struct {
	// 公开映射端口号
	Publish string `protobuf:"bytes,1,opt,name=publish,proto3" json:"publish,omitempty"`
	// 容器内部端口号
	Target               string   `protobuf:"bytes,2,opt,name=target,proto3" json:"target,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

port 端口映射策略

"3000"

"3000-3005"

"8000:8000"

"9090-9091:8080-8081"

"49100:22"

"127.0.0.1:8001:8001"

"127.0.0.1:5000-5010:5000-5010"

"6060:6060/udp"

"12400-12500:1240"

func (*Port) Descriptor

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

func (*Port) GetPublish

func (m *Port) GetPublish() string

func (*Port) GetTarget

func (m *Port) GetTarget() string

func (*Port) ProtoMessage

func (*Port) ProtoMessage()

func (*Port) Reset

func (m *Port) Reset()

func (*Port) String

func (m *Port) String() string

func (*Port) XXX_DiscardUnknown

func (m *Port) XXX_DiscardUnknown()

func (*Port) XXX_Marshal

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

func (*Port) XXX_Merge

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

func (*Port) XXX_Size

func (m *Port) XXX_Size() int

func (*Port) XXX_Unmarshal

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

type PortMapping

type PortMapping struct {
	// 传输协议,如TCP
	Protocol string `protobuf:"bytes,1,opt,name=protocol,proto3" json:"protocol,omitempty"`
	// 容器内部端口号
	ContainerPort string `protobuf:"bytes,2,opt,name=containerPort,proto3" json:"containerPort,omitempty"`
	// 映射外部端口号
	OutputPort           string   `protobuf:"bytes,3,opt,name=outputPort,proto3" json:"outputPort,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

PortMapping 端口映射内容

func (*PortMapping) Descriptor

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

func (*PortMapping) GetContainerPort

func (m *PortMapping) GetContainerPort() string

func (*PortMapping) GetOutputPort

func (m *PortMapping) GetOutputPort() string

func (*PortMapping) GetProtocol

func (m *PortMapping) GetProtocol() string

func (*PortMapping) ProtoMessage

func (*PortMapping) ProtoMessage()

func (*PortMapping) Reset

func (m *PortMapping) Reset()

func (*PortMapping) String

func (m *PortMapping) String() string

func (*PortMapping) XXX_DiscardUnknown

func (m *PortMapping) XXX_DiscardUnknown()

func (*PortMapping) XXX_Marshal

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

func (*PortMapping) XXX_Merge

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

func (*PortMapping) XXX_Size

func (m *PortMapping) XXX_Size() int

func (*PortMapping) XXX_Unmarshal

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

type Preference

type Preference struct {
	// 均匀传播的对象属性
	Spread               string   `protobuf:"bytes,1,opt,name=spread,proto3" json:"spread,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

可以通过设置服务将任务均匀地划分到不同类别的节点上

func (*Preference) Descriptor

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

func (*Preference) GetSpread

func (m *Preference) GetSpread() string

func (*Preference) ProtoMessage

func (*Preference) ProtoMessage()

func (*Preference) Reset

func (m *Preference) Reset()

func (*Preference) String

func (m *Preference) String() string

func (*Preference) XXX_DiscardUnknown

func (m *Preference) XXX_DiscardUnknown()

func (*Preference) XXX_Marshal

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

func (*Preference) XXX_Merge

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

func (*Preference) XXX_Size

func (m *Preference) XXX_Size() int

func (*Preference) XXX_Unmarshal

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

type ProcServerClient

type ProcServerClient interface {
	Resources(ctx context.Context, in *ReqResources, opts ...grpc.CallOption) (*RespResources, error)
}

ProcServerClient is the client API for ProcServer service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewProcServerClient

func NewProcServerClient(cc grpc.ClientConnInterface) ProcServerClient

type ProcServerServer

type ProcServerServer interface {
	Resources(context.Context, *ReqResources) (*RespResources, error)
}

ProcServerServer is the server API for ProcServer service.

type ProjectServerClient

type ProjectServerClient interface {
	// Deploy 部署新的堆栈或更新现有堆栈
	Deploy(ctx context.Context, in *ReqProject, opts ...grpc.CallOption) (*Response, error)
	Update(ctx context.Context, in *ReqProjectUpdate, opts ...grpc.CallOption) (*Response, error)
	Remove(ctx context.Context, in *ReqProjectRemove, opts ...grpc.CallOption) (*Response, error)
	ServiceState(ctx context.Context, in *ServiceCompare, opts ...grpc.CallOption) (*ServiceCompare, error)
}

ProjectServerClient is the client API for ProjectServer service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

type ProjectServerServer

type ProjectServerServer interface {
	// Deploy 部署新的堆栈或更新现有堆栈
	Deploy(context.Context, *ReqProject) (*Response, error)
	Update(context.Context, *ReqProjectUpdate) (*Response, error)
	Remove(context.Context, *ReqProjectRemove) (*Response, error)
	ServiceState(context.Context, *ServiceCompare) (*ServiceCompare, error)
}

ProjectServerServer is the server API for ProjectServer service.

type RemoteManager

type RemoteManager struct {
	NodeID               string   `protobuf:"bytes,1,opt,name=nodeID,proto3" json:"nodeID,omitempty"`
	Addr                 string   `protobuf:"bytes,2,opt,name=addr,proto3" json:"addr,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RemoteManager) Descriptor

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

func (*RemoteManager) GetAddr

func (m *RemoteManager) GetAddr() string

func (*RemoteManager) GetNodeID

func (m *RemoteManager) GetNodeID() string

func (*RemoteManager) ProtoMessage

func (*RemoteManager) ProtoMessage()

func (*RemoteManager) Reset

func (m *RemoteManager) Reset()

func (*RemoteManager) String

func (m *RemoteManager) String() string

func (*RemoteManager) XXX_DiscardUnknown

func (m *RemoteManager) XXX_DiscardUnknown()

func (*RemoteManager) XXX_Marshal

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

func (*RemoteManager) XXX_Merge

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

func (*RemoteManager) XXX_Size

func (m *RemoteManager) XXX_Size() int

func (*RemoteManager) XXX_Unmarshal

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

type ReqCompose

type ReqCompose struct {
	StackName            string   `protobuf:"bytes,1,opt,name=stackName,proto3" json:"stackName,omitempty"`
	Compose              *Compose `protobuf:"bytes,2,opt,name=compose,proto3" json:"compose,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ReqCompose) Descriptor

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

func (*ReqCompose) GetCompose

func (m *ReqCompose) GetCompose() *Compose

func (*ReqCompose) GetStackName

func (m *ReqCompose) GetStackName() string

func (*ReqCompose) ProtoMessage

func (*ReqCompose) ProtoMessage()

func (*ReqCompose) Reset

func (m *ReqCompose) Reset()

func (*ReqCompose) String

func (m *ReqCompose) String() string

func (*ReqCompose) XXX_DiscardUnknown

func (m *ReqCompose) XXX_DiscardUnknown()

func (*ReqCompose) XXX_Marshal

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

func (*ReqCompose) XXX_Merge

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

func (*ReqCompose) XXX_Size

func (m *ReqCompose) XXX_Size() int

func (*ReqCompose) XXX_Unmarshal

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

type ReqContainerInspect

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

func (*ReqContainerInspect) Descriptor

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

func (*ReqContainerInspect) GetContainerID

func (m *ReqContainerInspect) GetContainerID() string

func (*ReqContainerInspect) ProtoMessage

func (*ReqContainerInspect) ProtoMessage()

func (*ReqContainerInspect) Reset

func (m *ReqContainerInspect) Reset()

func (*ReqContainerInspect) String

func (m *ReqContainerInspect) String() string

func (*ReqContainerInspect) XXX_DiscardUnknown

func (m *ReqContainerInspect) XXX_DiscardUnknown()

func (*ReqContainerInspect) XXX_Marshal

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

func (*ReqContainerInspect) XXX_Merge

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

func (*ReqContainerInspect) XXX_Size

func (m *ReqContainerInspect) XXX_Size() int

func (*ReqContainerInspect) XXX_Unmarshal

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

type ReqContainerList

type ReqContainerList struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ReqContainerList) Descriptor

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

func (*ReqContainerList) ProtoMessage

func (*ReqContainerList) ProtoMessage()

func (*ReqContainerList) Reset

func (m *ReqContainerList) Reset()

func (*ReqContainerList) String

func (m *ReqContainerList) String() string

func (*ReqContainerList) XXX_DiscardUnknown

func (m *ReqContainerList) XXX_DiscardUnknown()

func (*ReqContainerList) XXX_Marshal

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

func (*ReqContainerList) XXX_Merge

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

func (*ReqContainerList) XXX_Size

func (m *ReqContainerList) XXX_Size() int

func (*ReqContainerList) XXX_Unmarshal

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

type ReqContainerLogs

type ReqContainerLogs struct {
	ContainerID          string   `protobuf:"bytes,1,opt,name=containerID,proto3" json:"containerID,omitempty"`
	Since                *Time    `protobuf:"bytes,2,opt,name=since,proto3" json:"since,omitempty"`
	Until                *Time    `protobuf:"bytes,3,opt,name=until,proto3" json:"until,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ReqContainerLogs) Descriptor

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

func (*ReqContainerLogs) GetContainerID

func (m *ReqContainerLogs) GetContainerID() string

func (*ReqContainerLogs) GetSince

func (m *ReqContainerLogs) GetSince() *Time

func (*ReqContainerLogs) GetUntil

func (m *ReqContainerLogs) GetUntil() *Time

func (*ReqContainerLogs) ProtoMessage

func (*ReqContainerLogs) ProtoMessage()

func (*ReqContainerLogs) Reset

func (m *ReqContainerLogs) Reset()

func (*ReqContainerLogs) String

func (m *ReqContainerLogs) String() string

func (*ReqContainerLogs) XXX_DiscardUnknown

func (m *ReqContainerLogs) XXX_DiscardUnknown()

func (*ReqContainerLogs) XXX_Marshal

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

func (*ReqContainerLogs) XXX_Merge

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

func (*ReqContainerLogs) XXX_Size

func (m *ReqContainerLogs) XXX_Size() int

func (*ReqContainerLogs) XXX_Unmarshal

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

type ReqContainerStats

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

func (*ReqContainerStats) Descriptor

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

func (*ReqContainerStats) GetContainerID

func (m *ReqContainerStats) GetContainerID() string

func (*ReqContainerStats) ProtoMessage

func (*ReqContainerStats) ProtoMessage()

func (*ReqContainerStats) Reset

func (m *ReqContainerStats) Reset()

func (*ReqContainerStats) String

func (m *ReqContainerStats) String() string

func (*ReqContainerStats) XXX_DiscardUnknown

func (m *ReqContainerStats) XXX_DiscardUnknown()

func (*ReqContainerStats) XXX_Marshal

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

func (*ReqContainerStats) XXX_Merge

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

func (*ReqContainerStats) XXX_Size

func (m *ReqContainerStats) XXX_Size() int

func (*ReqContainerStats) XXX_Unmarshal

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

type ReqContainerStatsAll

type ReqContainerStatsAll struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ReqContainerStatsAll) Descriptor

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

func (*ReqContainerStatsAll) ProtoMessage

func (*ReqContainerStatsAll) ProtoMessage()

func (*ReqContainerStatsAll) Reset

func (m *ReqContainerStatsAll) Reset()

func (*ReqContainerStatsAll) String

func (m *ReqContainerStatsAll) String() string

func (*ReqContainerStatsAll) XXX_DiscardUnknown

func (m *ReqContainerStatsAll) XXX_DiscardUnknown()

func (*ReqContainerStatsAll) XXX_Marshal

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

func (*ReqContainerStatsAll) XXX_Merge

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

func (*ReqContainerStatsAll) XXX_Size

func (m *ReqContainerStatsAll) XXX_Size() int

func (*ReqContainerStatsAll) XXX_Unmarshal

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

type ReqContainerSync

type ReqContainerSync struct {
	Docker               *DockerInfo  `protobuf:"bytes,1,opt,name=docker,proto3" json:"docker,omitempty"`
	Containers           []*Container `protobuf:"bytes,2,rep,name=containers,proto3" json:"containers,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*ReqContainerSync) Descriptor

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

func (*ReqContainerSync) GetContainers

func (m *ReqContainerSync) GetContainers() []*Container

func (*ReqContainerSync) GetDocker

func (m *ReqContainerSync) GetDocker() *DockerInfo

func (*ReqContainerSync) ProtoMessage

func (*ReqContainerSync) ProtoMessage()

func (*ReqContainerSync) Reset

func (m *ReqContainerSync) Reset()

func (*ReqContainerSync) String

func (m *ReqContainerSync) String() string

func (*ReqContainerSync) XXX_DiscardUnknown

func (m *ReqContainerSync) XXX_DiscardUnknown()

func (*ReqContainerSync) XXX_Marshal

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

func (*ReqContainerSync) XXX_Merge

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

func (*ReqContainerSync) XXX_Size

func (m *ReqContainerSync) XXX_Size() int

func (*ReqContainerSync) XXX_Unmarshal

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

type ReqImageList

type ReqImageList struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ReqImageList) Descriptor

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

func (*ReqImageList) ProtoMessage

func (*ReqImageList) ProtoMessage()

func (*ReqImageList) Reset

func (m *ReqImageList) Reset()

func (*ReqImageList) String

func (m *ReqImageList) String() string

func (*ReqImageList) XXX_DiscardUnknown

func (m *ReqImageList) XXX_DiscardUnknown()

func (*ReqImageList) XXX_Marshal

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

func (*ReqImageList) XXX_Merge

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

func (*ReqImageList) XXX_Size

func (m *ReqImageList) XXX_Size() int

func (*ReqImageList) XXX_Unmarshal

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

type ReqImagePull

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

func (*ReqImagePull) Descriptor

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

func (*ReqImagePull) GetRefStr

func (m *ReqImagePull) GetRefStr() string

func (*ReqImagePull) ProtoMessage

func (*ReqImagePull) ProtoMessage()

func (*ReqImagePull) Reset

func (m *ReqImagePull) Reset()

func (*ReqImagePull) String

func (m *ReqImagePull) String() string

func (*ReqImagePull) XXX_DiscardUnknown

func (m *ReqImagePull) XXX_DiscardUnknown()

func (*ReqImagePull) XXX_Marshal

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

func (*ReqImagePull) XXX_Merge

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

func (*ReqImagePull) XXX_Size

func (m *ReqImagePull) XXX_Size() int

func (*ReqImagePull) XXX_Unmarshal

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

type ReqImageRemove

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

func (*ReqImageRemove) Descriptor

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

func (*ReqImageRemove) GetID

func (m *ReqImageRemove) GetID() string

func (*ReqImageRemove) ProtoMessage

func (*ReqImageRemove) ProtoMessage()

func (*ReqImageRemove) Reset

func (m *ReqImageRemove) Reset()

func (*ReqImageRemove) String

func (m *ReqImageRemove) String() string

func (*ReqImageRemove) XXX_DiscardUnknown

func (m *ReqImageRemove) XXX_DiscardUnknown()

func (*ReqImageRemove) XXX_Marshal

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

func (*ReqImageRemove) XXX_Merge

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

func (*ReqImageRemove) XXX_Size

func (m *ReqImageRemove) XXX_Size() int

func (*ReqImageRemove) XXX_Unmarshal

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

type ReqImageTag

type ReqImageTag struct {
	Source               string   `protobuf:"bytes,1,opt,name=source,proto3" json:"source,omitempty"`
	Target               string   `protobuf:"bytes,2,opt,name=target,proto3" json:"target,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ReqImageTag) Descriptor

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

func (*ReqImageTag) GetSource

func (m *ReqImageTag) GetSource() string

func (*ReqImageTag) GetTarget

func (m *ReqImageTag) GetTarget() string

func (*ReqImageTag) ProtoMessage

func (*ReqImageTag) ProtoMessage()

func (*ReqImageTag) Reset

func (m *ReqImageTag) Reset()

func (*ReqImageTag) String

func (m *ReqImageTag) String() string

func (*ReqImageTag) XXX_DiscardUnknown

func (m *ReqImageTag) XXX_DiscardUnknown()

func (*ReqImageTag) XXX_Marshal

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

func (*ReqImageTag) XXX_Merge

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

func (*ReqImageTag) XXX_Size

func (m *ReqImageTag) XXX_Size() int

func (*ReqImageTag) XXX_Unmarshal

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

type ReqProject

type ReqProject struct {
	Name    string    `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Volumes []*Volume `protobuf:"bytes,2,rep,name=volumes,proto3" json:"volumes,omitempty"`
	// 启动期望服务集合
	Services             map[string]*Task `` /* 157-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*ReqProject) Descriptor

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

func (*ReqProject) GetName

func (m *ReqProject) GetName() string

func (*ReqProject) GetServices

func (m *ReqProject) GetServices() map[string]*Task

func (*ReqProject) GetVolumes

func (m *ReqProject) GetVolumes() []*Volume

func (*ReqProject) ProtoMessage

func (*ReqProject) ProtoMessage()

func (*ReqProject) Reset

func (m *ReqProject) Reset()

func (*ReqProject) String

func (m *ReqProject) String() string

func (*ReqProject) XXX_DiscardUnknown

func (m *ReqProject) XXX_DiscardUnknown()

func (*ReqProject) XXX_Marshal

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

func (*ReqProject) XXX_Merge

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

func (*ReqProject) XXX_Size

func (m *ReqProject) XXX_Size() int

func (*ReqProject) XXX_Unmarshal

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

type ReqProjectRemove

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

func (*ReqProjectRemove) Descriptor

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

func (*ReqProjectRemove) GetName

func (m *ReqProjectRemove) GetName() string

func (*ReqProjectRemove) ProtoMessage

func (*ReqProjectRemove) ProtoMessage()

func (*ReqProjectRemove) Reset

func (m *ReqProjectRemove) Reset()

func (*ReqProjectRemove) String

func (m *ReqProjectRemove) String() string

func (*ReqProjectRemove) XXX_DiscardUnknown

func (m *ReqProjectRemove) XXX_DiscardUnknown()

func (*ReqProjectRemove) XXX_Marshal

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

func (*ReqProjectRemove) XXX_Merge

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

func (*ReqProjectRemove) XXX_Size

func (m *ReqProjectRemove) XXX_Size() int

func (*ReqProjectRemove) XXX_Unmarshal

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

type ReqProjectUpdate

type ReqProjectUpdate struct {
	ProjectName          string   `protobuf:"bytes,1,opt,name=projectName,proto3" json:"projectName,omitempty"`
	ServiceName          string   `protobuf:"bytes,2,opt,name=serviceName,proto3" json:"serviceName,omitempty"`
	Service              *Task    `protobuf:"bytes,3,opt,name=service,proto3" json:"service,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ReqProjectUpdate) Descriptor

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

func (*ReqProjectUpdate) GetProjectName

func (m *ReqProjectUpdate) GetProjectName() string

func (*ReqProjectUpdate) GetService

func (m *ReqProjectUpdate) GetService() *Task

func (*ReqProjectUpdate) GetServiceName

func (m *ReqProjectUpdate) GetServiceName() string

func (*ReqProjectUpdate) ProtoMessage

func (*ReqProjectUpdate) ProtoMessage()

func (*ReqProjectUpdate) Reset

func (m *ReqProjectUpdate) Reset()

func (*ReqProjectUpdate) String

func (m *ReqProjectUpdate) String() string

func (*ReqProjectUpdate) XXX_DiscardUnknown

func (m *ReqProjectUpdate) XXX_DiscardUnknown()

func (*ReqProjectUpdate) XXX_Marshal

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

func (*ReqProjectUpdate) XXX_Merge

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

func (*ReqProjectUpdate) XXX_Size

func (m *ReqProjectUpdate) XXX_Size() int

func (*ReqProjectUpdate) XXX_Unmarshal

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

type ReqResources

type ReqResources struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ReqResources) Descriptor

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

func (*ReqResources) ProtoMessage

func (*ReqResources) ProtoMessage()

func (*ReqResources) Reset

func (m *ReqResources) Reset()

func (*ReqResources) String

func (m *ReqResources) String() string

func (*ReqResources) XXX_DiscardUnknown

func (m *ReqResources) XXX_DiscardUnknown()

func (*ReqResources) XXX_Marshal

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

func (*ReqResources) XXX_Merge

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

func (*ReqResources) XXX_Size

func (m *ReqResources) XXX_Size() int

func (*ReqResources) XXX_Unmarshal

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

type ReqServiceInspect

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

func (*ReqServiceInspect) Descriptor

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

func (*ReqServiceInspect) GetServiceID

func (m *ReqServiceInspect) GetServiceID() string

func (*ReqServiceInspect) ProtoMessage

func (*ReqServiceInspect) ProtoMessage()

func (*ReqServiceInspect) Reset

func (m *ReqServiceInspect) Reset()

func (*ReqServiceInspect) String

func (m *ReqServiceInspect) String() string

func (*ReqServiceInspect) XXX_DiscardUnknown

func (m *ReqServiceInspect) XXX_DiscardUnknown()

func (*ReqServiceInspect) XXX_Marshal

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

func (*ReqServiceInspect) XXX_Merge

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

func (*ReqServiceInspect) XXX_Size

func (m *ReqServiceInspect) XXX_Size() int

func (*ReqServiceInspect) XXX_Unmarshal

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

type ReqServiceList

type ReqServiceList struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ReqServiceList) Descriptor

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

func (*ReqServiceList) ProtoMessage

func (*ReqServiceList) ProtoMessage()

func (*ReqServiceList) Reset

func (m *ReqServiceList) Reset()

func (*ReqServiceList) String

func (m *ReqServiceList) String() string

func (*ReqServiceList) XXX_DiscardUnknown

func (m *ReqServiceList) XXX_DiscardUnknown()

func (*ReqServiceList) XXX_Marshal

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

func (*ReqServiceList) XXX_Merge

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

func (*ReqServiceList) XXX_Size

func (m *ReqServiceList) XXX_Size() int

func (*ReqServiceList) XXX_Unmarshal

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

type ReqServiceLogs

type ReqServiceLogs struct {
	ServiceID            string   `protobuf:"bytes,1,opt,name=serviceID,proto3" json:"serviceID,omitempty"`
	Since                *Time    `protobuf:"bytes,2,opt,name=since,proto3" json:"since,omitempty"`
	Until                *Time    `protobuf:"bytes,3,opt,name=until,proto3" json:"until,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ReqServiceLogs) Descriptor

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

func (*ReqServiceLogs) GetServiceID

func (m *ReqServiceLogs) GetServiceID() string

func (*ReqServiceLogs) GetSince

func (m *ReqServiceLogs) GetSince() *Time

func (*ReqServiceLogs) GetUntil

func (m *ReqServiceLogs) GetUntil() *Time

func (*ReqServiceLogs) ProtoMessage

func (*ReqServiceLogs) ProtoMessage()

func (*ReqServiceLogs) Reset

func (m *ReqServiceLogs) Reset()

func (*ReqServiceLogs) String

func (m *ReqServiceLogs) String() string

func (*ReqServiceLogs) XXX_DiscardUnknown

func (m *ReqServiceLogs) XXX_DiscardUnknown()

func (*ReqServiceLogs) XXX_Marshal

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

func (*ReqServiceLogs) XXX_Merge

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

func (*ReqServiceLogs) XXX_Size

func (m *ReqServiceLogs) XXX_Size() int

func (*ReqServiceLogs) XXX_Unmarshal

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

type ReqServiceResources

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

func (*ReqServiceResources) Descriptor

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

func (*ReqServiceResources) GetServiceID

func (m *ReqServiceResources) GetServiceID() string

func (*ReqServiceResources) ProtoMessage

func (*ReqServiceResources) ProtoMessage()

func (*ReqServiceResources) Reset

func (m *ReqServiceResources) Reset()

func (*ReqServiceResources) String

func (m *ReqServiceResources) String() string

func (*ReqServiceResources) XXX_DiscardUnknown

func (m *ReqServiceResources) XXX_DiscardUnknown()

func (*ReqServiceResources) XXX_Marshal

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

func (*ReqServiceResources) XXX_Merge

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

func (*ReqServiceResources) XXX_Size

func (m *ReqServiceResources) XXX_Size() int

func (*ReqServiceResources) XXX_Unmarshal

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

type ReqServiceResourcesAll

type ReqServiceResourcesAll struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ReqServiceResourcesAll) Descriptor

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

func (*ReqServiceResourcesAll) ProtoMessage

func (*ReqServiceResourcesAll) ProtoMessage()

func (*ReqServiceResourcesAll) Reset

func (m *ReqServiceResourcesAll) Reset()

func (*ReqServiceResourcesAll) String

func (m *ReqServiceResourcesAll) String() string

func (*ReqServiceResourcesAll) XXX_DiscardUnknown

func (m *ReqServiceResourcesAll) XXX_DiscardUnknown()

func (*ReqServiceResourcesAll) XXX_Marshal

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

func (*ReqServiceResourcesAll) XXX_Merge

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

func (*ReqServiceResourcesAll) XXX_Size

func (m *ReqServiceResourcesAll) XXX_Size() int

func (*ReqServiceResourcesAll) XXX_Unmarshal

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

type ReqStack

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

func (*ReqStack) Descriptor

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

func (*ReqStack) GetStackName

func (m *ReqStack) GetStackName() string

func (*ReqStack) ProtoMessage

func (*ReqStack) ProtoMessage()

func (*ReqStack) Reset

func (m *ReqStack) Reset()

func (*ReqStack) String

func (m *ReqStack) String() string

func (*ReqStack) XXX_DiscardUnknown

func (m *ReqStack) XXX_DiscardUnknown()

func (*ReqStack) XXX_Marshal

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

func (*ReqStack) XXX_Merge

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

func (*ReqStack) XXX_Size

func (m *ReqStack) XXX_Size() int

func (*ReqStack) XXX_Unmarshal

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

type Request

type Request struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Request) Descriptor

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

func (*Request) ProtoMessage

func (*Request) ProtoMessage()

func (*Request) Reset

func (m *Request) Reset()

func (*Request) String

func (m *Request) String() string

func (*Request) XXX_DiscardUnknown

func (m *Request) XXX_DiscardUnknown()

func (*Request) XXX_Marshal

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

func (*Request) XXX_Merge

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

func (*Request) XXX_Size

func (m *Request) XXX_Size() int

func (*Request) XXX_Unmarshal

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

type Resource

type Resource struct {
	// cpu比例,如0.5表示50%
	Cpus string `protobuf:"bytes,1,opt,name=cpus,proto3" json:"cpus,omitempty"`
	// 内存值,如50M
	Memory               string   `protobuf:"bytes,2,opt,name=memory,proto3" json:"memory,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

资源配置内容

func (*Resource) Descriptor

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

func (*Resource) GetCpus

func (m *Resource) GetCpus() string

func (*Resource) GetMemory

func (m *Resource) GetMemory() string

func (*Resource) ProtoMessage

func (*Resource) ProtoMessage()

func (*Resource) Reset

func (m *Resource) Reset()

func (*Resource) String

func (m *Resource) String() string

func (*Resource) XXX_DiscardUnknown

func (m *Resource) XXX_DiscardUnknown()

func (*Resource) XXX_Marshal

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

func (*Resource) XXX_Merge

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

func (*Resource) XXX_Size

func (m *Resource) XXX_Size() int

func (*Resource) XXX_Unmarshal

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

type ResourceInfo

type ResourceInfo struct {
	Nodal                []*Node                      `protobuf:"bytes,1,rep,name=nodal,proto3" json:"nodal,omitempty"`
	Services             []*Service                   `protobuf:"bytes,2,rep,name=services,proto3" json:"services,omitempty"`
	Nodes                map[string]*ReqContainerSync `` /* 151-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                     `json:"-"`
	XXX_unrecognized     []byte                       `json:"-"`
	XXX_sizecache        int32                        `json:"-"`
}

func (*ResourceInfo) Descriptor

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

func (*ResourceInfo) GetNodal

func (m *ResourceInfo) GetNodal() []*Node

func (*ResourceInfo) GetNodes

func (m *ResourceInfo) GetNodes() map[string]*ReqContainerSync

func (*ResourceInfo) GetServices

func (m *ResourceInfo) GetServices() []*Service

func (*ResourceInfo) ProtoMessage

func (*ResourceInfo) ProtoMessage()

func (*ResourceInfo) Reset

func (m *ResourceInfo) Reset()

func (*ResourceInfo) String

func (m *ResourceInfo) String() string

func (*ResourceInfo) XXX_DiscardUnknown

func (m *ResourceInfo) XXX_DiscardUnknown()

func (*ResourceInfo) XXX_Marshal

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

func (*ResourceInfo) XXX_Merge

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

func (*ResourceInfo) XXX_Size

func (m *ResourceInfo) XXX_Size() int

func (*ResourceInfo) XXX_Unmarshal

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

type ResourceServerClient

type ResourceServerClient interface {
	Info(ctx context.Context, in *Request, opts ...grpc.CallOption) (*ResourceInfo, error)
	ContainersSync(ctx context.Context, in *ReqContainerSync, opts ...grpc.CallOption) (*Response, error)
}

ResourceServerClient is the client API for ResourceServer service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

type ResourceServerServer

type ResourceServerServer interface {
	Info(context.Context, *Request) (*ResourceInfo, error)
	ContainersSync(context.Context, *ReqContainerSync) (*Response, error)
}

ResourceServerServer is the server API for ResourceServer service.

type Resources

type Resources struct {
	// 限制使用不超过资源
	Limits *Resource `protobuf:"bytes,1,opt,name=limits,proto3" json:"limits,omitempty"`
	// 总是可用资源
	Reservations         *Resource `protobuf:"bytes,2,opt,name=reservations,proto3" json:"reservations,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

资源配置策略

func (*Resources) Descriptor

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

func (*Resources) GetLimits

func (m *Resources) GetLimits() *Resource

func (*Resources) GetReservations

func (m *Resources) GetReservations() *Resource

func (*Resources) ProtoMessage

func (*Resources) ProtoMessage()

func (*Resources) Reset

func (m *Resources) Reset()

func (*Resources) String

func (m *Resources) String() string

func (*Resources) XXX_DiscardUnknown

func (m *Resources) XXX_DiscardUnknown()

func (*Resources) XXX_Marshal

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

func (*Resources) XXX_Merge

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

func (*Resources) XXX_Size

func (m *Resources) XXX_Size() int

func (*Resources) XXX_Unmarshal

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

type RespContainerInspect

type RespContainerInspect struct {
	Code                 Code     `protobuf:"varint,1,opt,name=code,proto3,enum=proto.Code" json:"code,omitempty"`
	ErrMsg               string   `protobuf:"bytes,2,opt,name=errMsg,proto3" json:"errMsg,omitempty"`
	Container            []byte   `protobuf:"bytes,3,opt,name=container,proto3" json:"container,omitempty"`
	Data                 []byte   `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RespContainerInspect) Descriptor

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

func (*RespContainerInspect) GetCode

func (m *RespContainerInspect) GetCode() Code

func (*RespContainerInspect) GetContainer

func (m *RespContainerInspect) GetContainer() []byte

func (*RespContainerInspect) GetData

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

func (*RespContainerInspect) GetErrMsg

func (m *RespContainerInspect) GetErrMsg() string

func (*RespContainerInspect) ProtoMessage

func (*RespContainerInspect) ProtoMessage()

func (*RespContainerInspect) Reset

func (m *RespContainerInspect) Reset()

func (*RespContainerInspect) String

func (m *RespContainerInspect) String() string

func (*RespContainerInspect) XXX_DiscardUnknown

func (m *RespContainerInspect) XXX_DiscardUnknown()

func (*RespContainerInspect) XXX_Marshal

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

func (*RespContainerInspect) XXX_Merge

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

func (*RespContainerInspect) XXX_Size

func (m *RespContainerInspect) XXX_Size() int

func (*RespContainerInspect) XXX_Unmarshal

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

type RespContainerList

type RespContainerList struct {
	Code                 Code     `protobuf:"varint,1,opt,name=code,proto3,enum=proto.Code" json:"code,omitempty"`
	ErrMsg               string   `protobuf:"bytes,2,opt,name=errMsg,proto3" json:"errMsg,omitempty"`
	Containers           []byte   `protobuf:"bytes,3,opt,name=containers,proto3" json:"containers,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RespContainerList) Descriptor

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

func (*RespContainerList) GetCode

func (m *RespContainerList) GetCode() Code

func (*RespContainerList) GetContainers

func (m *RespContainerList) GetContainers() []byte

func (*RespContainerList) GetErrMsg

func (m *RespContainerList) GetErrMsg() string

func (*RespContainerList) ProtoMessage

func (*RespContainerList) ProtoMessage()

func (*RespContainerList) Reset

func (m *RespContainerList) Reset()

func (*RespContainerList) String

func (m *RespContainerList) String() string

func (*RespContainerList) XXX_DiscardUnknown

func (m *RespContainerList) XXX_DiscardUnknown()

func (*RespContainerList) XXX_Marshal

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

func (*RespContainerList) XXX_Merge

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

func (*RespContainerList) XXX_Size

func (m *RespContainerList) XXX_Size() int

func (*RespContainerList) XXX_Unmarshal

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

type RespContainerLogs

type RespContainerLogs struct {
	Code                 Code     `protobuf:"varint,1,opt,name=code,proto3,enum=proto.Code" json:"code,omitempty"`
	ErrMsg               string   `protobuf:"bytes,2,opt,name=errMsg,proto3" json:"errMsg,omitempty"`
	Logs                 []byte   `protobuf:"bytes,3,opt,name=logs,proto3" json:"logs,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RespContainerLogs) Descriptor

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

func (*RespContainerLogs) GetCode

func (m *RespContainerLogs) GetCode() Code

func (*RespContainerLogs) GetErrMsg

func (m *RespContainerLogs) GetErrMsg() string

func (*RespContainerLogs) GetLogs

func (m *RespContainerLogs) GetLogs() []byte

func (*RespContainerLogs) ProtoMessage

func (*RespContainerLogs) ProtoMessage()

func (*RespContainerLogs) Reset

func (m *RespContainerLogs) Reset()

func (*RespContainerLogs) String

func (m *RespContainerLogs) String() string

func (*RespContainerLogs) XXX_DiscardUnknown

func (m *RespContainerLogs) XXX_DiscardUnknown()

func (*RespContainerLogs) XXX_Marshal

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

func (*RespContainerLogs) XXX_Merge

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

func (*RespContainerLogs) XXX_Size

func (m *RespContainerLogs) XXX_Size() int

func (*RespContainerLogs) XXX_Unmarshal

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

type RespContainerStats

type RespContainerStats struct {
	Code                 Code     `protobuf:"varint,1,opt,name=code,proto3,enum=proto.Code" json:"code,omitempty"`
	ErrMsg               string   `protobuf:"bytes,2,opt,name=errMsg,proto3" json:"errMsg,omitempty"`
	Stats                []byte   `protobuf:"bytes,3,opt,name=stats,proto3" json:"stats,omitempty"`
	OsType               string   `protobuf:"bytes,4,opt,name=osType,proto3" json:"osType,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RespContainerStats) Descriptor

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

func (*RespContainerStats) GetCode

func (m *RespContainerStats) GetCode() Code

func (*RespContainerStats) GetErrMsg

func (m *RespContainerStats) GetErrMsg() string

func (*RespContainerStats) GetOsType

func (m *RespContainerStats) GetOsType() string

func (*RespContainerStats) GetStats

func (m *RespContainerStats) GetStats() []byte

func (*RespContainerStats) ProtoMessage

func (*RespContainerStats) ProtoMessage()

func (*RespContainerStats) Reset

func (m *RespContainerStats) Reset()

func (*RespContainerStats) String

func (m *RespContainerStats) String() string

func (*RespContainerStats) XXX_DiscardUnknown

func (m *RespContainerStats) XXX_DiscardUnknown()

func (*RespContainerStats) XXX_Marshal

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

func (*RespContainerStats) XXX_Merge

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

func (*RespContainerStats) XXX_Size

func (m *RespContainerStats) XXX_Size() int

func (*RespContainerStats) XXX_Unmarshal

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

type RespContainerStatsAll

type RespContainerStatsAll struct {
	Code                 Code     `protobuf:"varint,1,opt,name=code,proto3,enum=proto.Code" json:"code,omitempty"`
	ErrMsg               string   `protobuf:"bytes,2,opt,name=errMsg,proto3" json:"errMsg,omitempty"`
	Stats                []byte   `protobuf:"bytes,3,opt,name=stats,proto3" json:"stats,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RespContainerStatsAll) Descriptor

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

func (*RespContainerStatsAll) GetCode

func (m *RespContainerStatsAll) GetCode() Code

func (*RespContainerStatsAll) GetErrMsg

func (m *RespContainerStatsAll) GetErrMsg() string

func (*RespContainerStatsAll) GetStats

func (m *RespContainerStatsAll) GetStats() []byte

func (*RespContainerStatsAll) ProtoMessage

func (*RespContainerStatsAll) ProtoMessage()

func (*RespContainerStatsAll) Reset

func (m *RespContainerStatsAll) Reset()

func (*RespContainerStatsAll) String

func (m *RespContainerStatsAll) String() string

func (*RespContainerStatsAll) XXX_DiscardUnknown

func (m *RespContainerStatsAll) XXX_DiscardUnknown()

func (*RespContainerStatsAll) XXX_Marshal

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

func (*RespContainerStatsAll) XXX_Merge

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

func (*RespContainerStatsAll) XXX_Size

func (m *RespContainerStatsAll) XXX_Size() int

func (*RespContainerStatsAll) XXX_Unmarshal

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

type RespImageList

type RespImageList struct {
	Code                 Code     `protobuf:"varint,1,opt,name=code,proto3,enum=proto.Code" json:"code,omitempty"`
	ErrMsg               string   `protobuf:"bytes,2,opt,name=errMsg,proto3" json:"errMsg,omitempty"`
	Images               []byte   `protobuf:"bytes,3,opt,name=images,proto3" json:"images,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RespImageList) Descriptor

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

func (*RespImageList) GetCode

func (m *RespImageList) GetCode() Code

func (*RespImageList) GetErrMsg

func (m *RespImageList) GetErrMsg() string

func (*RespImageList) GetImages

func (m *RespImageList) GetImages() []byte

func (*RespImageList) ProtoMessage

func (*RespImageList) ProtoMessage()

func (*RespImageList) Reset

func (m *RespImageList) Reset()

func (*RespImageList) String

func (m *RespImageList) String() string

func (*RespImageList) XXX_DiscardUnknown

func (m *RespImageList) XXX_DiscardUnknown()

func (*RespImageList) XXX_Marshal

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

func (*RespImageList) XXX_Merge

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

func (*RespImageList) XXX_Size

func (m *RespImageList) XXX_Size() int

func (*RespImageList) XXX_Unmarshal

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

type RespImagePull

type RespImagePull struct {
	Code                 Code     `protobuf:"varint,1,opt,name=code,proto3,enum=proto.Code" json:"code,omitempty"`
	ErrMsg               string   `protobuf:"bytes,2,opt,name=errMsg,proto3" json:"errMsg,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RespImagePull) Descriptor

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

func (*RespImagePull) GetCode

func (m *RespImagePull) GetCode() Code

func (*RespImagePull) GetErrMsg

func (m *RespImagePull) GetErrMsg() string

func (*RespImagePull) ProtoMessage

func (*RespImagePull) ProtoMessage()

func (*RespImagePull) Reset

func (m *RespImagePull) Reset()

func (*RespImagePull) String

func (m *RespImagePull) String() string

func (*RespImagePull) XXX_DiscardUnknown

func (m *RespImagePull) XXX_DiscardUnknown()

func (*RespImagePull) XXX_Marshal

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

func (*RespImagePull) XXX_Merge

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

func (*RespImagePull) XXX_Size

func (m *RespImagePull) XXX_Size() int

func (*RespImagePull) XXX_Unmarshal

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

type RespImageRemove

type RespImageRemove struct {
	Code                 Code     `protobuf:"varint,1,opt,name=code,proto3,enum=proto.Code" json:"code,omitempty"`
	ErrMsg               string   `protobuf:"bytes,2,opt,name=errMsg,proto3" json:"errMsg,omitempty"`
	ImageItems           []byte   `protobuf:"bytes,3,opt,name=imageItems,proto3" json:"imageItems,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RespImageRemove) Descriptor

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

func (*RespImageRemove) GetCode

func (m *RespImageRemove) GetCode() Code

func (*RespImageRemove) GetErrMsg

func (m *RespImageRemove) GetErrMsg() string

func (*RespImageRemove) GetImageItems

func (m *RespImageRemove) GetImageItems() []byte

func (*RespImageRemove) ProtoMessage

func (*RespImageRemove) ProtoMessage()

func (*RespImageRemove) Reset

func (m *RespImageRemove) Reset()

func (*RespImageRemove) String

func (m *RespImageRemove) String() string

func (*RespImageRemove) XXX_DiscardUnknown

func (m *RespImageRemove) XXX_DiscardUnknown()

func (*RespImageRemove) XXX_Marshal

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

func (*RespImageRemove) XXX_Merge

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

func (*RespImageRemove) XXX_Size

func (m *RespImageRemove) XXX_Size() int

func (*RespImageRemove) XXX_Unmarshal

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

type RespImageTag

type RespImageTag struct {
	Code                 Code     `protobuf:"varint,1,opt,name=code,proto3,enum=proto.Code" json:"code,omitempty"`
	ErrMsg               string   `protobuf:"bytes,2,opt,name=errMsg,proto3" json:"errMsg,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RespImageTag) Descriptor

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

func (*RespImageTag) GetCode

func (m *RespImageTag) GetCode() Code

func (*RespImageTag) GetErrMsg

func (m *RespImageTag) GetErrMsg() string

func (*RespImageTag) ProtoMessage

func (*RespImageTag) ProtoMessage()

func (*RespImageTag) Reset

func (m *RespImageTag) Reset()

func (*RespImageTag) String

func (m *RespImageTag) String() string

func (*RespImageTag) XXX_DiscardUnknown

func (m *RespImageTag) XXX_DiscardUnknown()

func (*RespImageTag) XXX_Marshal

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

func (*RespImageTag) XXX_Merge

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

func (*RespImageTag) XXX_Size

func (m *RespImageTag) XXX_Size() int

func (*RespImageTag) XXX_Unmarshal

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

type RespResources

type RespResources struct {
	Code                 Code     `protobuf:"varint,1,opt,name=code,proto3,enum=proto.Code" json:"code,omitempty"`
	ErrMsg               string   `protobuf:"bytes,2,opt,name=errMsg,proto3" json:"errMsg,omitempty"`
	Resources            []byte   `protobuf:"bytes,3,opt,name=resources,proto3" json:"resources,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RespResources) Descriptor

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

func (*RespResources) GetCode

func (m *RespResources) GetCode() Code

func (*RespResources) GetErrMsg

func (m *RespResources) GetErrMsg() string

func (*RespResources) GetResources

func (m *RespResources) GetResources() []byte

func (*RespResources) ProtoMessage

func (*RespResources) ProtoMessage()

func (*RespResources) Reset

func (m *RespResources) Reset()

func (*RespResources) String

func (m *RespResources) String() string

func (*RespResources) XXX_DiscardUnknown

func (m *RespResources) XXX_DiscardUnknown()

func (*RespResources) XXX_Marshal

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

func (*RespResources) XXX_Merge

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

func (*RespResources) XXX_Size

func (m *RespResources) XXX_Size() int

func (*RespResources) XXX_Unmarshal

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

type RespServiceInspect

type RespServiceInspect struct {
	Code                 Code     `protobuf:"varint,1,opt,name=code,proto3,enum=proto.Code" json:"code,omitempty"`
	ErrMsg               string   `protobuf:"bytes,2,opt,name=errMsg,proto3" json:"errMsg,omitempty"`
	Service              []byte   `protobuf:"bytes,3,opt,name=service,proto3" json:"service,omitempty"`
	Data                 []byte   `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RespServiceInspect) Descriptor

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

func (*RespServiceInspect) GetCode

func (m *RespServiceInspect) GetCode() Code

func (*RespServiceInspect) GetData

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

func (*RespServiceInspect) GetErrMsg

func (m *RespServiceInspect) GetErrMsg() string

func (*RespServiceInspect) GetService

func (m *RespServiceInspect) GetService() []byte

func (*RespServiceInspect) ProtoMessage

func (*RespServiceInspect) ProtoMessage()

func (*RespServiceInspect) Reset

func (m *RespServiceInspect) Reset()

func (*RespServiceInspect) String

func (m *RespServiceInspect) String() string

func (*RespServiceInspect) XXX_DiscardUnknown

func (m *RespServiceInspect) XXX_DiscardUnknown()

func (*RespServiceInspect) XXX_Marshal

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

func (*RespServiceInspect) XXX_Merge

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

func (*RespServiceInspect) XXX_Size

func (m *RespServiceInspect) XXX_Size() int

func (*RespServiceInspect) XXX_Unmarshal

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

type RespServiceList

type RespServiceList struct {
	Code                 Code     `protobuf:"varint,1,opt,name=code,proto3,enum=proto.Code" json:"code,omitempty"`
	ErrMsg               string   `protobuf:"bytes,2,opt,name=errMsg,proto3" json:"errMsg,omitempty"`
	Services             []byte   `protobuf:"bytes,3,opt,name=services,proto3" json:"services,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RespServiceList) Descriptor

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

func (*RespServiceList) GetCode

func (m *RespServiceList) GetCode() Code

func (*RespServiceList) GetErrMsg

func (m *RespServiceList) GetErrMsg() string

func (*RespServiceList) GetServices

func (m *RespServiceList) GetServices() []byte

func (*RespServiceList) ProtoMessage

func (*RespServiceList) ProtoMessage()

func (*RespServiceList) Reset

func (m *RespServiceList) Reset()

func (*RespServiceList) String

func (m *RespServiceList) String() string

func (*RespServiceList) XXX_DiscardUnknown

func (m *RespServiceList) XXX_DiscardUnknown()

func (*RespServiceList) XXX_Marshal

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

func (*RespServiceList) XXX_Merge

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

func (*RespServiceList) XXX_Size

func (m *RespServiceList) XXX_Size() int

func (*RespServiceList) XXX_Unmarshal

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

type RespServiceLogs

type RespServiceLogs struct {
	Code                 Code     `protobuf:"varint,1,opt,name=code,proto3,enum=proto.Code" json:"code,omitempty"`
	ErrMsg               string   `protobuf:"bytes,2,opt,name=errMsg,proto3" json:"errMsg,omitempty"`
	Logs                 []byte   `protobuf:"bytes,3,opt,name=logs,proto3" json:"logs,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RespServiceLogs) Descriptor

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

func (*RespServiceLogs) GetCode

func (m *RespServiceLogs) GetCode() Code

func (*RespServiceLogs) GetErrMsg

func (m *RespServiceLogs) GetErrMsg() string

func (*RespServiceLogs) GetLogs

func (m *RespServiceLogs) GetLogs() []byte

func (*RespServiceLogs) ProtoMessage

func (*RespServiceLogs) ProtoMessage()

func (*RespServiceLogs) Reset

func (m *RespServiceLogs) Reset()

func (*RespServiceLogs) String

func (m *RespServiceLogs) String() string

func (*RespServiceLogs) XXX_DiscardUnknown

func (m *RespServiceLogs) XXX_DiscardUnknown()

func (*RespServiceLogs) XXX_Marshal

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

func (*RespServiceLogs) XXX_Merge

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

func (*RespServiceLogs) XXX_Size

func (m *RespServiceLogs) XXX_Size() int

func (*RespServiceLogs) XXX_Unmarshal

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

type RespServiceResources

type RespServiceResources struct {
	Code                 Code     `protobuf:"varint,1,opt,name=code,proto3,enum=proto.Code" json:"code,omitempty"`
	ErrMsg               string   `protobuf:"bytes,2,opt,name=errMsg,proto3" json:"errMsg,omitempty"`
	Resource             []byte   `protobuf:"bytes,3,opt,name=resource,proto3" json:"resource,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RespServiceResources) Descriptor

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

func (*RespServiceResources) GetCode

func (m *RespServiceResources) GetCode() Code

func (*RespServiceResources) GetErrMsg

func (m *RespServiceResources) GetErrMsg() string

func (*RespServiceResources) GetResource

func (m *RespServiceResources) GetResource() []byte

func (*RespServiceResources) ProtoMessage

func (*RespServiceResources) ProtoMessage()

func (*RespServiceResources) Reset

func (m *RespServiceResources) Reset()

func (*RespServiceResources) String

func (m *RespServiceResources) String() string

func (*RespServiceResources) XXX_DiscardUnknown

func (m *RespServiceResources) XXX_DiscardUnknown()

func (*RespServiceResources) XXX_Marshal

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

func (*RespServiceResources) XXX_Merge

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

func (*RespServiceResources) XXX_Size

func (m *RespServiceResources) XXX_Size() int

func (*RespServiceResources) XXX_Unmarshal

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

type RespServiceResourcesAll

type RespServiceResourcesAll struct {
	Code                 Code     `protobuf:"varint,1,opt,name=code,proto3,enum=proto.Code" json:"code,omitempty"`
	ErrMsg               string   `protobuf:"bytes,2,opt,name=errMsg,proto3" json:"errMsg,omitempty"`
	Resource             []byte   `protobuf:"bytes,3,opt,name=resource,proto3" json:"resource,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RespServiceResourcesAll) Descriptor

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

func (*RespServiceResourcesAll) GetCode

func (m *RespServiceResourcesAll) GetCode() Code

func (*RespServiceResourcesAll) GetErrMsg

func (m *RespServiceResourcesAll) GetErrMsg() string

func (*RespServiceResourcesAll) GetResource

func (m *RespServiceResourcesAll) GetResource() []byte

func (*RespServiceResourcesAll) ProtoMessage

func (*RespServiceResourcesAll) ProtoMessage()

func (*RespServiceResourcesAll) Reset

func (m *RespServiceResourcesAll) Reset()

func (*RespServiceResourcesAll) String

func (m *RespServiceResourcesAll) String() string

func (*RespServiceResourcesAll) XXX_DiscardUnknown

func (m *RespServiceResourcesAll) XXX_DiscardUnknown()

func (*RespServiceResourcesAll) XXX_Marshal

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

func (*RespServiceResourcesAll) XXX_Merge

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

func (*RespServiceResourcesAll) XXX_Size

func (m *RespServiceResourcesAll) XXX_Size() int

func (*RespServiceResourcesAll) XXX_Unmarshal

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

type RespStackList

type RespStackList struct {
	Code                 Code     `protobuf:"varint,1,opt,name=code,proto3,enum=proto.Code" json:"code,omitempty"`
	ErrMsg               string   `protobuf:"bytes,2,opt,name=errMsg,proto3" json:"errMsg,omitempty"`
	Stacks               []*Stack `protobuf:"bytes,3,rep,name=stacks,proto3" json:"stacks,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RespStackList) Descriptor

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

func (*RespStackList) GetCode

func (m *RespStackList) GetCode() Code

func (*RespStackList) GetErrMsg

func (m *RespStackList) GetErrMsg() string

func (*RespStackList) GetStacks

func (m *RespStackList) GetStacks() []*Stack

func (*RespStackList) ProtoMessage

func (*RespStackList) ProtoMessage()

func (*RespStackList) Reset

func (m *RespStackList) Reset()

func (*RespStackList) String

func (m *RespStackList) String() string

func (*RespStackList) XXX_DiscardUnknown

func (m *RespStackList) XXX_DiscardUnknown()

func (*RespStackList) XXX_Marshal

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

func (*RespStackList) XXX_Merge

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

func (*RespStackList) XXX_Size

func (m *RespStackList) XXX_Size() int

func (*RespStackList) XXX_Unmarshal

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

type RespStackProcesses

type RespStackProcesses struct {
	Code                 Code            `protobuf:"varint,1,opt,name=code,proto3,enum=proto.Code" json:"code,omitempty"`
	ErrMsg               string          `protobuf:"bytes,2,opt,name=errMsg,proto3" json:"errMsg,omitempty"`
	StackProcesses       []*StackProcess `protobuf:"bytes,3,rep,name=stackProcesses,proto3" json:"stackProcesses,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*RespStackProcesses) Descriptor

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

func (*RespStackProcesses) GetCode

func (m *RespStackProcesses) GetCode() Code

func (*RespStackProcesses) GetErrMsg

func (m *RespStackProcesses) GetErrMsg() string

func (*RespStackProcesses) GetStackProcesses

func (m *RespStackProcesses) GetStackProcesses() []*StackProcess

func (*RespStackProcesses) ProtoMessage

func (*RespStackProcesses) ProtoMessage()

func (*RespStackProcesses) Reset

func (m *RespStackProcesses) Reset()

func (*RespStackProcesses) String

func (m *RespStackProcesses) String() string

func (*RespStackProcesses) XXX_DiscardUnknown

func (m *RespStackProcesses) XXX_DiscardUnknown()

func (*RespStackProcesses) XXX_Marshal

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

func (*RespStackProcesses) XXX_Merge

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

func (*RespStackProcesses) XXX_Size

func (m *RespStackProcesses) XXX_Size() int

func (*RespStackProcesses) XXX_Unmarshal

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

type RespStackServices

type RespStackServices struct {
	Code                 Code            `protobuf:"varint,1,opt,name=code,proto3,enum=proto.Code" json:"code,omitempty"`
	ErrMsg               string          `protobuf:"bytes,2,opt,name=errMsg,proto3" json:"errMsg,omitempty"`
	Services             []*StackService `protobuf:"bytes,3,rep,name=services,proto3" json:"services,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*RespStackServices) Descriptor

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

func (*RespStackServices) GetCode

func (m *RespStackServices) GetCode() Code

func (*RespStackServices) GetErrMsg

func (m *RespStackServices) GetErrMsg() string

func (*RespStackServices) GetServices

func (m *RespStackServices) GetServices() []*StackService

func (*RespStackServices) ProtoMessage

func (*RespStackServices) ProtoMessage()

func (*RespStackServices) Reset

func (m *RespStackServices) Reset()

func (*RespStackServices) String

func (m *RespStackServices) String() string

func (*RespStackServices) XXX_DiscardUnknown

func (m *RespStackServices) XXX_DiscardUnknown()

func (*RespStackServices) XXX_Marshal

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

func (*RespStackServices) XXX_Merge

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

func (*RespStackServices) XXX_Size

func (m *RespStackServices) XXX_Size() int

func (*RespStackServices) XXX_Unmarshal

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

type Response

type Response struct {
	Code                 Code     `protobuf:"varint,1,opt,name=code,proto3,enum=proto.Code" json:"code,omitempty"`
	ErrMsg               string   `protobuf:"bytes,2,opt,name=errMsg,proto3" json:"errMsg,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Response) Descriptor

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

func (*Response) GetCode

func (m *Response) GetCode() Code

func (*Response) GetErrMsg

func (m *Response) GetErrMsg() string

func (*Response) ProtoMessage

func (*Response) ProtoMessage()

func (*Response) Reset

func (m *Response) Reset()

func (*Response) String

func (m *Response) String() string

func (*Response) XXX_DiscardUnknown

func (m *Response) XXX_DiscardUnknown()

func (*Response) XXX_Marshal

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

func (*Response) XXX_Merge

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

func (*Response) XXX_Size

func (m *Response) XXX_Size() int

func (*Response) XXX_Unmarshal

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

type RestartPolicy

type RestartPolicy struct {
	// 重启判定条件,none、on-failure和any(默认any)
	Condition Condition `protobuf:"varint,1,opt,name=condition,proto3,enum=proto.Condition" json:"condition,omitempty"`
	// 在重启尝试之间等待多久(默认0)
	Delay string `protobuf:"bytes,2,opt,name=delay,proto3" json:"delay,omitempty"`
	// 尝试重启的次数(默认一直重启,直到成功)
	MaxAttempts uint64 `protobuf:"varint,3,opt,name=maxAttempts,proto3" json:"maxAttempts,omitempty"`
	// 在确实一个重启是否成功前需要等待的窗口时间
	Window               string   `protobuf:"bytes,4,opt,name=window,proto3" json:"window,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

配置在容器退出时是否并如何重启容器。取代restart指令

func (*RestartPolicy) Descriptor

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

func (*RestartPolicy) GetCondition

func (m *RestartPolicy) GetCondition() Condition

func (*RestartPolicy) GetDelay

func (m *RestartPolicy) GetDelay() string

func (*RestartPolicy) GetMaxAttempts

func (m *RestartPolicy) GetMaxAttempts() uint64

func (*RestartPolicy) GetWindow

func (m *RestartPolicy) GetWindow() string

func (*RestartPolicy) ProtoMessage

func (*RestartPolicy) ProtoMessage()

func (*RestartPolicy) Reset

func (m *RestartPolicy) Reset()

func (*RestartPolicy) String

func (m *RestartPolicy) String() string

func (*RestartPolicy) XXX_DiscardUnknown

func (m *RestartPolicy) XXX_DiscardUnknown()

func (*RestartPolicy) XXX_Marshal

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

func (*RestartPolicy) XXX_Merge

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

func (*RestartPolicy) XXX_Size

func (m *RestartPolicy) XXX_Size() int

func (*RestartPolicy) XXX_Unmarshal

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

type Service

type Service struct {
	// p5cxcpr7yu3zhymm0hfig4owt
	ID string `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	// "2020-05-18T02:25:51.0499467Z"
	CreateAt string `protobuf:"bytes,2,opt,name=createAt,proto3" json:"createAt,omitempty"`
	// "2020-05-18T02:25:51.0499467Z"
	UpdateAt             string   `protobuf:"bytes,3,opt,name=updateAt,proto3" json:"updateAt,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Service) Descriptor

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

func (*Service) GetCreateAt

func (m *Service) GetCreateAt() string

func (*Service) GetID

func (m *Service) GetID() string

func (*Service) GetUpdateAt

func (m *Service) GetUpdateAt() string

func (*Service) ProtoMessage

func (*Service) ProtoMessage()

func (*Service) Reset

func (m *Service) Reset()

func (*Service) String

func (m *Service) String() string

func (*Service) XXX_DiscardUnknown

func (m *Service) XXX_DiscardUnknown()

func (*Service) XXX_Marshal

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

func (*Service) XXX_Merge

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

func (*Service) XXX_Size

func (m *Service) XXX_Size() int

func (*Service) XXX_Unmarshal

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

type ServiceCompare

type ServiceCompare struct {
	Infos                []*ServiceCompareInfo `protobuf:"bytes,1,rep,name=infos,proto3" json:"infos,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*ServiceCompare) Descriptor

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

func (*ServiceCompare) GetInfos

func (m *ServiceCompare) GetInfos() []*ServiceCompareInfo

func (*ServiceCompare) ProtoMessage

func (*ServiceCompare) ProtoMessage()

func (*ServiceCompare) Reset

func (m *ServiceCompare) Reset()

func (*ServiceCompare) String

func (m *ServiceCompare) String() string

func (*ServiceCompare) XXX_DiscardUnknown

func (m *ServiceCompare) XXX_DiscardUnknown()

func (*ServiceCompare) XXX_Marshal

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

func (*ServiceCompare) XXX_Merge

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

func (*ServiceCompare) XXX_Size

func (m *ServiceCompare) XXX_Size() int

func (*ServiceCompare) XXX_Unmarshal

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

type ServiceCompareInfo

type ServiceCompareInfo struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	State                string   `protobuf:"bytes,2,opt,name=state,proto3" json:"state,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ServiceCompareInfo) Descriptor

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

func (*ServiceCompareInfo) GetName

func (m *ServiceCompareInfo) GetName() string

func (*ServiceCompareInfo) GetState

func (m *ServiceCompareInfo) GetState() string

func (*ServiceCompareInfo) ProtoMessage

func (*ServiceCompareInfo) ProtoMessage()

func (*ServiceCompareInfo) Reset

func (m *ServiceCompareInfo) Reset()

func (*ServiceCompareInfo) String

func (m *ServiceCompareInfo) String() string

func (*ServiceCompareInfo) XXX_DiscardUnknown

func (m *ServiceCompareInfo) XXX_DiscardUnknown()

func (*ServiceCompareInfo) XXX_Marshal

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

func (*ServiceCompareInfo) XXX_Merge

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

func (*ServiceCompareInfo) XXX_Size

func (m *ServiceCompareInfo) XXX_Size() int

func (*ServiceCompareInfo) XXX_Unmarshal

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

type ServiceServerClient

type ServiceServerClient interface {
	Logs(ctx context.Context, in *ReqServiceLogs, opts ...grpc.CallOption) (*RespServiceLogs, error)
	List(ctx context.Context, in *ReqServiceList, opts ...grpc.CallOption) (*RespServiceList, error)
	Inspect(ctx context.Context, in *ReqServiceInspect, opts ...grpc.CallOption) (*RespServiceInspect, error)
	Resource(ctx context.Context, in *ReqServiceResources, opts ...grpc.CallOption) (*RespServiceResources, error)
	ResourceAll(ctx context.Context, in *ReqServiceResourcesAll, opts ...grpc.CallOption) (*RespServiceResourcesAll, error)
}

ServiceServerClient is the client API for ServiceServer service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

type ServiceServerServer

ServiceServerServer is the server API for ServiceServer service.

type ServiceStats

type ServiceStats struct {
	CpuUsageRage         float32  `protobuf:"fixed32,1,opt,name=cpuUsageRage,proto3" json:"cpuUsageRage,omitempty"`
	CpuCoreNum           uint32   `protobuf:"varint,2,opt,name=cpuCoreNum,proto3" json:"cpuCoreNum,omitempty"`
	MemUsageRate         float32  `protobuf:"fixed32,3,opt,name=memUsageRate,proto3" json:"memUsageRate,omitempty"`
	MemUsage             string   `protobuf:"bytes,4,opt,name=memUsage,proto3" json:"memUsage,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ServiceStats) Descriptor

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

func (*ServiceStats) GetCpuCoreNum

func (m *ServiceStats) GetCpuCoreNum() uint32

func (*ServiceStats) GetCpuUsageRage

func (m *ServiceStats) GetCpuUsageRage() float32

func (*ServiceStats) GetMemUsage

func (m *ServiceStats) GetMemUsage() string

func (*ServiceStats) GetMemUsageRate

func (m *ServiceStats) GetMemUsageRate() float32

func (*ServiceStats) ProtoMessage

func (*ServiceStats) ProtoMessage()

func (*ServiceStats) Reset

func (m *ServiceStats) Reset()

func (*ServiceStats) String

func (m *ServiceStats) String() string

func (*ServiceStats) XXX_DiscardUnknown

func (m *ServiceStats) XXX_DiscardUnknown()

func (*ServiceStats) XXX_Marshal

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

func (*ServiceStats) XXX_Merge

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

func (*ServiceStats) XXX_Size

func (m *ServiceStats) XXX_Size() int

func (*ServiceStats) XXX_Unmarshal

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

type Stack

type Stack struct {
	// 创建时指定唯一名称
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Stack包含服务类型数量,每一个服务类型中可能包含一个或多个容器服务
	ServiceCount uint32 `protobuf:"varint,2,opt,name=serviceCount,proto3" json:"serviceCount,omitempty"`
	// 所属编排服务集群类型,swarm/kubernetes/all
	Orchestrator         string   `protobuf:"bytes,3,opt,name=orchestrator,proto3" json:"orchestrator,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Stack 堆栈服务

func (*Stack) Descriptor

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

func (*Stack) GetId

func (m *Stack) GetId() string

func (*Stack) GetOrchestrator

func (m *Stack) GetOrchestrator() string

func (*Stack) GetServiceCount

func (m *Stack) GetServiceCount() uint32

func (*Stack) ProtoMessage

func (*Stack) ProtoMessage()

func (*Stack) Reset

func (m *Stack) Reset()

func (*Stack) String

func (m *Stack) String() string

func (*Stack) XXX_DiscardUnknown

func (m *Stack) XXX_DiscardUnknown()

func (*Stack) XXX_Marshal

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

func (*Stack) XXX_Merge

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

func (*Stack) XXX_Size

func (m *Stack) XXX_Size() int

func (*Stack) XXX_Unmarshal

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

type StackProcess

type StackProcess struct {
	// 创建时指定唯一名称
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// 容器名称
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// 镜像名称
	Image string `protobuf:"bytes,3,opt,name=image,proto3" json:"image,omitempty"`
	// 镜像版本号
	ImageVersion string `protobuf:"bytes,4,opt,name=imageVersion,proto3" json:"imageVersion,omitempty"`
	// 部署所在节点名称
	Node string `protobuf:"bytes,5,opt,name=node,proto3" json:"node,omitempty"`
	// 容器运行状态
	DesiredState ContainerState `protobuf:"varint,6,opt,name=desiredState,proto3,enum=proto.ContainerState" json:"desiredState,omitempty"`
	// 容器维持当前运行状态持续时间
	CurrentState *Time `protobuf:"bytes,7,opt,name=currentState,proto3" json:"currentState,omitempty"`
	// 容器非运行状态错误内容
	ErrMsg string `protobuf:"bytes,8,opt,name=errMsg,proto3" json:"errMsg,omitempty"`
	// 容器端口服务
	Ports                []*PortMapping `protobuf:"bytes,9,rep,name=ports,proto3" json:"ports,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*StackProcess) Descriptor

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

func (*StackProcess) GetCurrentState

func (m *StackProcess) GetCurrentState() *Time

func (*StackProcess) GetDesiredState

func (m *StackProcess) GetDesiredState() ContainerState

func (*StackProcess) GetErrMsg

func (m *StackProcess) GetErrMsg() string

func (*StackProcess) GetId

func (m *StackProcess) GetId() string

func (*StackProcess) GetImage

func (m *StackProcess) GetImage() string

func (*StackProcess) GetImageVersion

func (m *StackProcess) GetImageVersion() string

func (*StackProcess) GetName

func (m *StackProcess) GetName() string

func (*StackProcess) GetNode

func (m *StackProcess) GetNode() string

func (*StackProcess) GetPorts

func (m *StackProcess) GetPorts() []*PortMapping

func (*StackProcess) ProtoMessage

func (*StackProcess) ProtoMessage()

func (*StackProcess) Reset

func (m *StackProcess) Reset()

func (*StackProcess) String

func (m *StackProcess) String() string

func (*StackProcess) XXX_DiscardUnknown

func (m *StackProcess) XXX_DiscardUnknown()

func (*StackProcess) XXX_Marshal

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

func (*StackProcess) XXX_Merge

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

func (*StackProcess) XXX_Size

func (m *StackProcess) XXX_Size() int

func (*StackProcess) XXX_Unmarshal

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

type StackServerClient

type StackServerClient interface {
	// Deploy 部署新的堆栈或更新现有堆栈
	//
	// tail 代表是否实时输出命令执行的日志信息
	Deploy(ctx context.Context, in *ReqCompose, opts ...grpc.CallOption) (*Response, error)
	// List 列出现有堆栈
	List(ctx context.Context, in *Request, opts ...grpc.CallOption) (*RespStackList, error)
	// Process 列出堆栈中的任务
	Process(ctx context.Context, in *ReqStack, opts ...grpc.CallOption) (*RespStackProcesses, error)
	// Services 列出堆栈中的服务
	Services(ctx context.Context, in *ReqStack, opts ...grpc.CallOption) (*RespStackServices, error)
	// Remove 删除一个或多个堆栈
	Remove(ctx context.Context, in *ReqStack, opts ...grpc.CallOption) (*Response, error)
}

StackServerClient is the client API for StackServer service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

type StackServerServer

type StackServerServer interface {
	// Deploy 部署新的堆栈或更新现有堆栈
	//
	// tail 代表是否实时输出命令执行的日志信息
	Deploy(context.Context, *ReqCompose) (*Response, error)
	// List 列出现有堆栈
	List(context.Context, *Request) (*RespStackList, error)
	// Process 列出堆栈中的任务
	Process(context.Context, *ReqStack) (*RespStackProcesses, error)
	// Services 列出堆栈中的服务
	Services(context.Context, *ReqStack) (*RespStackServices, error)
	// Remove 删除一个或多个堆栈
	Remove(context.Context, *ReqStack) (*Response, error)
}

StackServerServer is the server API for StackServer service.

type StackService

type StackService struct {
	// 服务唯一ID
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// 服务名称
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// 服务运行模式
	Mode Mode `protobuf:"varint,3,opt,name=mode,proto3,enum=proto.Mode" json:"mode,omitempty"`
	// 副本数量
	Replicas uint32 `protobuf:"varint,4,opt,name=replicas,proto3" json:"replicas,omitempty"`
	// 活跃数量,小于等于预期的副本数量,期望值是等于副本数量
	Active uint32 `protobuf:"varint,5,opt,name=active,proto3" json:"active,omitempty"`
	// 镜像名称
	Image string `protobuf:"bytes,6,opt,name=image,proto3" json:"image,omitempty"`
	// 镜像版本号
	ImageVersion string `protobuf:"bytes,7,opt,name=imageVersion,proto3" json:"imageVersion,omitempty"`
	// 容器端口服务
	Ports                []*PortMapping `protobuf:"bytes,8,rep,name=ports,proto3" json:"ports,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

stackService 管理容器的服务主体

func (*StackService) Descriptor

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

func (*StackService) GetActive

func (m *StackService) GetActive() uint32

func (*StackService) GetId

func (m *StackService) GetId() string

func (*StackService) GetImage

func (m *StackService) GetImage() string

func (*StackService) GetImageVersion

func (m *StackService) GetImageVersion() string

func (*StackService) GetMode

func (m *StackService) GetMode() Mode

func (*StackService) GetName

func (m *StackService) GetName() string

func (*StackService) GetPorts

func (m *StackService) GetPorts() []*PortMapping

func (*StackService) GetReplicas

func (m *StackService) GetReplicas() uint32

func (*StackService) ProtoMessage

func (*StackService) ProtoMessage()

func (*StackService) Reset

func (m *StackService) Reset()

func (*StackService) String

func (m *StackService) String() string

func (*StackService) XXX_DiscardUnknown

func (m *StackService) XXX_DiscardUnknown()

func (*StackService) XXX_Marshal

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

func (*StackService) XXX_Merge

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

func (*StackService) XXX_Size

func (m *StackService) XXX_Size() int

func (*StackService) XXX_Unmarshal

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

type Task

type Task struct {
	// 镜像服务
	Image *Image `protobuf:"bytes,1,opt,name=image,proto3" json:"image,omitempty"`
	// 端口映射策略集合
	Ports []*Port `protobuf:"bytes,2,rep,name=ports,proto3" json:"ports,omitempty"`
	// 环境变量
	Environments []*Environment `protobuf:"bytes,3,rep,name=environments,proto3" json:"environments,omitempty"`
	// 启动容器后执行的默认命令
	Command []string `protobuf:"bytes,4,rep,name=command,proto3" json:"command,omitempty"`
	// 启动容器后执行的默认命令参数
	Args []string `protobuf:"bytes,5,rep,name=args,proto3" json:"args,omitempty"`
	// 容器内部服务工作目录
	WorkingDir string `protobuf:"bytes,6,opt,name=workingDir,proto3" json:"workingDir,omitempty"`
	// 挂载服务集合
	Volumes []*ComposeVolume `protobuf:"bytes,7,rep,name=volumes,proto3" json:"volumes,omitempty"`
	// 工作网络集合
	Networks []string `protobuf:"bytes,8,rep,name=networks,proto3" json:"networks,omitempty"`
	// 通常,当前台进程在docker容器内完成时,它会假设作业已经完成并清理容器实例。
	// 但是数据库引擎和web服务器等需要继续运行。
	// 通过创建一个伪终端,容器保持活动状态。
	// 可以通过运行docker logs <<container name>>命令(带tty和不带tty)来查看这个工作流
	TTY bool `protobuf:"varint,9,opt,name=TTY,proto3" json:"TTY,omitempty"`
	// dns服务集合
	ExtraHosts []*ExtraHost `protobuf:"bytes,10,rep,name=extraHosts,proto3" json:"extraHosts,omitempty"`
	// 依赖关系服务
	DependsOn []string `protobuf:"bytes,11,rep,name=dependsOn,proto3" json:"dependsOn,omitempty"`
	// 指定swarm服务部署和运行时的相关配置
	Deploy               *Deploy  `protobuf:"bytes,12,opt,name=deploy,proto3" json:"deploy,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

容器服务

func (*Task) Descriptor

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

func (*Task) GetArgs

func (m *Task) GetArgs() []string

func (*Task) GetCommand

func (m *Task) GetCommand() []string

func (*Task) GetDependsOn

func (m *Task) GetDependsOn() []string

func (*Task) GetDeploy

func (m *Task) GetDeploy() *Deploy

func (*Task) GetEnvironments

func (m *Task) GetEnvironments() []*Environment

func (*Task) GetExtraHosts

func (m *Task) GetExtraHosts() []*ExtraHost

func (*Task) GetImage

func (m *Task) GetImage() *Image

func (*Task) GetNetworks

func (m *Task) GetNetworks() []string

func (*Task) GetPorts

func (m *Task) GetPorts() []*Port

func (*Task) GetTTY

func (m *Task) GetTTY() bool

func (*Task) GetVolumes

func (m *Task) GetVolumes() []*ComposeVolume

func (*Task) GetWorkingDir

func (m *Task) GetWorkingDir() string

func (*Task) ProtoMessage

func (*Task) ProtoMessage()

func (*Task) Reset

func (m *Task) Reset()

func (*Task) String

func (m *Task) String() string

func (*Task) XXX_DiscardUnknown

func (m *Task) XXX_DiscardUnknown()

func (*Task) XXX_Marshal

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

func (*Task) XXX_Merge

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

func (*Task) XXX_Size

func (m *Task) XXX_Size() int

func (*Task) XXX_Unmarshal

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

type Time

type Time struct {
	Sec                  int64    `protobuf:"varint,1,opt,name=sec,proto3" json:"sec,omitempty"`
	Nsec                 int64    `protobuf:"varint,2,opt,name=nsec,proto3" json:"nsec,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

容器维持当前运行状态持续时间

func (*Time) Descriptor

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

func (*Time) GetNsec

func (m *Time) GetNsec() int64

func (*Time) GetSec

func (m *Time) GetSec() int64

func (*Time) ProtoMessage

func (*Time) ProtoMessage()

func (*Time) Reset

func (m *Time) Reset()

func (*Time) String

func (m *Time) String() string

func (*Time) XXX_DiscardUnknown

func (m *Time) XXX_DiscardUnknown()

func (*Time) XXX_Marshal

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

func (*Time) XXX_Merge

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

func (*Time) XXX_Size

func (m *Time) XXX_Size() int

func (*Time) XXX_Unmarshal

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

type UnimplementedContainerServerServer

type UnimplementedContainerServerServer struct {
}

UnimplementedContainerServerServer can be embedded to have forward compatible implementations.

func (*UnimplementedContainerServerServer) Inspect

func (*UnimplementedContainerServerServer) List

func (*UnimplementedContainerServerServer) Logs

func (*UnimplementedContainerServerServer) Stats

func (*UnimplementedContainerServerServer) StatsAll

type UnimplementedImageServerServer

type UnimplementedImageServerServer struct {
}

UnimplementedImageServerServer can be embedded to have forward compatible implementations.

func (*UnimplementedImageServerServer) List

func (*UnimplementedImageServerServer) Pull

func (*UnimplementedImageServerServer) Remove

func (*UnimplementedImageServerServer) Tag

type UnimplementedProcServerServer

type UnimplementedProcServerServer struct {
}

UnimplementedProcServerServer can be embedded to have forward compatible implementations.

func (*UnimplementedProcServerServer) Resources

type UnimplementedProjectServerServer

type UnimplementedProjectServerServer struct {
}

UnimplementedProjectServerServer can be embedded to have forward compatible implementations.

func (*UnimplementedProjectServerServer) Deploy

func (*UnimplementedProjectServerServer) Remove

func (*UnimplementedProjectServerServer) ServiceState

func (*UnimplementedProjectServerServer) Update

type UnimplementedResourceServerServer

type UnimplementedResourceServerServer struct {
}

UnimplementedResourceServerServer can be embedded to have forward compatible implementations.

func (*UnimplementedResourceServerServer) ContainersSync

func (*UnimplementedResourceServerServer) Info

type UnimplementedServiceServerServer

type UnimplementedServiceServerServer struct {
}

UnimplementedServiceServerServer can be embedded to have forward compatible implementations.

func (*UnimplementedServiceServerServer) Inspect

func (*UnimplementedServiceServerServer) List

func (*UnimplementedServiceServerServer) Logs

func (*UnimplementedServiceServerServer) Resource

func (*UnimplementedServiceServerServer) ResourceAll

type UnimplementedStackServerServer

type UnimplementedStackServerServer struct {
}

UnimplementedStackServerServer can be embedded to have forward compatible implementations.

func (*UnimplementedStackServerServer) Deploy

func (*UnimplementedStackServerServer) List

func (*UnimplementedStackServerServer) Process

func (*UnimplementedStackServerServer) Remove

func (*UnimplementedStackServerServer) Services

type UpdateConfig

type UpdateConfig struct {
	// 同一时间升级的容器数量
	Parallelism uint64 `protobuf:"varint,1,opt,name=parallelism,proto3" json:"parallelism,omitempty"`
	// 容器升级间隔时间
	Delay string `protobuf:"bytes,2,opt,name=delay,proto3" json:"delay,omitempty"`
	// 升级失败后的动作(continue、rollback和pause。默认pause)
	FailureAction Action `protobuf:"varint,3,opt,name=failureAction,proto3,enum=proto.Action" json:"failureAction,omitempty"`
	// 更新完成后确实成功的时间(ns|us|ms|s|m|h)。(默认0s)
	Monitor string `protobuf:"bytes,4,opt,name=monitor,proto3" json:"monitor,omitempty"`
	// 更新期间允许的失败率
	MaxFailureRatio float32 `protobuf:"fixed32,5,opt,name=maxFailureRatio,proto3" json:"maxFailureRatio,omitempty"`
	// 更新期间的操作顺序。停止优先(旧任务在开始新任务之前停止)或者先启动(首先启动新任务,并且正在运行的任务短暂重叠)
	//
	// stop-first/start-first
	//
	//(默认停止优先)注意:只支持v3.4及更高版本
	Order                Order    `protobuf:"varint,6,opt,name=order,proto3,enum=proto.Order" json:"order,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

配置服务如何升级

func (*UpdateConfig) Descriptor

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

func (*UpdateConfig) GetDelay

func (m *UpdateConfig) GetDelay() string

func (*UpdateConfig) GetFailureAction

func (m *UpdateConfig) GetFailureAction() Action

func (*UpdateConfig) GetMaxFailureRatio

func (m *UpdateConfig) GetMaxFailureRatio() float32

func (*UpdateConfig) GetMonitor

func (m *UpdateConfig) GetMonitor() string

func (*UpdateConfig) GetOrder

func (m *UpdateConfig) GetOrder() Order

func (*UpdateConfig) GetParallelism

func (m *UpdateConfig) GetParallelism() uint64

func (*UpdateConfig) ProtoMessage

func (*UpdateConfig) ProtoMessage()

func (*UpdateConfig) Reset

func (m *UpdateConfig) Reset()

func (*UpdateConfig) String

func (m *UpdateConfig) String() string

func (*UpdateConfig) XXX_DiscardUnknown

func (m *UpdateConfig) XXX_DiscardUnknown()

func (*UpdateConfig) XXX_Marshal

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

func (*UpdateConfig) XXX_Merge

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

func (*UpdateConfig) XXX_Size

func (m *UpdateConfig) XXX_Size() int

func (*UpdateConfig) XXX_Unmarshal

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

type Version

type Version struct {
	Index                uint64   `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Version represents the internal object version.

func (*Version) Descriptor

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

func (*Version) GetIndex

func (m *Version) GetIndex() uint64

func (*Version) ProtoMessage

func (*Version) ProtoMessage()

func (*Version) Reset

func (m *Version) Reset()

func (*Version) String

func (m *Version) String() string

func (*Version) XXX_DiscardUnknown

func (m *Version) XXX_DiscardUnknown()

func (*Version) XXX_Marshal

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

func (*Version) XXX_Merge

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

func (*Version) XXX_Size

func (m *Version) XXX_Size() int

func (*Version) XXX_Unmarshal

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

type Volume

type Volume struct {
	Name                 string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Driver               string            `protobuf:"bytes,2,opt,name=driver,proto3" json:"driver,omitempty"`
	DriverOpts           map[string]string `` /* 161-byte string literal not displayed */
	Labels               map[string]string `` /* 153-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*Volume) Descriptor

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

func (*Volume) GetDriver

func (m *Volume) GetDriver() string

func (*Volume) GetDriverOpts

func (m *Volume) GetDriverOpts() map[string]string

func (*Volume) GetLabels

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

func (*Volume) GetName

func (m *Volume) GetName() string

func (*Volume) ProtoMessage

func (*Volume) ProtoMessage()

func (*Volume) Reset

func (m *Volume) Reset()

func (*Volume) String

func (m *Volume) String() string

func (*Volume) XXX_DiscardUnknown

func (m *Volume) XXX_DiscardUnknown()

func (*Volume) XXX_Marshal

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

func (*Volume) XXX_Merge

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

func (*Volume) XXX_Size

func (m *Volume) XXX_Size() int

func (*Volume) XXX_Unmarshal

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL