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 

type ContainerServerClient interface {
	Logs(ctx context.Context, in *ReqContainerLogs, opts ...grpc.CallOption) (*RespContainerLogs, error)
	List(ctx context.Context, in *ReqContainerList, opts ...grpc.CallOption) (*RespContainerList, error)
	Inspect(ctx context.Context, in *ReqContainerInspect, opts ...grpc.CallOption) (*RespContainerInspect, error)
	Stats(ctx context.Context, in *ReqContainerStats, opts ...grpc.CallOption) (*RespContainerStats, error)
	StatsAll(ctx context.Context, in *ReqContainerStatsAll, opts ...grpc.CallOption) (*RespContainerStatsAll, error)
}

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.

func NewContainerServerClient 

func NewContainerServerClient(cc grpc.ClientConnInterface) ContainerServerClient

type ContainerServerServer 

type ContainerServerServer interface {
	Logs(context.Context, *ReqContainerLogs) (*RespContainerLogs, error)
	List(context.Context, *ReqContainerList) (*RespContainerList, error)
	Inspect(context.Context, *ReqContainerInspect) (*RespContainerInspect, error)
	Stats(context.Context, *ReqContainerStats) (*RespContainerStats, error)
	StatsAll(context.Context, *ReqContainerStatsAll) (*RespContainerStatsAll, error)
}

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.

func NewImageServerClient 

func NewImageServerClient(cc grpc.ClientConnInterface) ImageServerClient

type ImageServerServer 

type ImageServerServer interface {
	List(context.Context, *ReqImageList) (*RespImageList, error)
	Pull(context.Context, *ReqImagePull) (*RespImagePull, error)
	Remove(context.Context, *ReqImageRemove) (*RespImageRemove, error)
	Tag(context.Context, *ReqImageTag) (*RespImageTag, error)
}

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.

func NewProjectServerClient 

func NewProjectServerClient(cc grpc.ClientConnInterface) ProjectServerClient

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.

func NewResourceServerClient 

func NewResourceServerClient(cc grpc.ClientConnInterface) ResourceServerClient

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.

func NewServiceServerClient 

func NewServiceServerClient(cc grpc.ClientConnInterface) ServiceServerClient

type ServiceServerServer 

type ServiceServerServer interface {
	Logs(context.Context, *ReqServiceLogs) (*RespServiceLogs, error)
	List(context.Context, *ReqServiceList) (*RespServiceList, error)
	Inspect(context.Context, *ReqServiceInspect) (*RespServiceInspect, error)
	Resource(context.Context, *ReqServiceResources) (*RespServiceResources, error)
	ResourceAll(context.Context, *ReqServiceResourcesAll) (*RespServiceResourcesAll, error)
}

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.

func NewStackServerClient 

func NewStackServerClient(cc grpc.ClientConnInterface) StackServerClient

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) Inspect(ctx context.Context, req *ReqContainerInspect) (*RespContainerInspect, error)

func (*UnimplementedContainerServerServer) List 

func (*UnimplementedContainerServerServer) List(ctx context.Context, req *ReqContainerList) (*RespContainerList, error)

func (*UnimplementedContainerServerServer) Logs 

func (*UnimplementedContainerServerServer) Logs(ctx context.Context, req *ReqContainerLogs) (*RespContainerLogs, error)

func (*UnimplementedContainerServerServer) Stats 

func (*UnimplementedContainerServerServer) Stats(ctx context.Context, req *ReqContainerStats) (*RespContainerStats, error)

func (*UnimplementedContainerServerServer) StatsAll 

func (*UnimplementedContainerServerServer) StatsAll(ctx context.Context, req *ReqContainerStatsAll) (*RespContainerStatsAll, error)

type UnimplementedImageServerServer 

type UnimplementedImageServerServer struct {
}

UnimplementedImageServerServer can be embedded to have forward compatible implementations.

func (*UnimplementedImageServerServer) List 

func (*UnimplementedImageServerServer) List(ctx context.Context, req *ReqImageList) (*RespImageList, error)

func (*UnimplementedImageServerServer) Pull 

func (*UnimplementedImageServerServer) Pull(ctx context.Context, req *ReqImagePull) (*RespImagePull, error)

func (*UnimplementedImageServerServer) Remove 

func (*UnimplementedImageServerServer) Remove(ctx context.Context, req *ReqImageRemove) (*RespImageRemove, error)

func (*UnimplementedImageServerServer) Tag 

func (*UnimplementedImageServerServer) Tag(ctx context.Context, req *ReqImageTag) (*RespImageTag, error)

type UnimplementedProcServerServer 

type UnimplementedProcServerServer struct {
}

UnimplementedProcServerServer can be embedded to have forward compatible implementations.

func (*UnimplementedProcServerServer) Resources 

func (*UnimplementedProcServerServer) Resources(ctx context.Context, req *ReqResources) (*RespResources, error)

type UnimplementedProjectServerServer 

type UnimplementedProjectServerServer struct {
}

UnimplementedProjectServerServer can be embedded to have forward compatible implementations.

func (*UnimplementedProjectServerServer) Deploy 

func (*UnimplementedProjectServerServer) Deploy(ctx context.Context, req *ReqProject) (*Response, error)

func (*UnimplementedProjectServerServer) Remove 

func (*UnimplementedProjectServerServer) Remove(ctx context.Context, req *ReqProjectRemove) (*Response, error)

func (*UnimplementedProjectServerServer) ServiceState 

func (*UnimplementedProjectServerServer) ServiceState(ctx context.Context, req *ServiceCompare) (*ServiceCompare, error)

func (*UnimplementedProjectServerServer) Update 

func (*UnimplementedProjectServerServer) Update(ctx context.Context, req *ReqProjectUpdate) (*Response, error)

type UnimplementedResourceServerServer 

type UnimplementedResourceServerServer struct {
}

UnimplementedResourceServerServer can be embedded to have forward compatible implementations.

func (*UnimplementedResourceServerServer) ContainersSync 

func (*UnimplementedResourceServerServer) ContainersSync(ctx context.Context, req *ReqContainerSync) (*Response, error)

func (*UnimplementedResourceServerServer) Info 

func (*UnimplementedResourceServerServer) Info(ctx context.Context, req *Request) (*ResourceInfo, error)

type UnimplementedServiceServerServer 

type UnimplementedServiceServerServer struct {
}

UnimplementedServiceServerServer can be embedded to have forward compatible implementations.

func (*UnimplementedServiceServerServer) Inspect 

func (*UnimplementedServiceServerServer) Inspect(ctx context.Context, req *ReqServiceInspect) (*RespServiceInspect, error)

func (*UnimplementedServiceServerServer) List 

func (*UnimplementedServiceServerServer) List(ctx context.Context, req *ReqServiceList) (*RespServiceList, error)

func (*UnimplementedServiceServerServer) Logs 

func (*UnimplementedServiceServerServer) Logs(ctx context.Context, req *ReqServiceLogs) (*RespServiceLogs, error)

func (*UnimplementedServiceServerServer) Resource 

func (*UnimplementedServiceServerServer) Resource(ctx context.Context, req *ReqServiceResources) (*RespServiceResources, error)

func (*UnimplementedServiceServerServer) ResourceAll 

func (*UnimplementedServiceServerServer) ResourceAll(ctx context.Context, req *ReqServiceResourcesAll) (*RespServiceResourcesAll, error)

type UnimplementedStackServerServer 

type UnimplementedStackServerServer struct {
}

UnimplementedStackServerServer can be embedded to have forward compatible implementations.

func (*UnimplementedStackServerServer) Deploy 

func (*UnimplementedStackServerServer) Deploy(ctx context.Context, req *ReqCompose) (*Response, error)

func (*UnimplementedStackServerServer) List 

func (*UnimplementedStackServerServer) List(ctx context.Context, req *Request) (*RespStackList, error)

func (*UnimplementedStackServerServer) Process 

func (*UnimplementedStackServerServer) Process(ctx context.Context, req *ReqStack) (*RespStackProcesses, error)

func (*UnimplementedStackServerServer) Remove 

func (*UnimplementedStackServerServer) Remove(ctx context.Context, req *ReqStack) (*Response, error)

func (*UnimplementedStackServerServer) Services 

func (*UnimplementedStackServerServer) Services(ctx context.Context, req *ReqStack) (*RespStackServices, error)

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

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