controlplane

package
v0.1.0 Latest Latest
Warning

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

 Go to latest Published: Jun 22, 2020 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_controlplane_cluster_operations_proto protoreflect.FileDescriptor
View Source 
var File_controlplane_scenario_proto protoreflect.FileDescriptor
View Source 
var File_controlplane_status_proto protoreflect.FileDescriptor

Functions

func RegisterClusterOperationsServer 

func RegisterClusterOperationsServer(s *grpc.Server, srv ClusterOperationsServer)

func RegisterScenarioServer 

func RegisterScenarioServer(s *grpc.Server, srv ScenarioServer)

func RegisterStatusServer 

func RegisterStatusServer(s *grpc.Server, srv StatusServer)

Types

type ApateletInformation 

type ApateletInformation struct {

	// The port of the apatelet api
	Port int32 `protobuf:"varint,1,opt,name=port,proto3" json:"port,omitempty"`
	// contains filtered or unexported fields
}

func (*ApateletInformation) Descriptor deprecated 

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

Deprecated: Use ApateletInformation.ProtoReflect.Descriptor instead.

func (*ApateletInformation) GetPort 

func (x *ApateletInformation) GetPort() int32

func (*ApateletInformation) ProtoMessage 

func (*ApateletInformation) ProtoMessage()

func (*ApateletInformation) ProtoReflect 

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

func (*ApateletInformation) Reset 

func (x *ApateletInformation) Reset()

func (*ApateletInformation) String 

func (x *ApateletInformation) String() string

type ClusterOperationsClient 

type ClusterOperationsClient interface {
	// Joins the node to the Apate cluster.
	// Will return information needed to identify yourself
	// And to join the kubernetes cluster.
	JoinCluster(ctx context.Context, in *ApateletInformation, opts ...grpc.CallOption) (*JoinInformation, error)
	// Removes the node from the cluster
	LeaveCluster(ctx context.Context, in *LeaveInformation, opts ...grpc.CallOption) (*empty.Empty, error)
	// Returns the kube config file
	GetKubeConfig(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*KubeConfig, error)
}

ClusterOperationsClient is the client API for ClusterOperations service.

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

func NewClusterOperationsClient 

func NewClusterOperationsClient(cc grpc.ClientConnInterface) ClusterOperationsClient

type ClusterOperationsServer 

type ClusterOperationsServer interface {
	// Joins the node to the Apate cluster.
	// Will return information needed to identify yourself
	// And to join the kubernetes cluster.
	JoinCluster(context.Context, *ApateletInformation) (*JoinInformation, error)
	// Removes the node from the cluster
	LeaveCluster(context.Context, *LeaveInformation) (*empty.Empty, error)
	// Returns the kube config file
	GetKubeConfig(context.Context, *empty.Empty) (*KubeConfig, error)
}

ClusterOperationsServer is the server API for ClusterOperations service.

type ClusterStatus 

type ClusterStatus struct {
	HealthyNodes int32 `protobuf:"varint,1,opt,name=healthy_nodes,json=healthyNodes,proto3" json:"healthy_nodes,omitempty"`
	// contains filtered or unexported fields
}

func (*ClusterStatus) Descriptor deprecated 

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

Deprecated: Use ClusterStatus.ProtoReflect.Descriptor instead.

func (*ClusterStatus) GetHealthyNodes 

func (x *ClusterStatus) GetHealthyNodes() int32

func (*ClusterStatus) ProtoMessage 

func (*ClusterStatus) ProtoMessage()

func (*ClusterStatus) ProtoReflect 

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

func (*ClusterStatus) Reset 

func (x *ClusterStatus) Reset()

func (*ClusterStatus) String 

func (x *ClusterStatus) String() string

type JoinInformation 

type JoinInformation struct {

	// The kube config which can be used to join the kubernetes cluster
	KubeConfig []byte `protobuf:"bytes,1,opt,name=kube_config,json=kubeConfig,proto3" json:"kube_config,omitempty"`
	// The UUID that will be used from the control plane to identify this node
	NodeUuid string `protobuf:"bytes,2,opt,name=node_uuid,json=nodeUuid,proto3" json:"node_uuid,omitempty"`
	// The label of the node
	NodeLabel string `protobuf:"bytes,3,opt,name=node_label,json=nodeLabel,proto3" json:"node_label,omitempty"`
	// Start time if scenario already started
	StartTime int64 `protobuf:"varint,4,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	// The hardware that was 'allocated' to the apatelet
	Hardware *NodeHardware `protobuf:"bytes,5,opt,name=hardware,proto3" json:"hardware,omitempty"`
	// contains filtered or unexported fields
}

func (*JoinInformation) Descriptor deprecated 

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

Deprecated: Use JoinInformation.ProtoReflect.Descriptor instead.

func (*JoinInformation) GetHardware 

func (x *JoinInformation) GetHardware() *NodeHardware

func (*JoinInformation) GetKubeConfig 

func (x *JoinInformation) GetKubeConfig() []byte

func (*JoinInformation) GetNodeLabel 

func (x *JoinInformation) GetNodeLabel() string

func (*JoinInformation) GetNodeUuid 

func (x *JoinInformation) GetNodeUuid() string

func (*JoinInformation) GetStartTime 

func (x *JoinInformation) GetStartTime() int64

func (*JoinInformation) ProtoMessage 

func (*JoinInformation) ProtoMessage()

func (*JoinInformation) ProtoReflect 

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

func (*JoinInformation) Reset 

func (x *JoinInformation) Reset()

func (*JoinInformation) String 

func (x *JoinInformation) String() string

type KubeConfig 

type KubeConfig struct {

	// The kube config
	Config []byte `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
	// contains filtered or unexported fields
}

func (*KubeConfig) Descriptor deprecated 

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

Deprecated: Use KubeConfig.ProtoReflect.Descriptor instead.

func (*KubeConfig) GetConfig 

func (x *KubeConfig) GetConfig() []byte

func (*KubeConfig) ProtoMessage 

func (*KubeConfig) ProtoMessage()

func (*KubeConfig) ProtoReflect 

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

func (*KubeConfig) Reset 

func (x *KubeConfig) Reset()

func (*KubeConfig) String 

func (x *KubeConfig) String() string

type LeaveInformation 

type LeaveInformation struct {

	// The UUID that is be used from the control plane to identify this node
	NodeUuid string `protobuf:"bytes,1,opt,name=node_uuid,json=nodeUuid,proto3" json:"node_uuid,omitempty"`
	// contains filtered or unexported fields
}

func (*LeaveInformation) Descriptor deprecated 

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

Deprecated: Use LeaveInformation.ProtoReflect.Descriptor instead.

func (*LeaveInformation) GetNodeUuid 

func (x *LeaveInformation) GetNodeUuid() string

func (*LeaveInformation) ProtoMessage 

func (*LeaveInformation) ProtoMessage()

func (*LeaveInformation) ProtoReflect 

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

func (*LeaveInformation) Reset 

func (x *LeaveInformation) Reset()

func (*LeaveInformation) String 

func (x *LeaveInformation) String() string

type NodeHardware 

type NodeHardware struct {

	// The amount of bytes of memory
	Memory int64 `protobuf:"varint,1,opt,name=memory,proto3" json:"memory,omitempty"`
	// The amount of milli CPUs in Kubernetes
	Cpu int64 `protobuf:"varint,2,opt,name=cpu,proto3" json:"cpu,omitempty"`
	// The amount of bytes of storage
	Storage int64 `protobuf:"varint,3,opt,name=storage,proto3" json:"storage,omitempty"`
	// The amount of bytes of ephemeral storage
	EphemeralStorage int64 `protobuf:"varint,4,opt,name=ephemeral_storage,json=ephemeralStorage,proto3" json:"ephemeral_storage,omitempty"`
	// The max amount of pods in Kubernetes
	MaxPods int64 `protobuf:"varint,5,opt,name=max_pods,json=maxPods,proto3" json:"max_pods,omitempty"`
	// contains filtered or unexported fields
}

func (*NodeHardware) Descriptor deprecated 

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

Deprecated: Use NodeHardware.ProtoReflect.Descriptor instead.

func (*NodeHardware) GetCpu 

func (x *NodeHardware) GetCpu() int64

func (*NodeHardware) GetEphemeralStorage 

func (x *NodeHardware) GetEphemeralStorage() int64

func (*NodeHardware) GetMaxPods 

func (x *NodeHardware) GetMaxPods() int64

func (*NodeHardware) GetMemory 

func (x *NodeHardware) GetMemory() int64

func (*NodeHardware) GetStorage 

func (x *NodeHardware) GetStorage() int64

func (*NodeHardware) ProtoMessage 

func (*NodeHardware) ProtoMessage()

func (*NodeHardware) ProtoReflect 

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

func (*NodeHardware) Reset 

func (x *NodeHardware) Reset()

func (*NodeHardware) String 

func (x *NodeHardware) String() string

type ScenarioClient 

type ScenarioClient interface {
	StartScenario(ctx context.Context, in *StartScenario, opts ...grpc.CallOption) (*empty.Empty, error)
}

ScenarioClient is the client API for Scenario service.

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

func NewScenarioClient 

func NewScenarioClient(cc grpc.ClientConnInterface) ScenarioClient

type ScenarioServer 

type ScenarioServer interface {
	StartScenario(context.Context, *StartScenario) (*empty.Empty, error)
}

ScenarioServer is the server API for Scenario service.

type StartScenario 

type StartScenario struct {

	// Whether to disable watchers before starting the scenario.
	// This will reduce the overhead of the informers significantly.
	// Enabling this option will require a restart before the informers will work again
	DisableWatchers bool `protobuf:"varint,1,opt,name=disable_watchers,json=disableWatchers,proto3" json:"disable_watchers,omitempty"`
	// contains filtered or unexported fields
}

The top level object which defines how the different Apatelet will emulate certain deployments

func (*StartScenario) Descriptor deprecated 

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

Deprecated: Use StartScenario.ProtoReflect.Descriptor instead.

func (*StartScenario) GetDisableWatchers 

func (x *StartScenario) GetDisableWatchers() bool

func (*StartScenario) ProtoMessage 

func (*StartScenario) ProtoMessage()

func (*StartScenario) ProtoReflect 

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

func (*StartScenario) Reset 

func (x *StartScenario) Reset()

func (*StartScenario) String 

func (x *StartScenario) String() string

type StatusClient 

type StatusClient interface {
	Status(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*ClusterStatus, error)
}

StatusClient is the client API for Status service.

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

func NewStatusClient 

func NewStatusClient(cc grpc.ClientConnInterface) StatusClient

type StatusServer 

type StatusServer interface {
	Status(context.Context, *empty.Empty) (*ClusterStatus, error)
}

StatusServer is the server API for Status service.

type UnimplementedClusterOperationsServer 

type UnimplementedClusterOperationsServer struct {
}

UnimplementedClusterOperationsServer can be embedded to have forward compatible implementations.

func (*UnimplementedClusterOperationsServer) GetKubeConfig 

func (*UnimplementedClusterOperationsServer) GetKubeConfig(context.Context, *empty.Empty) (*KubeConfig, error)

func (*UnimplementedClusterOperationsServer) JoinCluster 

func (*UnimplementedClusterOperationsServer) JoinCluster(context.Context, *ApateletInformation) (*JoinInformation, error)

func (*UnimplementedClusterOperationsServer) LeaveCluster 

func (*UnimplementedClusterOperationsServer) LeaveCluster(context.Context, *LeaveInformation) (*empty.Empty, error)

type UnimplementedScenarioServer 

type UnimplementedScenarioServer struct {
}

UnimplementedScenarioServer can be embedded to have forward compatible implementations.

func (*UnimplementedScenarioServer) StartScenario 

func (*UnimplementedScenarioServer) StartScenario(context.Context, *StartScenario) (*empty.Empty, error)

type UnimplementedStatusServer 

type UnimplementedStatusServer struct {
}

UnimplementedStatusServer can be embedded to have forward compatible implementations.

func (*UnimplementedStatusServer) Status 

func (*UnimplementedStatusServer) Status(context.Context, *empty.Empty) (*ClusterStatus, 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.