cloud

package
v0.10.10-alpha.4 Latest Latest
Warning

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

 Go to latest Published: Jun 7, 2021 License: Apache-2.0 Imports: 9 Imported by: 10

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var ControlPlaneState_name = map[int32]string{
	0: "NotLeader",
	1: "Leader",
}
View Source 
var ControlPlaneState_value = map[string]int32{
	"NotLeader": 0,
	"Leader":    1,
}
View Source 
var ManagementStrategyType_name = map[int32]string{
	0: "Pivoted",
	1: "Distinct",
}
View Source 
var ManagementStrategyType_value = map[string]int32{
	"Pivoted":  0,
	"Distinct": 1,
}
View Source 
var NodeState_name = map[int32]string{
	0: "Unknown",
	1: "Active",
	2: "Inactive",
}
View Source 
var NodeState_value = map[string]int32{
	"Unknown":  0,
	"Active":   1,
	"Inactive": 2,
}
View Source 
var NodeType_name = map[int32]string{
	0: "ControlPlane",
	1: "LinuxWorker",
	2: "WindowsWorker",
	3: "LoadBalancer",
}
View Source 
var NodeType_value = map[string]int32{
	"ControlPlane":  0,
	"LinuxWorker":   1,
	"WindowsWorker": 2,
	"LoadBalancer":  3,
}
View Source 
var SubPostOperation_name = map[int32]string{
	0: "CREATE",
	1: "UPDATE",
	2: "LOCK",
}
View Source 
var SubPostOperation_value = map[string]int32{
	"CREATE": 0,
	"UPDATE": 1,
	"LOCK":   2,
}

Functions

func RegisterClusterAgentServer 

func RegisterClusterAgentServer(s *grpc.Server, srv ClusterAgentServer)

func RegisterControlPlaneAgentServer added in v0.10.6 

func RegisterControlPlaneAgentServer(s *grpc.Server, srv ControlPlaneAgentServer)

func RegisterEtcdClusterAgentServer added in v0.10.6 

func RegisterEtcdClusterAgentServer(s *grpc.Server, srv EtcdClusterAgentServer)

func RegisterEtcdServerAgentServer added in v0.10.6 

func RegisterEtcdServerAgentServer(s *grpc.Server, srv EtcdServerAgentServer)

func RegisterGroupAgentServer 

func RegisterGroupAgentServer(s *grpc.Server, srv GroupAgentServer)

func RegisterKubernetesAgentServer 

func RegisterKubernetesAgentServer(s *grpc.Server, srv KubernetesAgentServer)

func RegisterLocationAgentServer 

func RegisterLocationAgentServer(s *grpc.Server, srv LocationAgentServer)

func RegisterNodeAgentServer 

func RegisterNodeAgentServer(s *grpc.Server, srv NodeAgentServer)

func RegisterSubscriptionAgentServer 

func RegisterSubscriptionAgentServer(s *grpc.Server, srv SubscriptionAgentServer)

Types

type Cluster 

type Cluster struct {
	Name                 string         `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Id                   string         `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	Fqdn                 string         `protobuf:"bytes,3,opt,name=fqdn,proto3" json:"fqdn,omitempty"`
	Status               *common.Status `protobuf:"bytes,4,opt,name=status,proto3" json:"status,omitempty"`
	UserOwned            bool           `protobuf:"varint,5,opt,name=UserOwned,proto3" json:"UserOwned,omitempty"`
	IsLocalCluster       bool           `protobuf:"varint,6,opt,name=IsLocalCluster,proto3" json:"IsLocalCluster,omitempty"`
	Domain               string         `protobuf:"bytes,7,opt,name=domain,proto3" json:"domain,omitempty"`
	Nodes                []*Node        `protobuf:"bytes,8,rep,name=Nodes,proto3" json:"Nodes,omitempty"`
	LocationName         string         `protobuf:"bytes,9,opt,name=locationName,proto3" json:"locationName,omitempty"`
	Tags                 *common.Tags   `protobuf:"bytes,10,opt,name=tags,proto3" json:"tags,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*Cluster) Descriptor 

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

func (*Cluster) GetDomain 

func (m *Cluster) GetDomain() string

func (*Cluster) GetFqdn 

func (m *Cluster) GetFqdn() string

func (*Cluster) GetId 

func (m *Cluster) GetId() string

func (*Cluster) GetIsLocalCluster 

func (m *Cluster) GetIsLocalCluster() bool

func (*Cluster) GetLocationName 

func (m *Cluster) GetLocationName() string

func (*Cluster) GetName 

func (m *Cluster) GetName() string

func (*Cluster) GetNodes 

func (m *Cluster) GetNodes() []*Node

func (*Cluster) GetStatus 

func (m *Cluster) GetStatus() *common.Status

func (*Cluster) GetTags added in v0.10.5 

func (m *Cluster) GetTags() *common.Tags

func (*Cluster) GetUserOwned 

func (m *Cluster) GetUserOwned() bool

func (*Cluster) ProtoMessage 

func (*Cluster) ProtoMessage()

func (*Cluster) Reset 

func (m *Cluster) Reset()

func (*Cluster) String 

func (m *Cluster) String() string

func (*Cluster) XXX_DiscardUnknown 

func (m *Cluster) XXX_DiscardUnknown()

func (*Cluster) XXX_Marshal 

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

func (*Cluster) XXX_Merge 

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

func (*Cluster) XXX_Size 

func (m *Cluster) XXX_Size() int

func (*Cluster) XXX_Unmarshal 

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

type ClusterAPIConfiguration 

type ClusterAPIConfiguration struct {
	ConfigurationEndpoint         string   `protobuf:"bytes,1,opt,name=ConfigurationEndpoint,proto3" json:"ConfigurationEndpoint,omitempty"`
	InfrastructureProviderVersion string   `protobuf:"bytes,2,opt,name=InfrastructureProviderVersion,proto3" json:"InfrastructureProviderVersion,omitempty"`
	BootstrapProviderVersion      string   `protobuf:"bytes,3,opt,name=BootstrapProviderVersion,proto3" json:"BootstrapProviderVersion,omitempty"`
	ControlPlaneProviderVersion   string   `protobuf:"bytes,4,opt,name=ControlPlaneProviderVersion,proto3" json:"ControlPlaneProviderVersion,omitempty"`
	CoreProviderVersion           string   `protobuf:"bytes,5,opt,name=CoreProviderVersion,proto3" json:"CoreProviderVersion,omitempty"`
	XXX_NoUnkeyedLiteral          struct{} `json:"-"`
	XXX_unrecognized              []byte   `json:"-"`
	XXX_sizecache                 int32    `json:"-"`
}

func (*ClusterAPIConfiguration) Descriptor 

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

func (*ClusterAPIConfiguration) GetBootstrapProviderVersion 

func (m *ClusterAPIConfiguration) GetBootstrapProviderVersion() string

func (*ClusterAPIConfiguration) GetConfigurationEndpoint 

func (m *ClusterAPIConfiguration) GetConfigurationEndpoint() string

func (*ClusterAPIConfiguration) GetControlPlaneProviderVersion 

func (m *ClusterAPIConfiguration) GetControlPlaneProviderVersion() string

func (*ClusterAPIConfiguration) GetCoreProviderVersion 

func (m *ClusterAPIConfiguration) GetCoreProviderVersion() string

func (*ClusterAPIConfiguration) GetInfrastructureProviderVersion 

func (m *ClusterAPIConfiguration) GetInfrastructureProviderVersion() string

func (*ClusterAPIConfiguration) ProtoMessage 

func (*ClusterAPIConfiguration) ProtoMessage()

func (*ClusterAPIConfiguration) Reset 

func (m *ClusterAPIConfiguration) Reset()

func (*ClusterAPIConfiguration) String 

func (m *ClusterAPIConfiguration) String() string

func (*ClusterAPIConfiguration) XXX_DiscardUnknown 

func (m *ClusterAPIConfiguration) XXX_DiscardUnknown()

func (*ClusterAPIConfiguration) XXX_Marshal 

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

func (*ClusterAPIConfiguration) XXX_Merge 

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

func (*ClusterAPIConfiguration) XXX_Size 

func (m *ClusterAPIConfiguration) XXX_Size() int

func (*ClusterAPIConfiguration) XXX_Unmarshal 

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

type ClusterAgentClient 

type ClusterAgentClient interface {
	LoadCluster(ctx context.Context, in *Cluster, opts ...grpc.CallOption) (*ClusterResponse, error)
	UnloadCluster(ctx context.Context, in *Cluster, opts ...grpc.CallOption) (*ClusterResponse, error)
	GetCluster(ctx context.Context, in *Cluster, opts ...grpc.CallOption) (*ClusterResponse, error)
	GetNodes(ctx context.Context, in *Cluster, opts ...grpc.CallOption) (*NodeResponse, error)
}

ClusterAgentClient is the client API for ClusterAgent service.

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

func NewClusterAgentClient 

func NewClusterAgentClient(cc *grpc.ClientConn) ClusterAgentClient

type ClusterAgentServer 

type ClusterAgentServer interface {
	LoadCluster(context.Context, *Cluster) (*ClusterResponse, error)
	UnloadCluster(context.Context, *Cluster) (*ClusterResponse, error)
	GetCluster(context.Context, *Cluster) (*ClusterResponse, error)
	GetNodes(context.Context, *Cluster) (*NodeResponse, error)
}

ClusterAgentServer is the server API for ClusterAgent service.

type ClusterConfiguration 

type ClusterConfiguration struct {
	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 (*ClusterConfiguration) Descriptor 

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

func (*ClusterConfiguration) GetVersion 

func (m *ClusterConfiguration) GetVersion() string

func (*ClusterConfiguration) ProtoMessage 

func (*ClusterConfiguration) ProtoMessage()

func (*ClusterConfiguration) Reset 

func (m *ClusterConfiguration) Reset()

func (*ClusterConfiguration) String 

func (m *ClusterConfiguration) String() string

func (*ClusterConfiguration) XXX_DiscardUnknown 

func (m *ClusterConfiguration) XXX_DiscardUnknown()

func (*ClusterConfiguration) XXX_Marshal 

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

func (*ClusterConfiguration) XXX_Merge 

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

func (*ClusterConfiguration) XXX_Size 

func (m *ClusterConfiguration) XXX_Size() int

func (*ClusterConfiguration) XXX_Unmarshal 

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

type ClusterResponse 

type ClusterResponse struct {
	Clusters             []*Cluster          `protobuf:"bytes,1,rep,name=Clusters,proto3" json:"Clusters,omitempty"`
	Result               *wrappers.BoolValue `protobuf:"bytes,2,opt,name=Result,proto3" json:"Result,omitempty"`
	Error                string              `protobuf:"bytes,3,opt,name=Error,proto3" json:"Error,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*ClusterResponse) Descriptor 

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

func (*ClusterResponse) GetClusters 

func (m *ClusterResponse) GetClusters() []*Cluster

func (*ClusterResponse) GetError 

func (m *ClusterResponse) GetError() string

func (*ClusterResponse) GetResult 

func (m *ClusterResponse) GetResult() *wrappers.BoolValue

func (*ClusterResponse) ProtoMessage 

func (*ClusterResponse) ProtoMessage()

func (*ClusterResponse) Reset 

func (m *ClusterResponse) Reset()

func (*ClusterResponse) String 

func (m *ClusterResponse) String() string

func (*ClusterResponse) XXX_DiscardUnknown 

func (m *ClusterResponse) XXX_DiscardUnknown()

func (*ClusterResponse) XXX_Marshal 

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

func (*ClusterResponse) XXX_Merge 

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

func (*ClusterResponse) XXX_Size 

func (m *ClusterResponse) XXX_Size() int

func (*ClusterResponse) XXX_Unmarshal 

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

type ComputeConfiguration 

type ComputeConfiguration struct {
	Cri                  string                   `protobuf:"bytes,1,opt,name=cri,proto3" json:"cri,omitempty"`
	PublicKey            *SSHPublicKey            `protobuf:"bytes,2,opt,name=publicKey,proto3" json:"publicKey,omitempty"`
	NodePools            []*NodePoolConfiguration `protobuf:"bytes,3,rep,name=NodePools,proto3" json:"NodePools,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

func (*ComputeConfiguration) Descriptor 

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

func (*ComputeConfiguration) GetCri 

func (m *ComputeConfiguration) GetCri() string

func (*ComputeConfiguration) GetNodePools 

func (m *ComputeConfiguration) GetNodePools() []*NodePoolConfiguration

func (*ComputeConfiguration) GetPublicKey 

func (m *ComputeConfiguration) GetPublicKey() *SSHPublicKey

func (*ComputeConfiguration) ProtoMessage 

func (*ComputeConfiguration) ProtoMessage()

func (*ComputeConfiguration) Reset 

func (m *ComputeConfiguration) Reset()

func (*ComputeConfiguration) String 

func (m *ComputeConfiguration) String() string

func (*ComputeConfiguration) XXX_DiscardUnknown 

func (m *ComputeConfiguration) XXX_DiscardUnknown()

func (*ComputeConfiguration) XXX_Marshal 

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

func (*ComputeConfiguration) XXX_Merge 

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

func (*ComputeConfiguration) XXX_Size 

func (m *ComputeConfiguration) XXX_Size() int

func (*ComputeConfiguration) XXX_Unmarshal 

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

type ContainerRegistry 

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

func (*ContainerRegistry) Descriptor 

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

func (*ContainerRegistry) GetName 

func (m *ContainerRegistry) GetName() string

func (*ContainerRegistry) GetPassword 

func (m *ContainerRegistry) GetPassword() string

func (*ContainerRegistry) GetUsername 

func (m *ContainerRegistry) GetUsername() string

func (*ContainerRegistry) ProtoMessage 

func (*ContainerRegistry) ProtoMessage()

func (*ContainerRegistry) Reset 

func (m *ContainerRegistry) Reset()

func (*ContainerRegistry) String 

func (m *ContainerRegistry) String() string

func (*ContainerRegistry) XXX_DiscardUnknown 

func (m *ContainerRegistry) XXX_DiscardUnknown()

func (*ContainerRegistry) XXX_Marshal 

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

func (*ContainerRegistry) XXX_Merge 

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

func (*ContainerRegistry) XXX_Size 

func (m *ContainerRegistry) XXX_Size() int

func (*ContainerRegistry) XXX_Unmarshal 

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

type ControlPlane added in v0.10.6 

type ControlPlane struct {
	// id is an internal value required for all entities
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// name is an identifier provided during ControlPlane creation
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// locationName is the name of the Location entity this ControlPlane belongs to
	LocationName string `protobuf:"bytes,3,opt,name=locationName,proto3" json:"locationName,omitempty"`
	// fqdn is the fqdn, hostname, or ip address that this ControlPlane will use as part of the leadership election
	Fqdn string `protobuf:"bytes,4,opt,name=fqdn,proto3" json:"fqdn,omitempty"`
	// port is the port that this ControlPlane will use as part of the leadership election
	Port int32 `protobuf:"varint,5,opt,name=port,proto3" json:"port,omitempty"`
	// status is a standard entity status
	Status *common.Status `protobuf:"bytes,6,opt,name=status,proto3" json:"status,omitempty"`
	// state stores the last known election status of this ControlPlane
	State                ControlPlaneState `protobuf:"varint,7,opt,name=state,proto3,enum=moc.cloudagent.controlplane.ControlPlaneState" json:"state,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

There is a ControlPlane entity for every CloudAgent participating to provide high availability without FailoverCluster

func (*ControlPlane) Descriptor added in v0.10.6 

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

func (*ControlPlane) GetFqdn added in v0.10.6 

func (m *ControlPlane) GetFqdn() string

func (*ControlPlane) GetId added in v0.10.6 

func (m *ControlPlane) GetId() string

func (*ControlPlane) GetLocationName added in v0.10.6 

func (m *ControlPlane) GetLocationName() string

func (*ControlPlane) GetName added in v0.10.6 

func (m *ControlPlane) GetName() string

func (*ControlPlane) GetPort added in v0.10.6 

func (m *ControlPlane) GetPort() int32

func (*ControlPlane) GetState added in v0.10.6 

func (m *ControlPlane) GetState() ControlPlaneState

func (*ControlPlane) GetStatus added in v0.10.6 

func (m *ControlPlane) GetStatus() *common.Status

func (*ControlPlane) ProtoMessage added in v0.10.6 

func (*ControlPlane) ProtoMessage()

func (*ControlPlane) Reset added in v0.10.6 

func (m *ControlPlane) Reset()

func (*ControlPlane) String added in v0.10.6 

func (m *ControlPlane) String() string

func (*ControlPlane) XXX_DiscardUnknown added in v0.10.6 

func (m *ControlPlane) XXX_DiscardUnknown()

func (*ControlPlane) XXX_Marshal added in v0.10.6 

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

func (*ControlPlane) XXX_Merge added in v0.10.6 

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

func (*ControlPlane) XXX_Size added in v0.10.6 

func (m *ControlPlane) XXX_Size() int

func (*ControlPlane) XXX_Unmarshal added in v0.10.6 

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

type ControlPlaneAgentClient added in v0.10.6 

type ControlPlaneAgentClient interface {
	Invoke(ctx context.Context, in *ControlPlaneRequest, opts ...grpc.CallOption) (*ControlPlaneResponse, error)
}

ControlPlaneAgentClient is the client API for ControlPlaneAgent service.

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

func NewControlPlaneAgentClient added in v0.10.6 

func NewControlPlaneAgentClient(cc *grpc.ClientConn) ControlPlaneAgentClient

type ControlPlaneAgentServer added in v0.10.6 

type ControlPlaneAgentServer interface {
	Invoke(context.Context, *ControlPlaneRequest) (*ControlPlaneResponse, error)
}

ControlPlaneAgentServer is the server API for ControlPlaneAgent service.

type ControlPlaneRequest added in v0.10.6 

type ControlPlaneRequest struct {
	ControlPlanes        []*ControlPlane  `protobuf:"bytes,1,rep,name=ControlPlanes,proto3" json:"ControlPlanes,omitempty"`
	OperationType        common.Operation `protobuf:"varint,2,opt,name=OperationType,proto3,enum=moc.Operation" json:"OperationType,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*ControlPlaneRequest) Descriptor added in v0.10.6 

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

func (*ControlPlaneRequest) GetControlPlanes added in v0.10.6 

func (m *ControlPlaneRequest) GetControlPlanes() []*ControlPlane

func (*ControlPlaneRequest) GetOperationType added in v0.10.6 

func (m *ControlPlaneRequest) GetOperationType() common.Operation

func (*ControlPlaneRequest) ProtoMessage added in v0.10.6 

func (*ControlPlaneRequest) ProtoMessage()

func (*ControlPlaneRequest) Reset added in v0.10.6 

func (m *ControlPlaneRequest) Reset()

func (*ControlPlaneRequest) String added in v0.10.6 

func (m *ControlPlaneRequest) String() string

func (*ControlPlaneRequest) XXX_DiscardUnknown added in v0.10.6 

func (m *ControlPlaneRequest) XXX_DiscardUnknown()

func (*ControlPlaneRequest) XXX_Marshal added in v0.10.6 

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

func (*ControlPlaneRequest) XXX_Merge added in v0.10.6 

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

func (*ControlPlaneRequest) XXX_Size added in v0.10.6 

func (m *ControlPlaneRequest) XXX_Size() int

func (*ControlPlaneRequest) XXX_Unmarshal added in v0.10.6 

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

type ControlPlaneResponse added in v0.10.6 

type ControlPlaneResponse struct {
	ControlPlanes        []*ControlPlane     `protobuf:"bytes,1,rep,name=ControlPlanes,proto3" json:"ControlPlanes,omitempty"`
	Result               *wrappers.BoolValue `protobuf:"bytes,2,opt,name=Result,proto3" json:"Result,omitempty"`
	Error                string              `protobuf:"bytes,3,opt,name=Error,proto3" json:"Error,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*ControlPlaneResponse) Descriptor added in v0.10.6 

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

func (*ControlPlaneResponse) GetControlPlanes added in v0.10.6 

func (m *ControlPlaneResponse) GetControlPlanes() []*ControlPlane

func (*ControlPlaneResponse) GetError added in v0.10.6 

func (m *ControlPlaneResponse) GetError() string

func (*ControlPlaneResponse) GetResult added in v0.10.6 

func (m *ControlPlaneResponse) GetResult() *wrappers.BoolValue

func (*ControlPlaneResponse) ProtoMessage added in v0.10.6 

func (*ControlPlaneResponse) ProtoMessage()

func (*ControlPlaneResponse) Reset added in v0.10.6 

func (m *ControlPlaneResponse) Reset()

func (*ControlPlaneResponse) String added in v0.10.6 

func (m *ControlPlaneResponse) String() string

func (*ControlPlaneResponse) XXX_DiscardUnknown added in v0.10.6 

func (m *ControlPlaneResponse) XXX_DiscardUnknown()

func (*ControlPlaneResponse) XXX_Marshal added in v0.10.6 

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

func (*ControlPlaneResponse) XXX_Merge added in v0.10.6 

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

func (*ControlPlaneResponse) XXX_Size added in v0.10.6 

func (m *ControlPlaneResponse) XXX_Size() int

func (*ControlPlaneResponse) XXX_Unmarshal added in v0.10.6 

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

type ControlPlaneState added in v0.10.6 

type ControlPlaneState int32
const (
	ControlPlaneState_NotLeader ControlPlaneState = 0
	ControlPlaneState_Leader    ControlPlaneState = 1
)

func (ControlPlaneState) EnumDescriptor added in v0.10.6 

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

func (ControlPlaneState) String added in v0.10.6 

func (x ControlPlaneState) String() string

type EtcdCluster added in v0.10.6 

type EtcdCluster 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"`
	LocationName string `protobuf:"bytes,3,opt,name=locationName,proto3" json:"locationName,omitempty"`
	GroupName    string `protobuf:"bytes,4,opt,name=groupName,proto3" json:"groupName,omitempty"`
	// etcd ca certificate that works as RoT for client and peer connections
	CaCertificate string `protobuf:"bytes,5,opt,name=caCertificate,proto3" json:"caCertificate,omitempty"`
	// etcd ca key associated with the ca certificate
	CaKey                string         `protobuf:"bytes,6,opt,name=caKey,proto3" json:"caKey,omitempty"`
	Status               *common.Status `protobuf:"bytes,7,opt,name=status,proto3" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*EtcdCluster) Descriptor added in v0.10.6 

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

func (*EtcdCluster) GetCaCertificate added in v0.10.6 

func (m *EtcdCluster) GetCaCertificate() string

func (*EtcdCluster) GetCaKey added in v0.10.6 

func (m *EtcdCluster) GetCaKey() string

func (*EtcdCluster) GetGroupName added in v0.10.6 

func (m *EtcdCluster) GetGroupName() string

func (*EtcdCluster) GetId added in v0.10.6 

func (m *EtcdCluster) GetId() string

func (*EtcdCluster) GetLocationName added in v0.10.6 

func (m *EtcdCluster) GetLocationName() string

func (*EtcdCluster) GetName added in v0.10.6 

func (m *EtcdCluster) GetName() string

func (*EtcdCluster) GetStatus added in v0.10.6 

func (m *EtcdCluster) GetStatus() *common.Status

func (*EtcdCluster) ProtoMessage added in v0.10.6 

func (*EtcdCluster) ProtoMessage()

func (*EtcdCluster) Reset added in v0.10.6 

func (m *EtcdCluster) Reset()

func (*EtcdCluster) String added in v0.10.6 

func (m *EtcdCluster) String() string

func (*EtcdCluster) XXX_DiscardUnknown added in v0.10.6 

func (m *EtcdCluster) XXX_DiscardUnknown()

func (*EtcdCluster) XXX_Marshal added in v0.10.6 

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

func (*EtcdCluster) XXX_Merge added in v0.10.6 

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

func (*EtcdCluster) XXX_Size added in v0.10.6 

func (m *EtcdCluster) XXX_Size() int

func (*EtcdCluster) XXX_Unmarshal added in v0.10.6 

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

type EtcdClusterAgentClient added in v0.10.6 

type EtcdClusterAgentClient interface {
	Invoke(ctx context.Context, in *EtcdClusterRequest, opts ...grpc.CallOption) (*EtcdClusterResponse, error)
}

EtcdClusterAgentClient is the client API for EtcdClusterAgent service.

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

func NewEtcdClusterAgentClient added in v0.10.6 

func NewEtcdClusterAgentClient(cc *grpc.ClientConn) EtcdClusterAgentClient

type EtcdClusterAgentServer added in v0.10.6 

type EtcdClusterAgentServer interface {
	Invoke(context.Context, *EtcdClusterRequest) (*EtcdClusterResponse, error)
}

EtcdClusterAgentServer is the server API for EtcdClusterAgent service.

type EtcdClusterRequest added in v0.10.6 

type EtcdClusterRequest struct {
	EtcdClusters         []*EtcdCluster   `protobuf:"bytes,1,rep,name=EtcdClusters,proto3" json:"EtcdClusters,omitempty"`
	OperationType        common.Operation `protobuf:"varint,2,opt,name=OperationType,proto3,enum=moc.Operation" json:"OperationType,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*EtcdClusterRequest) Descriptor added in v0.10.6 

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

func (*EtcdClusterRequest) GetEtcdClusters added in v0.10.6 

func (m *EtcdClusterRequest) GetEtcdClusters() []*EtcdCluster

func (*EtcdClusterRequest) GetOperationType added in v0.10.6 

func (m *EtcdClusterRequest) GetOperationType() common.Operation

func (*EtcdClusterRequest) ProtoMessage added in v0.10.6 

func (*EtcdClusterRequest) ProtoMessage()

func (*EtcdClusterRequest) Reset added in v0.10.6 

func (m *EtcdClusterRequest) Reset()

func (*EtcdClusterRequest) String added in v0.10.6 

func (m *EtcdClusterRequest) String() string

func (*EtcdClusterRequest) XXX_DiscardUnknown added in v0.10.6 

func (m *EtcdClusterRequest) XXX_DiscardUnknown()

func (*EtcdClusterRequest) XXX_Marshal added in v0.10.6 

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

func (*EtcdClusterRequest) XXX_Merge added in v0.10.6 

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

func (*EtcdClusterRequest) XXX_Size added in v0.10.6 

func (m *EtcdClusterRequest) XXX_Size() int

func (*EtcdClusterRequest) XXX_Unmarshal added in v0.10.6 

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

type EtcdClusterResponse added in v0.10.6 

type EtcdClusterResponse struct {
	EtcdClusters         []*EtcdCluster      `protobuf:"bytes,1,rep,name=EtcdClusters,proto3" json:"EtcdClusters,omitempty"`
	Result               *wrappers.BoolValue `protobuf:"bytes,2,opt,name=Result,proto3" json:"Result,omitempty"`
	Error                string              `protobuf:"bytes,3,opt,name=Error,proto3" json:"Error,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*EtcdClusterResponse) Descriptor added in v0.10.6 

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

func (*EtcdClusterResponse) GetError added in v0.10.6 

func (m *EtcdClusterResponse) GetError() string

func (*EtcdClusterResponse) GetEtcdClusters added in v0.10.6 

func (m *EtcdClusterResponse) GetEtcdClusters() []*EtcdCluster

func (*EtcdClusterResponse) GetResult added in v0.10.6 

func (m *EtcdClusterResponse) GetResult() *wrappers.BoolValue

func (*EtcdClusterResponse) ProtoMessage added in v0.10.6 

func (*EtcdClusterResponse) ProtoMessage()

func (*EtcdClusterResponse) Reset added in v0.10.6 

func (m *EtcdClusterResponse) Reset()

func (*EtcdClusterResponse) String added in v0.10.6 

func (m *EtcdClusterResponse) String() string

func (*EtcdClusterResponse) XXX_DiscardUnknown added in v0.10.6 

func (m *EtcdClusterResponse) XXX_DiscardUnknown()

func (*EtcdClusterResponse) XXX_Marshal added in v0.10.6 

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

func (*EtcdClusterResponse) XXX_Merge added in v0.10.6 

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

func (*EtcdClusterResponse) XXX_Size added in v0.10.6 

func (m *EtcdClusterResponse) XXX_Size() int

func (*EtcdClusterResponse) XXX_Unmarshal added in v0.10.6 

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

type EtcdServer added in v0.10.6 

type EtcdServer 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"`
	EtcdClusterName string `protobuf:"bytes,3,opt,name=etcdClusterName,proto3" json:"etcdClusterName,omitempty"`
	ClusterId       string `protobuf:"bytes,4,opt,name=clusterId,proto3" json:"clusterId,omitempty"`
	LocationName    string `protobuf:"bytes,5,opt,name=locationName,proto3" json:"locationName,omitempty"`
	GroupName       string `protobuf:"bytes,6,opt,name=groupName,proto3" json:"groupName,omitempty"`
	// fqdn is the fqdn, hostname, or ip address that this EtcdServer will
	// advertise on
	Fqdn string `protobuf:"bytes,7,opt,name=fqdn,proto3" json:"fqdn,omitempty"`
	// etcd client port to listen on
	ClientPort           uint32         `protobuf:"varint,8,opt,name=clientPort,proto3" json:"clientPort,omitempty"`
	Status               *common.Status `protobuf:"bytes,9,opt,name=status,proto3" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*EtcdServer) Descriptor added in v0.10.6 

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

func (*EtcdServer) GetClientPort added in v0.10.6 

func (m *EtcdServer) GetClientPort() uint32

func (*EtcdServer) GetClusterId added in v0.10.6 

func (m *EtcdServer) GetClusterId() string

func (*EtcdServer) GetEtcdClusterName added in v0.10.6 

func (m *EtcdServer) GetEtcdClusterName() string

func (*EtcdServer) GetFqdn added in v0.10.6 

func (m *EtcdServer) GetFqdn() string

func (*EtcdServer) GetGroupName added in v0.10.6 

func (m *EtcdServer) GetGroupName() string

func (*EtcdServer) GetId added in v0.10.6 

func (m *EtcdServer) GetId() string

func (*EtcdServer) GetLocationName added in v0.10.6 

func (m *EtcdServer) GetLocationName() string

func (*EtcdServer) GetName added in v0.10.6 

func (m *EtcdServer) GetName() string

func (*EtcdServer) GetStatus added in v0.10.6 

func (m *EtcdServer) GetStatus() *common.Status

func (*EtcdServer) ProtoMessage added in v0.10.6 

func (*EtcdServer) ProtoMessage()

func (*EtcdServer) Reset added in v0.10.6 

func (m *EtcdServer) Reset()

func (*EtcdServer) String added in v0.10.6 

func (m *EtcdServer) String() string

func (*EtcdServer) XXX_DiscardUnknown added in v0.10.6 

func (m *EtcdServer) XXX_DiscardUnknown()

func (*EtcdServer) XXX_Marshal added in v0.10.6 

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

func (*EtcdServer) XXX_Merge added in v0.10.6 

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

func (*EtcdServer) XXX_Size added in v0.10.6 

func (m *EtcdServer) XXX_Size() int

func (*EtcdServer) XXX_Unmarshal added in v0.10.6 

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

type EtcdServerAgentClient added in v0.10.6 

type EtcdServerAgentClient interface {
	Invoke(ctx context.Context, in *EtcdServerRequest, opts ...grpc.CallOption) (*EtcdServerResponse, error)
}

EtcdServerAgentClient is the client API for EtcdServerAgent service.

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

func NewEtcdServerAgentClient added in v0.10.6 

func NewEtcdServerAgentClient(cc *grpc.ClientConn) EtcdServerAgentClient

type EtcdServerAgentServer added in v0.10.6 

type EtcdServerAgentServer interface {
	Invoke(context.Context, *EtcdServerRequest) (*EtcdServerResponse, error)
}

EtcdServerAgentServer is the server API for EtcdServerAgent service.

type EtcdServerRequest added in v0.10.6 

type EtcdServerRequest struct {
	EtcdServers          []*EtcdServer    `protobuf:"bytes,1,rep,name=EtcdServers,proto3" json:"EtcdServers,omitempty"`
	OperationType        common.Operation `protobuf:"varint,2,opt,name=OperationType,proto3,enum=moc.Operation" json:"OperationType,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*EtcdServerRequest) Descriptor added in v0.10.6 

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

func (*EtcdServerRequest) GetEtcdServers added in v0.10.6 

func (m *EtcdServerRequest) GetEtcdServers() []*EtcdServer

func (*EtcdServerRequest) GetOperationType added in v0.10.6 

func (m *EtcdServerRequest) GetOperationType() common.Operation

func (*EtcdServerRequest) ProtoMessage added in v0.10.6 

func (*EtcdServerRequest) ProtoMessage()

func (*EtcdServerRequest) Reset added in v0.10.6 

func (m *EtcdServerRequest) Reset()

func (*EtcdServerRequest) String added in v0.10.6 

func (m *EtcdServerRequest) String() string

func (*EtcdServerRequest) XXX_DiscardUnknown added in v0.10.6 

func (m *EtcdServerRequest) XXX_DiscardUnknown()

func (*EtcdServerRequest) XXX_Marshal added in v0.10.6 

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

func (*EtcdServerRequest) XXX_Merge added in v0.10.6 

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

func (*EtcdServerRequest) XXX_Size added in v0.10.6 

func (m *EtcdServerRequest) XXX_Size() int

func (*EtcdServerRequest) XXX_Unmarshal added in v0.10.6 

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

type EtcdServerResponse added in v0.10.6 

type EtcdServerResponse struct {
	EtcdServers          []*EtcdServer       `protobuf:"bytes,1,rep,name=EtcdServers,proto3" json:"EtcdServers,omitempty"`
	Result               *wrappers.BoolValue `protobuf:"bytes,2,opt,name=Result,proto3" json:"Result,omitempty"`
	Error                string              `protobuf:"bytes,3,opt,name=Error,proto3" json:"Error,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*EtcdServerResponse) Descriptor added in v0.10.6 

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

func (*EtcdServerResponse) GetError added in v0.10.6 

func (m *EtcdServerResponse) GetError() string

func (*EtcdServerResponse) GetEtcdServers added in v0.10.6 

func (m *EtcdServerResponse) GetEtcdServers() []*EtcdServer

func (*EtcdServerResponse) GetResult added in v0.10.6 

func (m *EtcdServerResponse) GetResult() *wrappers.BoolValue

func (*EtcdServerResponse) ProtoMessage added in v0.10.6 

func (*EtcdServerResponse) ProtoMessage()

func (*EtcdServerResponse) Reset added in v0.10.6 

func (m *EtcdServerResponse) Reset()

func (*EtcdServerResponse) String added in v0.10.6 

func (m *EtcdServerResponse) String() string

func (*EtcdServerResponse) XXX_DiscardUnknown added in v0.10.6 

func (m *EtcdServerResponse) XXX_DiscardUnknown()

func (*EtcdServerResponse) XXX_Marshal added in v0.10.6 

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

func (*EtcdServerResponse) XXX_Merge added in v0.10.6 

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

func (*EtcdServerResponse) XXX_Size added in v0.10.6 

func (m *EtcdServerResponse) XXX_Size() int

func (*EtcdServerResponse) XXX_Unmarshal added in v0.10.6 

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

type Group 

type Group struct {
	Name                 string         `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Id                   string         `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	Status               *common.Status `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"`
	LocationName         string         `protobuf:"bytes,4,opt,name=locationName,proto3" json:"locationName,omitempty"`
	Tags                 *common.Tags   `protobuf:"bytes,5,opt,name=tags,proto3" json:"tags,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*Group) Descriptor 

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

func (*Group) GetId 

func (m *Group) GetId() string

func (*Group) GetLocationName 

func (m *Group) GetLocationName() string

func (*Group) GetName 

func (m *Group) GetName() string

func (*Group) GetStatus 

func (m *Group) GetStatus() *common.Status

func (*Group) GetTags added in v0.10.5 

func (m *Group) GetTags() *common.Tags

func (*Group) ProtoMessage 

func (*Group) ProtoMessage()

func (*Group) Reset 

func (m *Group) Reset()

func (*Group) String 

func (m *Group) String() string

func (*Group) XXX_DiscardUnknown 

func (m *Group) XXX_DiscardUnknown()

func (*Group) XXX_Marshal 

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

func (*Group) XXX_Merge 

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

func (*Group) XXX_Size 

func (m *Group) XXX_Size() int

func (*Group) XXX_Unmarshal 

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

type GroupAgentClient 

type GroupAgentClient interface {
	Invoke(ctx context.Context, in *GroupRequest, opts ...grpc.CallOption) (*GroupResponse, error)
}

GroupAgentClient is the client API for GroupAgent service.

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

func NewGroupAgentClient 

func NewGroupAgentClient(cc *grpc.ClientConn) GroupAgentClient

type GroupAgentServer 

type GroupAgentServer interface {
	Invoke(context.Context, *GroupRequest) (*GroupResponse, error)
}

GroupAgentServer is the server API for GroupAgent service.

type GroupRequest 

type GroupRequest struct {
	Groups               []*Group         `protobuf:"bytes,1,rep,name=Groups,proto3" json:"Groups,omitempty"`
	OperationType        common.Operation `protobuf:"varint,2,opt,name=OperationType,proto3,enum=moc.Operation" json:"OperationType,omitempty"`
	PostOperationType    SubPostOperation `` /* 131-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*GroupRequest) Descriptor 

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

func (*GroupRequest) GetGroups 

func (m *GroupRequest) GetGroups() []*Group

func (*GroupRequest) GetOperationType 

func (m *GroupRequest) GetOperationType() common.Operation

func (*GroupRequest) GetPostOperationType 

func (m *GroupRequest) GetPostOperationType() SubPostOperation

func (*GroupRequest) ProtoMessage 

func (*GroupRequest) ProtoMessage()

func (*GroupRequest) Reset 

func (m *GroupRequest) Reset()

func (*GroupRequest) String 

func (m *GroupRequest) String() string

func (*GroupRequest) XXX_DiscardUnknown 

func (m *GroupRequest) XXX_DiscardUnknown()

func (*GroupRequest) XXX_Marshal 

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

func (*GroupRequest) XXX_Merge 

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

func (*GroupRequest) XXX_Size 

func (m *GroupRequest) XXX_Size() int

func (*GroupRequest) XXX_Unmarshal 

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

type GroupResponse 

type GroupResponse struct {
	Groups               []*Group            `protobuf:"bytes,1,rep,name=Groups,proto3" json:"Groups,omitempty"`
	Result               *wrappers.BoolValue `protobuf:"bytes,2,opt,name=Result,proto3" json:"Result,omitempty"`
	Error                string              `protobuf:"bytes,3,opt,name=Error,proto3" json:"Error,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*GroupResponse) Descriptor 

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

func (*GroupResponse) GetError 

func (m *GroupResponse) GetError() string

func (*GroupResponse) GetGroups 

func (m *GroupResponse) GetGroups() []*Group

func (*GroupResponse) GetResult 

func (m *GroupResponse) GetResult() *wrappers.BoolValue

func (*GroupResponse) ProtoMessage 

func (*GroupResponse) ProtoMessage()

func (*GroupResponse) Reset 

func (m *GroupResponse) Reset()

func (*GroupResponse) String 

func (m *GroupResponse) String() string

func (*GroupResponse) XXX_DiscardUnknown 

func (m *GroupResponse) XXX_DiscardUnknown()

func (*GroupResponse) XXX_Marshal 

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

func (*GroupResponse) XXX_Merge 

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

func (*GroupResponse) XXX_Size 

func (m *GroupResponse) XXX_Size() int

func (*GroupResponse) XXX_Unmarshal 

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

type Kubernetes 

type Kubernetes struct {
	Name                 string                   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Id                   string                   `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	Status               *common.Status           `protobuf:"bytes,4,opt,name=status,proto3" json:"status,omitempty"`
	Cluster              *ClusterConfiguration    `protobuf:"bytes,5,opt,name=cluster,proto3" json:"cluster,omitempty"`
	Network              *NetworkConfiguration    `protobuf:"bytes,6,opt,name=network,proto3" json:"network,omitempty"`
	Storage              *StorageConfiguration    `protobuf:"bytes,7,opt,name=storage,proto3" json:"storage,omitempty"`
	Compute              *ComputeConfiguration    `protobuf:"bytes,8,opt,name=compute,proto3" json:"compute,omitempty"`
	GroupName            string                   `protobuf:"bytes,9,opt,name=groupName,proto3" json:"groupName,omitempty"`
	ManagementStrategy   ManagementStrategyType   `` /* 145-byte string literal not displayed */
	LocationName         string                   `protobuf:"bytes,11,opt,name=locationName,proto3" json:"locationName,omitempty"`
	KubeConfig           []byte                   `protobuf:"bytes,12,opt,name=kubeConfig,proto3" json:"kubeConfig,omitempty"`
	CapiConfig           *ClusterAPIConfiguration `protobuf:"bytes,13,opt,name=capiConfig,proto3" json:"capiConfig,omitempty"`
	ContainerRegistry    *ContainerRegistry       `protobuf:"bytes,14,opt,name=containerRegistry,proto3" json:"containerRegistry,omitempty"`
	DeploymentManifest   []byte                   `protobuf:"bytes,15,opt,name=deploymentManifest,proto3" json:"deploymentManifest,omitempty"`
	Tags                 *common.Tags             `protobuf:"bytes,16,opt,name=tags,proto3" json:"tags,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

func (*Kubernetes) Descriptor 

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

func (*Kubernetes) GetCapiConfig 

func (m *Kubernetes) GetCapiConfig() *ClusterAPIConfiguration

func (*Kubernetes) GetCluster 

func (m *Kubernetes) GetCluster() *ClusterConfiguration

func (*Kubernetes) GetCompute 

func (m *Kubernetes) GetCompute() *ComputeConfiguration

func (*Kubernetes) GetContainerRegistry 

func (m *Kubernetes) GetContainerRegistry() *ContainerRegistry

func (*Kubernetes) GetDeploymentManifest 

func (m *Kubernetes) GetDeploymentManifest() []byte

func (*Kubernetes) GetGroupName 

func (m *Kubernetes) GetGroupName() string

func (*Kubernetes) GetId 

func (m *Kubernetes) GetId() string

func (*Kubernetes) GetKubeConfig 

func (m *Kubernetes) GetKubeConfig() []byte

func (*Kubernetes) GetLocationName 

func (m *Kubernetes) GetLocationName() string

func (*Kubernetes) GetManagementStrategy 

func (m *Kubernetes) GetManagementStrategy() ManagementStrategyType

func (*Kubernetes) GetName 

func (m *Kubernetes) GetName() string

func (*Kubernetes) GetNetwork 

func (m *Kubernetes) GetNetwork() *NetworkConfiguration

func (*Kubernetes) GetStatus 

func (m *Kubernetes) GetStatus() *common.Status

func (*Kubernetes) GetStorage 

func (m *Kubernetes) GetStorage() *StorageConfiguration

func (*Kubernetes) GetTags added in v0.10.5 

func (m *Kubernetes) GetTags() *common.Tags

func (*Kubernetes) ProtoMessage 

func (*Kubernetes) ProtoMessage()

func (*Kubernetes) Reset 

func (m *Kubernetes) Reset()

func (*Kubernetes) String 

func (m *Kubernetes) String() string

func (*Kubernetes) XXX_DiscardUnknown 

func (m *Kubernetes) XXX_DiscardUnknown()

func (*Kubernetes) XXX_Marshal 

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

func (*Kubernetes) XXX_Merge 

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

func (*Kubernetes) XXX_Size 

func (m *Kubernetes) XXX_Size() int

func (*Kubernetes) XXX_Unmarshal 

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

type KubernetesAgentClient 

type KubernetesAgentClient interface {
	Invoke(ctx context.Context, in *KubernetesRequest, opts ...grpc.CallOption) (*KubernetesResponse, error)
}

KubernetesAgentClient is the client API for KubernetesAgent service.

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

func NewKubernetesAgentClient 

func NewKubernetesAgentClient(cc *grpc.ClientConn) KubernetesAgentClient

type KubernetesAgentServer 

type KubernetesAgentServer interface {
	Invoke(context.Context, *KubernetesRequest) (*KubernetesResponse, error)
}

KubernetesAgentServer is the server API for KubernetesAgent service.

type KubernetesRequest 

type KubernetesRequest struct {
	Kubernetess          []*Kubernetes    `protobuf:"bytes,1,rep,name=Kubernetess,proto3" json:"Kubernetess,omitempty"`
	OperationType        common.Operation `protobuf:"varint,2,opt,name=OperationType,proto3,enum=moc.Operation" json:"OperationType,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*KubernetesRequest) Descriptor 

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

func (*KubernetesRequest) GetKubernetess 

func (m *KubernetesRequest) GetKubernetess() []*Kubernetes

func (*KubernetesRequest) GetOperationType 

func (m *KubernetesRequest) GetOperationType() common.Operation

func (*KubernetesRequest) ProtoMessage 

func (*KubernetesRequest) ProtoMessage()

func (*KubernetesRequest) Reset 

func (m *KubernetesRequest) Reset()

func (*KubernetesRequest) String 

func (m *KubernetesRequest) String() string

func (*KubernetesRequest) XXX_DiscardUnknown 

func (m *KubernetesRequest) XXX_DiscardUnknown()

func (*KubernetesRequest) XXX_Marshal 

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

func (*KubernetesRequest) XXX_Merge 

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

func (*KubernetesRequest) XXX_Size 

func (m *KubernetesRequest) XXX_Size() int

func (*KubernetesRequest) XXX_Unmarshal 

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

type KubernetesResponse 

type KubernetesResponse struct {
	Kubernetess          []*Kubernetes       `protobuf:"bytes,1,rep,name=Kubernetess,proto3" json:"Kubernetess,omitempty"`
	Result               *wrappers.BoolValue `protobuf:"bytes,2,opt,name=Result,proto3" json:"Result,omitempty"`
	Error                string              `protobuf:"bytes,3,opt,name=Error,proto3" json:"Error,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*KubernetesResponse) Descriptor 

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

func (*KubernetesResponse) GetError 

func (m *KubernetesResponse) GetError() string

func (*KubernetesResponse) GetKubernetess 

func (m *KubernetesResponse) GetKubernetess() []*Kubernetes

func (*KubernetesResponse) GetResult 

func (m *KubernetesResponse) GetResult() *wrappers.BoolValue

func (*KubernetesResponse) ProtoMessage 

func (*KubernetesResponse) ProtoMessage()

func (*KubernetesResponse) Reset 

func (m *KubernetesResponse) Reset()

func (*KubernetesResponse) String 

func (m *KubernetesResponse) String() string

func (*KubernetesResponse) XXX_DiscardUnknown 

func (m *KubernetesResponse) XXX_DiscardUnknown()

func (*KubernetesResponse) XXX_Marshal 

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

func (*KubernetesResponse) XXX_Merge 

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

func (*KubernetesResponse) XXX_Size 

func (m *KubernetesResponse) XXX_Size() int

func (*KubernetesResponse) XXX_Unmarshal 

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

type Location 

type Location struct {
	Name                 string         `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Id                   string         `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	Status               *common.Status `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"`
	Tags                 *common.Tags   `protobuf:"bytes,4,opt,name=tags,proto3" json:"tags,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*Location) Descriptor 

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

func (*Location) GetId 

func (m *Location) GetId() string

func (*Location) GetName 

func (m *Location) GetName() string

func (*Location) GetStatus 

func (m *Location) GetStatus() *common.Status

func (*Location) GetTags added in v0.10.5 

func (m *Location) GetTags() *common.Tags

func (*Location) ProtoMessage 

func (*Location) ProtoMessage()

func (*Location) Reset 

func (m *Location) Reset()

func (*Location) String 

func (m *Location) String() string

func (*Location) XXX_DiscardUnknown 

func (m *Location) XXX_DiscardUnknown()

func (*Location) XXX_Marshal 

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

func (*Location) XXX_Merge 

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

func (*Location) XXX_Size 

func (m *Location) XXX_Size() int

func (*Location) XXX_Unmarshal 

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

type LocationAgentClient 

type LocationAgentClient interface {
	Invoke(ctx context.Context, in *LocationRequest, opts ...grpc.CallOption) (*LocationResponse, error)
}

LocationAgentClient is the client API for LocationAgent service.

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

func NewLocationAgentClient 

func NewLocationAgentClient(cc *grpc.ClientConn) LocationAgentClient

type LocationAgentServer 

type LocationAgentServer interface {
	Invoke(context.Context, *LocationRequest) (*LocationResponse, error)
}

LocationAgentServer is the server API for LocationAgent service.

type LocationRequest 

type LocationRequest struct {
	Locations            []*Location      `protobuf:"bytes,1,rep,name=Locations,proto3" json:"Locations,omitempty"`
	OperationType        common.Operation `protobuf:"varint,2,opt,name=OperationType,proto3,enum=moc.Operation" json:"OperationType,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*LocationRequest) Descriptor 

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

func (*LocationRequest) GetLocations 

func (m *LocationRequest) GetLocations() []*Location

func (*LocationRequest) GetOperationType 

func (m *LocationRequest) GetOperationType() common.Operation

func (*LocationRequest) ProtoMessage 

func (*LocationRequest) ProtoMessage()

func (*LocationRequest) Reset 

func (m *LocationRequest) Reset()

func (*LocationRequest) String 

func (m *LocationRequest) String() string

func (*LocationRequest) XXX_DiscardUnknown 

func (m *LocationRequest) XXX_DiscardUnknown()

func (*LocationRequest) XXX_Marshal 

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

func (*LocationRequest) XXX_Merge 

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

func (*LocationRequest) XXX_Size 

func (m *LocationRequest) XXX_Size() int

func (*LocationRequest) XXX_Unmarshal 

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

type LocationResponse 

type LocationResponse struct {
	Locations            []*Location         `protobuf:"bytes,1,rep,name=Locations,proto3" json:"Locations,omitempty"`
	Result               *wrappers.BoolValue `protobuf:"bytes,2,opt,name=Result,proto3" json:"Result,omitempty"`
	Error                string              `protobuf:"bytes,3,opt,name=Error,proto3" json:"Error,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*LocationResponse) Descriptor 

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

func (*LocationResponse) GetError 

func (m *LocationResponse) GetError() string

func (*LocationResponse) GetLocations 

func (m *LocationResponse) GetLocations() []*Location

func (*LocationResponse) GetResult 

func (m *LocationResponse) GetResult() *wrappers.BoolValue

func (*LocationResponse) ProtoMessage 

func (*LocationResponse) ProtoMessage()

func (*LocationResponse) Reset 

func (m *LocationResponse) Reset()

func (*LocationResponse) String 

func (m *LocationResponse) String() string

func (*LocationResponse) XXX_DiscardUnknown 

func (m *LocationResponse) XXX_DiscardUnknown()

func (*LocationResponse) XXX_Marshal 

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

func (*LocationResponse) XXX_Merge 

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

func (*LocationResponse) XXX_Size 

func (m *LocationResponse) XXX_Size() int

func (*LocationResponse) XXX_Unmarshal 

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

type ManagementStrategyType 

type ManagementStrategyType int32
const (
	ManagementStrategyType_Pivoted  ManagementStrategyType = 0
	ManagementStrategyType_Distinct ManagementStrategyType = 1
)

func (ManagementStrategyType) EnumDescriptor 

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

func (ManagementStrategyType) String 

func (x ManagementStrategyType) String() string

type NetworkConfiguration 

type NetworkConfiguration struct {
	Cni         string `protobuf:"bytes,1,opt,name=cni,proto3" json:"cni,omitempty"`
	PodCidr     string `protobuf:"bytes,2,opt,name=podCidr,proto3" json:"podCidr,omitempty"`
	ClusterCidr string `protobuf:"bytes,3,opt,name=clusterCidr,proto3" json:"clusterCidr,omitempty"`
	// TODO: merge controlplane cidr and network
	ControlPlaneCidr     string   `protobuf:"bytes,4,opt,name=controlPlaneCidr,proto3" json:"controlPlaneCidr,omitempty"`
	Virtualnetwork       string   `protobuf:"bytes,5,opt,name=virtualnetwork,proto3" json:"virtualnetwork,omitempty"`
	LoadBalancerVip      string   `protobuf:"bytes,6,opt,name=loadBalancerVip,proto3" json:"loadBalancerVip,omitempty"`
	LoadBalancerMac      string   `protobuf:"bytes,7,opt,name=loadBalancerMac,proto3" json:"loadBalancerMac,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NetworkConfiguration) Descriptor 

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

func (*NetworkConfiguration) GetClusterCidr 

func (m *NetworkConfiguration) GetClusterCidr() string

func (*NetworkConfiguration) GetCni 

func (m *NetworkConfiguration) GetCni() string

func (*NetworkConfiguration) GetControlPlaneCidr 

func (m *NetworkConfiguration) GetControlPlaneCidr() string

func (*NetworkConfiguration) GetLoadBalancerMac 

func (m *NetworkConfiguration) GetLoadBalancerMac() string

func (*NetworkConfiguration) GetLoadBalancerVip 

func (m *NetworkConfiguration) GetLoadBalancerVip() string

func (*NetworkConfiguration) GetPodCidr 

func (m *NetworkConfiguration) GetPodCidr() string

func (*NetworkConfiguration) GetVirtualnetwork 

func (m *NetworkConfiguration) GetVirtualnetwork() string

func (*NetworkConfiguration) ProtoMessage 

func (*NetworkConfiguration) ProtoMessage()

func (*NetworkConfiguration) Reset 

func (m *NetworkConfiguration) Reset()

func (*NetworkConfiguration) String 

func (m *NetworkConfiguration) String() string

func (*NetworkConfiguration) XXX_DiscardUnknown 

func (m *NetworkConfiguration) XXX_DiscardUnknown()

func (*NetworkConfiguration) XXX_Marshal 

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

func (*NetworkConfiguration) XXX_Merge 

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

func (*NetworkConfiguration) XXX_Size 

func (m *NetworkConfiguration) XXX_Size() int

func (*NetworkConfiguration) XXX_Unmarshal 

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

type Node 

type Node struct {
	Name                 string           `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Id                   string           `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	Fqdn                 string           `protobuf:"bytes,3,opt,name=fqdn,proto3" json:"fqdn,omitempty"`
	Status               *common.Status   `protobuf:"bytes,4,opt,name=status,proto3" json:"status,omitempty"`
	LocationName         string           `protobuf:"bytes,5,opt,name=locationName,proto3" json:"locationName,omitempty"`
	Certificate          string           `protobuf:"bytes,6,opt,name=certificate,proto3" json:"certificate,omitempty"`
	Port                 int32            `protobuf:"varint,7,opt,name=port,proto3" json:"port,omitempty"`
	AuthorizerPort       int32            `protobuf:"varint,8,opt,name=authorizerPort,proto3" json:"authorizerPort,omitempty"`
	RunningState         NodeState        `protobuf:"varint,9,opt,name=runningState,proto3,enum=moc.cloudagent.node.NodeState" json:"runningState,omitempty"`
	Info                 *common.NodeInfo `protobuf:"bytes,10,opt,name=info,proto3" json:"info,omitempty"`
	Tags                 *common.Tags     `protobuf:"bytes,11,opt,name=tags,proto3" json:"tags,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*Node) Descriptor 

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

func (*Node) GetAuthorizerPort 

func (m *Node) GetAuthorizerPort() int32

func (*Node) GetCertificate 

func (m *Node) GetCertificate() string

func (*Node) GetFqdn 

func (m *Node) GetFqdn() string

func (*Node) GetId 

func (m *Node) GetId() string

func (*Node) GetInfo 

func (m *Node) GetInfo() *common.NodeInfo

func (*Node) GetLocationName 

func (m *Node) GetLocationName() string

func (*Node) GetName 

func (m *Node) GetName() string

func (*Node) GetPort 

func (m *Node) GetPort() int32

func (*Node) GetRunningState 

func (m *Node) GetRunningState() NodeState

func (*Node) GetStatus 

func (m *Node) GetStatus() *common.Status

func (*Node) GetTags added in v0.10.5 

func (m *Node) GetTags() *common.Tags

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 NodeAgentClient 

type NodeAgentClient interface {
	Invoke(ctx context.Context, in *NodeRequest, opts ...grpc.CallOption) (*NodeResponse, error)
}

NodeAgentClient is the client API for NodeAgent service.

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

func NewNodeAgentClient 

func NewNodeAgentClient(cc *grpc.ClientConn) NodeAgentClient

type NodeAgentServer 

type NodeAgentServer interface {
	Invoke(context.Context, *NodeRequest) (*NodeResponse, error)
}

NodeAgentServer is the server API for NodeAgent service.

type NodePoolConfiguration 

type NodePoolConfiguration struct {
	NodeType             NodeType `protobuf:"varint,1,opt,name=NodeType,proto3,enum=moc.cloudagent.kubernetes.NodeType" json:"NodeType,omitempty"`
	Imagereference       string   `protobuf:"bytes,2,opt,name=imagereference,proto3" json:"imagereference,omitempty"`
	Replicas             int32    `protobuf:"varint,3,opt,name=replicas,proto3" json:"replicas,omitempty"`
	VMSize               string   `protobuf:"bytes,4,opt,name=VMSize,proto3" json:"VMSize,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NodePoolConfiguration) Descriptor 

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

func (*NodePoolConfiguration) GetImagereference 

func (m *NodePoolConfiguration) GetImagereference() string

func (*NodePoolConfiguration) GetNodeType 

func (m *NodePoolConfiguration) GetNodeType() NodeType

func (*NodePoolConfiguration) GetReplicas 

func (m *NodePoolConfiguration) GetReplicas() int32

func (*NodePoolConfiguration) GetVMSize 

func (m *NodePoolConfiguration) GetVMSize() string

func (*NodePoolConfiguration) ProtoMessage 

func (*NodePoolConfiguration) ProtoMessage()

func (*NodePoolConfiguration) Reset 

func (m *NodePoolConfiguration) Reset()

func (*NodePoolConfiguration) String 

func (m *NodePoolConfiguration) String() string

func (*NodePoolConfiguration) XXX_DiscardUnknown 

func (m *NodePoolConfiguration) XXX_DiscardUnknown()

func (*NodePoolConfiguration) XXX_Marshal 

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

func (*NodePoolConfiguration) XXX_Merge 

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

func (*NodePoolConfiguration) XXX_Size 

func (m *NodePoolConfiguration) XXX_Size() int

func (*NodePoolConfiguration) XXX_Unmarshal 

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

type NodeRequest 

type NodeRequest struct {
	Nodes                []*Node          `protobuf:"bytes,1,rep,name=Nodes,proto3" json:"Nodes,omitempty"`
	OperationType        common.Operation `protobuf:"varint,2,opt,name=OperationType,proto3,enum=moc.Operation" json:"OperationType,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*NodeRequest) Descriptor 

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

func (*NodeRequest) GetNodes 

func (m *NodeRequest) GetNodes() []*Node

func (*NodeRequest) GetOperationType 

func (m *NodeRequest) GetOperationType() common.Operation

func (*NodeRequest) ProtoMessage 

func (*NodeRequest) ProtoMessage()

func (*NodeRequest) Reset 

func (m *NodeRequest) Reset()

func (*NodeRequest) String 

func (m *NodeRequest) String() string

func (*NodeRequest) XXX_DiscardUnknown 

func (m *NodeRequest) XXX_DiscardUnknown()

func (*NodeRequest) XXX_Marshal 

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

func (*NodeRequest) XXX_Merge 

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

func (*NodeRequest) XXX_Size 

func (m *NodeRequest) XXX_Size() int

func (*NodeRequest) XXX_Unmarshal 

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

type NodeResponse 

type NodeResponse struct {
	Nodes                []*Node             `protobuf:"bytes,1,rep,name=Nodes,proto3" json:"Nodes,omitempty"`
	Result               *wrappers.BoolValue `protobuf:"bytes,2,opt,name=Result,proto3" json:"Result,omitempty"`
	Error                string              `protobuf:"bytes,3,opt,name=Error,proto3" json:"Error,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*NodeResponse) Descriptor 

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

func (*NodeResponse) GetError 

func (m *NodeResponse) GetError() string

func (*NodeResponse) GetNodes 

func (m *NodeResponse) GetNodes() []*Node

func (*NodeResponse) GetResult 

func (m *NodeResponse) GetResult() *wrappers.BoolValue

func (*NodeResponse) ProtoMessage 

func (*NodeResponse) ProtoMessage()

func (*NodeResponse) Reset 

func (m *NodeResponse) Reset()

func (*NodeResponse) String 

func (m *NodeResponse) String() string

func (*NodeResponse) XXX_DiscardUnknown 

func (m *NodeResponse) XXX_DiscardUnknown()

func (*NodeResponse) XXX_Marshal 

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

func (*NodeResponse) XXX_Merge 

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

func (*NodeResponse) XXX_Size 

func (m *NodeResponse) XXX_Size() int

func (*NodeResponse) XXX_Unmarshal 

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

type NodeState 

type NodeState int32
const (
	NodeState_Unknown  NodeState = 0
	NodeState_Active   NodeState = 1
	NodeState_Inactive NodeState = 2
)

func (NodeState) EnumDescriptor 

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

func (NodeState) String 

func (x NodeState) String() string

type NodeType 

type NodeType int32
const (
	NodeType_ControlPlane  NodeType = 0
	NodeType_LinuxWorker   NodeType = 1
	NodeType_WindowsWorker NodeType = 2
	NodeType_LoadBalancer  NodeType = 3
)

func (NodeType) EnumDescriptor 

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

func (NodeType) String 

func (x NodeType) String() string

type SSHPublicKey 

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

func (*SSHPublicKey) Descriptor 

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

func (*SSHPublicKey) GetKeyData 

func (m *SSHPublicKey) GetKeyData() string

func (*SSHPublicKey) ProtoMessage 

func (*SSHPublicKey) ProtoMessage()

func (*SSHPublicKey) Reset 

func (m *SSHPublicKey) Reset()

func (*SSHPublicKey) String 

func (m *SSHPublicKey) String() string

func (*SSHPublicKey) XXX_DiscardUnknown 

func (m *SSHPublicKey) XXX_DiscardUnknown()

func (*SSHPublicKey) XXX_Marshal 

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

func (*SSHPublicKey) XXX_Merge 

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

func (*SSHPublicKey) XXX_Size 

func (m *SSHPublicKey) XXX_Size() int

func (*SSHPublicKey) XXX_Unmarshal 

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

type StorageConfiguration 

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

func (*StorageConfiguration) Descriptor 

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

func (*StorageConfiguration) GetCsi 

func (m *StorageConfiguration) GetCsi() string

func (*StorageConfiguration) ProtoMessage 

func (*StorageConfiguration) ProtoMessage()

func (*StorageConfiguration) Reset 

func (m *StorageConfiguration) Reset()

func (*StorageConfiguration) String 

func (m *StorageConfiguration) String() string

func (*StorageConfiguration) XXX_DiscardUnknown 

func (m *StorageConfiguration) XXX_DiscardUnknown()

func (*StorageConfiguration) XXX_Marshal 

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

func (*StorageConfiguration) XXX_Merge 

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

func (*StorageConfiguration) XXX_Size 

func (m *StorageConfiguration) XXX_Size() int

func (*StorageConfiguration) XXX_Unmarshal 

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

type SubPostOperation 

type SubPostOperation int32
const (
	SubPostOperation_CREATE SubPostOperation = 0
	SubPostOperation_UPDATE SubPostOperation = 1
	SubPostOperation_LOCK   SubPostOperation = 2
)

func (SubPostOperation) EnumDescriptor 

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

func (SubPostOperation) String 

func (x SubPostOperation) String() string

type Subscription 

type Subscription struct {
	Name                 string         `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Id                   string         `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	Status               *common.Status `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"`
	Tags                 *common.Tags   `protobuf:"bytes,4,opt,name=tags,proto3" json:"tags,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*Subscription) Descriptor 

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

func (*Subscription) GetId 

func (m *Subscription) GetId() string

func (*Subscription) GetName 

func (m *Subscription) GetName() string

func (*Subscription) GetStatus 

func (m *Subscription) GetStatus() *common.Status

func (*Subscription) GetTags added in v0.10.5 

func (m *Subscription) GetTags() *common.Tags

func (*Subscription) ProtoMessage 

func (*Subscription) ProtoMessage()

func (*Subscription) Reset 

func (m *Subscription) Reset()

func (*Subscription) String 

func (m *Subscription) String() string

func (*Subscription) XXX_DiscardUnknown 

func (m *Subscription) XXX_DiscardUnknown()

func (*Subscription) XXX_Marshal 

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

func (*Subscription) XXX_Merge 

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

func (*Subscription) XXX_Size 

func (m *Subscription) XXX_Size() int

func (*Subscription) XXX_Unmarshal 

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

type SubscriptionAgentClient 

type SubscriptionAgentClient interface {
	Invoke(ctx context.Context, in *SubscriptionRequest, opts ...grpc.CallOption) (*SubscriptionResponse, error)
}

SubscriptionAgentClient is the client API for SubscriptionAgent service.

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

func NewSubscriptionAgentClient 

func NewSubscriptionAgentClient(cc *grpc.ClientConn) SubscriptionAgentClient

type SubscriptionAgentServer 

type SubscriptionAgentServer interface {
	Invoke(context.Context, *SubscriptionRequest) (*SubscriptionResponse, error)
}

SubscriptionAgentServer is the server API for SubscriptionAgent service.

type SubscriptionRequest 

type SubscriptionRequest struct {
	Subscriptions        []*Subscription  `protobuf:"bytes,1,rep,name=Subscriptions,proto3" json:"Subscriptions,omitempty"`
	OperationType        common.Operation `protobuf:"varint,2,opt,name=OperationType,proto3,enum=moc.Operation" json:"OperationType,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*SubscriptionRequest) Descriptor 

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

func (*SubscriptionRequest) GetOperationType 

func (m *SubscriptionRequest) GetOperationType() common.Operation

func (*SubscriptionRequest) GetSubscriptions 

func (m *SubscriptionRequest) GetSubscriptions() []*Subscription

func (*SubscriptionRequest) ProtoMessage 

func (*SubscriptionRequest) ProtoMessage()

func (*SubscriptionRequest) Reset 

func (m *SubscriptionRequest) Reset()

func (*SubscriptionRequest) String 

func (m *SubscriptionRequest) String() string

func (*SubscriptionRequest) XXX_DiscardUnknown 

func (m *SubscriptionRequest) XXX_DiscardUnknown()

func (*SubscriptionRequest) XXX_Marshal 

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

func (*SubscriptionRequest) XXX_Merge 

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

func (*SubscriptionRequest) XXX_Size 

func (m *SubscriptionRequest) XXX_Size() int

func (*SubscriptionRequest) XXX_Unmarshal 

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

type SubscriptionResponse 

type SubscriptionResponse struct {
	Subscriptions        []*Subscription     `protobuf:"bytes,1,rep,name=Subscriptions,proto3" json:"Subscriptions,omitempty"`
	Result               *wrappers.BoolValue `protobuf:"bytes,2,opt,name=Result,proto3" json:"Result,omitempty"`
	Error                string              `protobuf:"bytes,3,opt,name=Error,proto3" json:"Error,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*SubscriptionResponse) Descriptor 

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

func (*SubscriptionResponse) GetError 

func (m *SubscriptionResponse) GetError() string

func (*SubscriptionResponse) GetResult 

func (m *SubscriptionResponse) GetResult() *wrappers.BoolValue

func (*SubscriptionResponse) GetSubscriptions 

func (m *SubscriptionResponse) GetSubscriptions() []*Subscription

func (*SubscriptionResponse) ProtoMessage 

func (*SubscriptionResponse) ProtoMessage()

func (*SubscriptionResponse) Reset 

func (m *SubscriptionResponse) Reset()

func (*SubscriptionResponse) String 

func (m *SubscriptionResponse) String() string

func (*SubscriptionResponse) XXX_DiscardUnknown 

func (m *SubscriptionResponse) XXX_DiscardUnknown()

func (*SubscriptionResponse) XXX_Marshal 

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

func (*SubscriptionResponse) XXX_Merge 

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

func (*SubscriptionResponse) XXX_Size 

func (m *SubscriptionResponse) XXX_Size() int

func (*SubscriptionResponse) XXX_Unmarshal 

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

type UnimplementedClusterAgentServer 

type UnimplementedClusterAgentServer struct {
}

UnimplementedClusterAgentServer can be embedded to have forward compatible implementations.

func (*UnimplementedClusterAgentServer) GetCluster 

func (*UnimplementedClusterAgentServer) GetCluster(ctx context.Context, req *Cluster) (*ClusterResponse, error)

func (*UnimplementedClusterAgentServer) GetNodes 

func (*UnimplementedClusterAgentServer) GetNodes(ctx context.Context, req *Cluster) (*NodeResponse, error)

func (*UnimplementedClusterAgentServer) LoadCluster 

func (*UnimplementedClusterAgentServer) LoadCluster(ctx context.Context, req *Cluster) (*ClusterResponse, error)

func (*UnimplementedClusterAgentServer) UnloadCluster 

func (*UnimplementedClusterAgentServer) UnloadCluster(ctx context.Context, req *Cluster) (*ClusterResponse, error)

type UnimplementedControlPlaneAgentServer added in v0.10.6 

type UnimplementedControlPlaneAgentServer struct {
}

UnimplementedControlPlaneAgentServer can be embedded to have forward compatible implementations.

func (*UnimplementedControlPlaneAgentServer) Invoke added in v0.10.6 

func (*UnimplementedControlPlaneAgentServer) Invoke(ctx context.Context, req *ControlPlaneRequest) (*ControlPlaneResponse, error)

type UnimplementedEtcdClusterAgentServer added in v0.10.6 

type UnimplementedEtcdClusterAgentServer struct {
}

UnimplementedEtcdClusterAgentServer can be embedded to have forward compatible implementations.

func (*UnimplementedEtcdClusterAgentServer) Invoke added in v0.10.6 

func (*UnimplementedEtcdClusterAgentServer) Invoke(ctx context.Context, req *EtcdClusterRequest) (*EtcdClusterResponse, error)

type UnimplementedEtcdServerAgentServer added in v0.10.6 

type UnimplementedEtcdServerAgentServer struct {
}

UnimplementedEtcdServerAgentServer can be embedded to have forward compatible implementations.

func (*UnimplementedEtcdServerAgentServer) Invoke added in v0.10.6 

func (*UnimplementedEtcdServerAgentServer) Invoke(ctx context.Context, req *EtcdServerRequest) (*EtcdServerResponse, error)

type UnimplementedGroupAgentServer 

type UnimplementedGroupAgentServer struct {
}

UnimplementedGroupAgentServer can be embedded to have forward compatible implementations.

func (*UnimplementedGroupAgentServer) Invoke 

func (*UnimplementedGroupAgentServer) Invoke(ctx context.Context, req *GroupRequest) (*GroupResponse, error)

type UnimplementedKubernetesAgentServer 

type UnimplementedKubernetesAgentServer struct {
}

UnimplementedKubernetesAgentServer can be embedded to have forward compatible implementations.

func (*UnimplementedKubernetesAgentServer) Invoke 

func (*UnimplementedKubernetesAgentServer) Invoke(ctx context.Context, req *KubernetesRequest) (*KubernetesResponse, error)

type UnimplementedLocationAgentServer 

type UnimplementedLocationAgentServer struct {
}

UnimplementedLocationAgentServer can be embedded to have forward compatible implementations.

func (*UnimplementedLocationAgentServer) Invoke 

func (*UnimplementedLocationAgentServer) Invoke(ctx context.Context, req *LocationRequest) (*LocationResponse, error)

type UnimplementedNodeAgentServer 

type UnimplementedNodeAgentServer struct {
}

UnimplementedNodeAgentServer can be embedded to have forward compatible implementations.

func (*UnimplementedNodeAgentServer) Invoke 

func (*UnimplementedNodeAgentServer) Invoke(ctx context.Context, req *NodeRequest) (*NodeResponse, error)

type UnimplementedSubscriptionAgentServer 

type UnimplementedSubscriptionAgentServer struct {
}

UnimplementedSubscriptionAgentServer can be embedded to have forward compatible implementations.

func (*UnimplementedSubscriptionAgentServer) Invoke 

func (*UnimplementedSubscriptionAgentServer) Invoke(ctx context.Context, req *SubscriptionRequest) (*SubscriptionResponse, 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.