controller

package
v0.1.2 Latest Latest
Warning

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

 Go to latest Published: Jun 30, 2022 License: Apache-2.0 Imports: 9 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ClusterState_name = map[int32]string{
		0: "CLUSTER_STATE_UNKNOWN",
		1: "CLUSTER_STATE_CREATING",
		2: "CLUSTER_STATE_RUNNING",
		3: "CLUSTER_STATE_ERROR",
	}
	ClusterState_value = map[string]int32{
		"CLUSTER_STATE_UNKNOWN":  0,
		"CLUSTER_STATE_CREATING": 1,
		"CLUSTER_STATE_RUNNING":  2,
		"CLUSTER_STATE_ERROR":    3,
	}
)

Enum value maps for ClusterState.

View Source 
var (
	TopologyState_name = map[int32]string{
		0: "TOPOLOGY_STATE_UNKNOWN",
		1: "TOPOLOGY_STATE_CREATING",
		2: "TOPOLOGY_STATE_RUNNING",
		3: "TOPOLOGY_STATE_ERROR",
	}
	TopologyState_value = map[string]int32{
		"TOPOLOGY_STATE_UNKNOWN":  0,
		"TOPOLOGY_STATE_CREATING": 1,
		"TOPOLOGY_STATE_RUNNING":  2,
		"TOPOLOGY_STATE_ERROR":    3,
	}
)

Enum value maps for TopologyState.

View Source 
var File_controller_proto protoreflect.FileDescriptor
View Source 
var TopologyManager_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "controller.TopologyManager",
	HandlerType: (*TopologyManagerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateTopology",
			Handler:    _TopologyManager_CreateTopology_Handler,
		},
		{
			MethodName: "DeleteTopology",
			Handler:    _TopologyManager_DeleteTopology_Handler,
		},
		{
			MethodName: "ShowTopology",
			Handler:    _TopologyManager_ShowTopology_Handler,
		},
		{
			MethodName: "CreateCluster",
			Handler:    _TopologyManager_CreateCluster_Handler,
		},
		{
			MethodName: "DeleteCluster",
			Handler:    _TopologyManager_DeleteCluster_Handler,
		},
		{
			MethodName: "ShowCluster",
			Handler:    _TopologyManager_ShowCluster_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "controller.proto",
}

TopologyManager_ServiceDesc is the grpc.ServiceDesc for TopologyManager service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterTopologyManagerServer 

func RegisterTopologyManagerServer(s grpc.ServiceRegistrar, srv TopologyManagerServer)

Types

type ClusterState 

type ClusterState int32
const (
	ClusterState_CLUSTER_STATE_UNKNOWN  ClusterState = 0
	ClusterState_CLUSTER_STATE_CREATING ClusterState = 1
	ClusterState_CLUSTER_STATE_RUNNING  ClusterState = 2
	ClusterState_CLUSTER_STATE_ERROR    ClusterState = 3
)

func (ClusterState) Descriptor 

func (ClusterState) Descriptor() protoreflect.EnumDescriptor

func (ClusterState) Enum 

func (x ClusterState) Enum() *ClusterState

func (ClusterState) EnumDescriptor deprecated 

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

Deprecated: Use ClusterState.Descriptor instead.

func (ClusterState) Number 

func (x ClusterState) Number() protoreflect.EnumNumber

func (ClusterState) String 

func (x ClusterState) String() string

func (ClusterState) Type 

func (ClusterState) Type() protoreflect.EnumType

type ControllerSpec 

type ControllerSpec struct {

	// Types that are assignable to Spec:
	//	*ControllerSpec_Ixiatg
	Spec isControllerSpec_Spec `protobuf_oneof:"spec"`
	// contains filtered or unexported fields
}

Controller specifications

func (*ControllerSpec) Descriptor deprecated 

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

Deprecated: Use ControllerSpec.ProtoReflect.Descriptor instead.

func (*ControllerSpec) GetIxiatg 

func (x *ControllerSpec) GetIxiatg() *IxiaTGSpec

func (*ControllerSpec) GetSpec 

func (m *ControllerSpec) GetSpec() isControllerSpec_Spec

func (*ControllerSpec) ProtoMessage 

func (*ControllerSpec) ProtoMessage()

func (*ControllerSpec) ProtoReflect 

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

func (*ControllerSpec) Reset 

func (x *ControllerSpec) Reset()

func (*ControllerSpec) String 

func (x *ControllerSpec) String() string

type ControllerSpec_Ixiatg 

type ControllerSpec_Ixiatg struct {
	Ixiatg *IxiaTGSpec `protobuf:"bytes,1,opt,name=ixiatg,proto3,oneof"`
}

type CreateClusterRequest 

type CreateClusterRequest struct {

	// Types that are assignable to ClusterSpec:
	//	*CreateClusterRequest_Kind
	ClusterSpec isCreateClusterRequest_ClusterSpec `protobuf_oneof:"cluster_spec"`
	// Types that are assignable to IngressSpec:
	//	*CreateClusterRequest_Metallb
	IngressSpec isCreateClusterRequest_IngressSpec `protobuf_oneof:"ingress_spec"`
	// Types that are assignable to CniSpec:
	//	*CreateClusterRequest_Meshnet
	CniSpec         isCreateClusterRequest_CniSpec `protobuf_oneof:"cni_spec"`
	ControllerSpecs []*ControllerSpec              `protobuf:"bytes,4,rep,name=controller_specs,json=controllerSpecs,proto3" json:"controller_specs,omitempty"`
	// contains filtered or unexported fields
}

Request message to create a cluster.

func (*CreateClusterRequest) Descriptor deprecated 

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

Deprecated: Use CreateClusterRequest.ProtoReflect.Descriptor instead.

func (*CreateClusterRequest) GetClusterSpec 

func (m *CreateClusterRequest) GetClusterSpec() isCreateClusterRequest_ClusterSpec

func (*CreateClusterRequest) GetCniSpec 

func (m *CreateClusterRequest) GetCniSpec() isCreateClusterRequest_CniSpec

func (*CreateClusterRequest) GetControllerSpecs 

func (x *CreateClusterRequest) GetControllerSpecs() []*ControllerSpec

func (*CreateClusterRequest) GetIngressSpec 

func (m *CreateClusterRequest) GetIngressSpec() isCreateClusterRequest_IngressSpec

func (*CreateClusterRequest) GetKind 

func (x *CreateClusterRequest) GetKind() *KindSpec

func (*CreateClusterRequest) GetMeshnet 

func (x *CreateClusterRequest) GetMeshnet() *MeshnetSpec

func (*CreateClusterRequest) GetMetallb 

func (x *CreateClusterRequest) GetMetallb() *MetallbSpec

func (*CreateClusterRequest) ProtoMessage 

func (*CreateClusterRequest) ProtoMessage()

func (*CreateClusterRequest) ProtoReflect 

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

func (*CreateClusterRequest) Reset 

func (x *CreateClusterRequest) Reset()

func (*CreateClusterRequest) String 

func (x *CreateClusterRequest) String() string

type CreateClusterRequest_Kind 

type CreateClusterRequest_Kind struct {
	Kind *KindSpec `protobuf:"bytes,1,opt,name=kind,proto3,oneof"`
}

type CreateClusterRequest_Meshnet 

type CreateClusterRequest_Meshnet struct {
	Meshnet *MeshnetSpec `protobuf:"bytes,3,opt,name=meshnet,proto3,oneof"`
}

type CreateClusterRequest_Metallb 

type CreateClusterRequest_Metallb struct {
	Metallb *MetallbSpec `protobuf:"bytes,2,opt,name=metallb,proto3,oneof"`
}

type CreateClusterResponse 

type CreateClusterResponse struct {
	Name  string       `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	State ClusterState `protobuf:"varint,2,opt,name=state,proto3,enum=controller.ClusterState" json:"state,omitempty"`
	// contains filtered or unexported fields
}

Returns create cluster response.

func (*CreateClusterResponse) Descriptor deprecated 

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

Deprecated: Use CreateClusterResponse.ProtoReflect.Descriptor instead.

func (*CreateClusterResponse) GetName 

func (x *CreateClusterResponse) GetName() string

func (*CreateClusterResponse) GetState 

func (x *CreateClusterResponse) GetState() ClusterState

func (*CreateClusterResponse) ProtoMessage 

func (*CreateClusterResponse) ProtoMessage()

func (*CreateClusterResponse) ProtoReflect 

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

func (*CreateClusterResponse) Reset 

func (x *CreateClusterResponse) Reset()

func (*CreateClusterResponse) String 

func (x *CreateClusterResponse) String() string

type CreateTopologyRequest 

type CreateTopologyRequest struct {
	Topology *topo.Topology `protobuf:"bytes,1,opt,name=topology,proto3" json:"topology,omitempty"`
	Kubecfg  string         `protobuf:"bytes,2,opt,name=kubecfg,proto3" json:"kubecfg,omitempty"`
	// contains filtered or unexported fields
}

Request message to create a topology.

func (*CreateTopologyRequest) Descriptor deprecated 

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

Deprecated: Use CreateTopologyRequest.ProtoReflect.Descriptor instead.

func (*CreateTopologyRequest) GetKubecfg 

func (x *CreateTopologyRequest) GetKubecfg() string

func (*CreateTopologyRequest) GetTopology 

func (x *CreateTopologyRequest) GetTopology() *topo.Topology

func (*CreateTopologyRequest) ProtoMessage 

func (*CreateTopologyRequest) ProtoMessage()

func (*CreateTopologyRequest) ProtoReflect 

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

func (*CreateTopologyRequest) Reset 

func (x *CreateTopologyRequest) Reset()

func (*CreateTopologyRequest) String 

func (x *CreateTopologyRequest) String() string

type CreateTopologyResponse 

type CreateTopologyResponse struct {
	TopologyName string        `protobuf:"bytes,1,opt,name=topology_name,json=topologyName,proto3" json:"topology_name,omitempty"`
	State        TopologyState `protobuf:"varint,2,opt,name=state,proto3,enum=controller.TopologyState" json:"state,omitempty"`
	// contains filtered or unexported fields
}

Returns create topology response.

func (*CreateTopologyResponse) Descriptor deprecated 

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

Deprecated: Use CreateTopologyResponse.ProtoReflect.Descriptor instead.

func (*CreateTopologyResponse) GetState 

func (x *CreateTopologyResponse) GetState() TopologyState

func (*CreateTopologyResponse) GetTopologyName 

func (x *CreateTopologyResponse) GetTopologyName() string

func (*CreateTopologyResponse) ProtoMessage 

func (*CreateTopologyResponse) ProtoMessage()

func (*CreateTopologyResponse) ProtoReflect 

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

func (*CreateTopologyResponse) Reset 

func (x *CreateTopologyResponse) Reset()

func (*CreateTopologyResponse) String 

func (x *CreateTopologyResponse) String() string

type DeleteClusterRequest 

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

Request message to delete a cluster.

func (*DeleteClusterRequest) Descriptor deprecated 

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

Deprecated: Use DeleteClusterRequest.ProtoReflect.Descriptor instead.

func (*DeleteClusterRequest) GetName 

func (x *DeleteClusterRequest) GetName() string

func (*DeleteClusterRequest) ProtoMessage 

func (*DeleteClusterRequest) ProtoMessage()

func (*DeleteClusterRequest) ProtoReflect 

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

func (*DeleteClusterRequest) Reset 

func (x *DeleteClusterRequest) Reset()

func (*DeleteClusterRequest) String 

func (x *DeleteClusterRequest) String() string

type DeleteClusterResponse 

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

Returns delete cluster response.

func (*DeleteClusterResponse) Descriptor deprecated 

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

Deprecated: Use DeleteClusterResponse.ProtoReflect.Descriptor instead.

func (*DeleteClusterResponse) ProtoMessage 

func (*DeleteClusterResponse) ProtoMessage()

func (*DeleteClusterResponse) ProtoReflect 

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

func (*DeleteClusterResponse) Reset 

func (x *DeleteClusterResponse) Reset()

func (*DeleteClusterResponse) String 

func (x *DeleteClusterResponse) String() string

type DeleteTopologyRequest 

type DeleteTopologyRequest struct {
	TopologyName string `protobuf:"bytes,1,opt,name=topology_name,json=topologyName,proto3" json:"topology_name,omitempty"`
	// contains filtered or unexported fields
}

Request message to delete a topology.

func (*DeleteTopologyRequest) Descriptor deprecated 

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

Deprecated: Use DeleteTopologyRequest.ProtoReflect.Descriptor instead.

func (*DeleteTopologyRequest) GetTopologyName 

func (x *DeleteTopologyRequest) GetTopologyName() string

func (*DeleteTopologyRequest) ProtoMessage 

func (*DeleteTopologyRequest) ProtoMessage()

func (*DeleteTopologyRequest) ProtoReflect 

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

func (*DeleteTopologyRequest) Reset 

func (x *DeleteTopologyRequest) Reset()

func (*DeleteTopologyRequest) String 

func (x *DeleteTopologyRequest) String() string

type DeleteTopologyResponse 

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

Returns delete topology response.

func (*DeleteTopologyResponse) Descriptor deprecated 

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

Deprecated: Use DeleteTopologyResponse.ProtoReflect.Descriptor instead.

func (*DeleteTopologyResponse) ProtoMessage 

func (*DeleteTopologyResponse) ProtoMessage()

func (*DeleteTopologyResponse) ProtoReflect 

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

func (*DeleteTopologyResponse) Reset 

func (x *DeleteTopologyResponse) Reset()

func (*DeleteTopologyResponse) String 

func (x *DeleteTopologyResponse) String() string

type IxiaTGConfigMap 

type IxiaTGConfigMap struct {
	Release string         `protobuf:"bytes,1,opt,name=release,proto3" json:"release,omitempty"`
	Images  []*IxiaTGImage `protobuf:"bytes,2,rep,name=images,proto3" json:"images,omitempty"`
	// contains filtered or unexported fields
}

IxiaTG config map values

func (*IxiaTGConfigMap) Descriptor deprecated 

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

Deprecated: Use IxiaTGConfigMap.ProtoReflect.Descriptor instead.

func (*IxiaTGConfigMap) GetImages 

func (x *IxiaTGConfigMap) GetImages() []*IxiaTGImage

func (*IxiaTGConfigMap) GetRelease 

func (x *IxiaTGConfigMap) GetRelease() string

func (*IxiaTGConfigMap) ProtoMessage 

func (*IxiaTGConfigMap) ProtoMessage()

func (*IxiaTGConfigMap) ProtoReflect 

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

func (*IxiaTGConfigMap) Reset 

func (x *IxiaTGConfigMap) Reset()

func (*IxiaTGConfigMap) String 

func (x *IxiaTGConfigMap) String() string

type IxiaTGImage 

type IxiaTGImage struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	Tag  string `protobuf:"bytes,3,opt,name=tag,proto3" json:"tag,omitempty"`
	// contains filtered or unexported fields
}

IxiaTG image identifier

func (*IxiaTGImage) Descriptor deprecated 

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

Deprecated: Use IxiaTGImage.ProtoReflect.Descriptor instead.

func (*IxiaTGImage) GetName 

func (x *IxiaTGImage) GetName() string

func (*IxiaTGImage) GetPath 

func (x *IxiaTGImage) GetPath() string

func (*IxiaTGImage) GetTag 

func (x *IxiaTGImage) GetTag() string

func (*IxiaTGImage) ProtoMessage 

func (*IxiaTGImage) ProtoMessage()

func (*IxiaTGImage) ProtoReflect 

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

func (*IxiaTGImage) Reset 

func (x *IxiaTGImage) Reset()

func (*IxiaTGImage) String 

func (x *IxiaTGImage) String() string

type IxiaTGSpec 

type IxiaTGSpec struct {
	ManifestDir string           `protobuf:"bytes,1,opt,name=manifest_dir,json=manifestDir,proto3" json:"manifest_dir,omitempty"`
	ConfigMap   *IxiaTGConfigMap `protobuf:"bytes,2,opt,name=config_map,json=configMap,proto3" json:"config_map,omitempty"`
	// contains filtered or unexported fields
}

IxiaTG specifications

func (*IxiaTGSpec) Descriptor deprecated 

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

Deprecated: Use IxiaTGSpec.ProtoReflect.Descriptor instead.

func (*IxiaTGSpec) GetConfigMap 

func (x *IxiaTGSpec) GetConfigMap() *IxiaTGConfigMap

func (*IxiaTGSpec) GetManifestDir 

func (x *IxiaTGSpec) GetManifestDir() string

func (*IxiaTGSpec) ProtoMessage 

func (*IxiaTGSpec) ProtoMessage()

func (*IxiaTGSpec) ProtoReflect 

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

func (*IxiaTGSpec) Reset 

func (x *IxiaTGSpec) Reset()

func (*IxiaTGSpec) String 

func (x *IxiaTGSpec) String() string

type KindSpec 

type KindSpec struct {
	Name                     string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Recycle                  bool     `protobuf:"varint,2,opt,name=recycle,proto3" json:"recycle,omitempty"`
	Version                  string   `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
	Image                    string   `protobuf:"bytes,4,opt,name=image,proto3" json:"image,omitempty"`
	Retain                   bool     `protobuf:"varint,5,opt,name=retain,proto3" json:"retain,omitempty"`
	Kubecfg                  string   `protobuf:"bytes,6,opt,name=kubecfg,proto3" json:"kubecfg,omitempty"`
	GoogleArtifactRegistries []string `` /* 135-byte string literal not displayed */
	// container_images is a map of source images to target images for containers
	// to load in the kind cluster. For example:
	// container_images = {
	//   "us-west1-docker.pkg.dev/pkg/a:ga": "pkg/a:latest",
	//   "us-west1-docker.pkg.dev/pkg/b:v0.8.0": "pkg/b:v0.8.0",
	// }
	// Would load images "pkg/a:latest" and "pkg/b:v0.8.0" into the cluster
	// after fetching their source images from "us-west1-docker.pkg.dev".
	ContainerImages map[string]string `` /* 194-byte string literal not displayed */
	// contains filtered or unexported fields
}

Kind cluster specifications

func (*KindSpec) Descriptor deprecated 

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

Deprecated: Use KindSpec.ProtoReflect.Descriptor instead.

func (*KindSpec) GetContainerImages 

func (x *KindSpec) GetContainerImages() map[string]string

func (*KindSpec) GetGoogleArtifactRegistries 

func (x *KindSpec) GetGoogleArtifactRegistries() []string

func (*KindSpec) GetImage 

func (x *KindSpec) GetImage() string

func (*KindSpec) GetKubecfg 

func (x *KindSpec) GetKubecfg() string

func (*KindSpec) GetName 

func (x *KindSpec) GetName() string

func (*KindSpec) GetRecycle 

func (x *KindSpec) GetRecycle() bool

func (*KindSpec) GetRetain 

func (x *KindSpec) GetRetain() bool

func (*KindSpec) GetVersion 

func (x *KindSpec) GetVersion() string

func (*KindSpec) ProtoMessage 

func (*KindSpec) ProtoMessage()

func (*KindSpec) ProtoReflect 

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

func (*KindSpec) Reset 

func (x *KindSpec) Reset()

func (*KindSpec) String 

func (x *KindSpec) String() string

type MeshnetSpec 

type MeshnetSpec struct {
	Image       string `protobuf:"bytes,1,opt,name=image,proto3" json:"image,omitempty"`
	ManifestDir string `protobuf:"bytes,2,opt,name=manifest_dir,json=manifestDir,proto3" json:"manifest_dir,omitempty"`
	// contains filtered or unexported fields
}

Meshnet specifications

func (*MeshnetSpec) Descriptor deprecated 

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

Deprecated: Use MeshnetSpec.ProtoReflect.Descriptor instead.

func (*MeshnetSpec) GetImage 

func (x *MeshnetSpec) GetImage() string

func (*MeshnetSpec) GetManifestDir 

func (x *MeshnetSpec) GetManifestDir() string

func (*MeshnetSpec) ProtoMessage 

func (*MeshnetSpec) ProtoMessage()

func (*MeshnetSpec) ProtoReflect 

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

func (*MeshnetSpec) Reset 

func (x *MeshnetSpec) Reset()

func (*MeshnetSpec) String 

func (x *MeshnetSpec) String() string

type MetallbSpec 

type MetallbSpec struct {
	Version     string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	IpCount     int32  `protobuf:"varint,2,opt,name=ip_count,json=ipCount,proto3" json:"ip_count,omitempty"`
	ManifestDir string `protobuf:"bytes,3,opt,name=manifest_dir,json=manifestDir,proto3" json:"manifest_dir,omitempty"`
	// contains filtered or unexported fields
}

Metallb specifications

func (*MetallbSpec) Descriptor deprecated 

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

Deprecated: Use MetallbSpec.ProtoReflect.Descriptor instead.

func (*MetallbSpec) GetIpCount 

func (x *MetallbSpec) GetIpCount() int32

func (*MetallbSpec) GetManifestDir 

func (x *MetallbSpec) GetManifestDir() string

func (*MetallbSpec) GetVersion 

func (x *MetallbSpec) GetVersion() string

func (*MetallbSpec) ProtoMessage 

func (*MetallbSpec) ProtoMessage()

func (*MetallbSpec) ProtoReflect 

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

func (*MetallbSpec) Reset 

func (x *MetallbSpec) Reset()

func (*MetallbSpec) String 

func (x *MetallbSpec) String() string

type ShowClusterRequest 

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

Request message to show cluster by name.

func (*ShowClusterRequest) Descriptor deprecated 

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

Deprecated: Use ShowClusterRequest.ProtoReflect.Descriptor instead.

func (*ShowClusterRequest) GetName 

func (x *ShowClusterRequest) GetName() string

func (*ShowClusterRequest) ProtoMessage 

func (*ShowClusterRequest) ProtoMessage()

func (*ShowClusterRequest) ProtoReflect 

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

func (*ShowClusterRequest) Reset 

func (x *ShowClusterRequest) Reset()

func (*ShowClusterRequest) String 

func (x *ShowClusterRequest) String() string

type ShowClusterResponse 

type ShowClusterResponse struct {
	State         ClusterState `protobuf:"varint,1,opt,name=state,proto3,enum=controller.ClusterState" json:"state,omitempty"`
	TopologyNames []string     `protobuf:"bytes,2,rep,name=topology_names,json=topologyNames,proto3" json:"topology_names,omitempty"`
	// contains filtered or unexported fields
}

Returns show cluster response.

func (*ShowClusterResponse) Descriptor deprecated 

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

Deprecated: Use ShowClusterResponse.ProtoReflect.Descriptor instead.

func (*ShowClusterResponse) GetState 

func (x *ShowClusterResponse) GetState() ClusterState

func (*ShowClusterResponse) GetTopologyNames 

func (x *ShowClusterResponse) GetTopologyNames() []string

func (*ShowClusterResponse) ProtoMessage 

func (*ShowClusterResponse) ProtoMessage()

func (*ShowClusterResponse) ProtoReflect 

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

func (*ShowClusterResponse) Reset 

func (x *ShowClusterResponse) Reset()

func (*ShowClusterResponse) String 

func (x *ShowClusterResponse) String() string

type ShowTopologyRequest 

type ShowTopologyRequest struct {
	TopologyName string `protobuf:"bytes,1,opt,name=topology_name,json=topologyName,proto3" json:"topology_name,omitempty"`
	// contains filtered or unexported fields
}

Request message to view topology info

func (*ShowTopologyRequest) Descriptor deprecated 

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

Deprecated: Use ShowTopologyRequest.ProtoReflect.Descriptor instead.

func (*ShowTopologyRequest) GetTopologyName 

func (x *ShowTopologyRequest) GetTopologyName() string

func (*ShowTopologyRequest) ProtoMessage 

func (*ShowTopologyRequest) ProtoMessage()

func (*ShowTopologyRequest) ProtoReflect 

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

func (*ShowTopologyRequest) Reset 

func (x *ShowTopologyRequest) Reset()

func (*ShowTopologyRequest) String 

func (x *ShowTopologyRequest) String() string

type ShowTopologyResponse 

type ShowTopologyResponse struct {
	State    TopologyState  `protobuf:"varint,1,opt,name=state,proto3,enum=controller.TopologyState" json:"state,omitempty"`
	Topology *topo.Topology `protobuf:"bytes,2,opt,name=topology,proto3" json:"topology,omitempty"`
	// contains filtered or unexported fields
}

Returns topology view response.

func (*ShowTopologyResponse) Descriptor deprecated 

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

Deprecated: Use ShowTopologyResponse.ProtoReflect.Descriptor instead.

func (*ShowTopologyResponse) GetState 

func (x *ShowTopologyResponse) GetState() TopologyState

func (*ShowTopologyResponse) GetTopology 

func (x *ShowTopologyResponse) GetTopology() *topo.Topology

func (*ShowTopologyResponse) ProtoMessage 

func (*ShowTopologyResponse) ProtoMessage()

func (*ShowTopologyResponse) ProtoReflect 

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

func (*ShowTopologyResponse) Reset 

func (x *ShowTopologyResponse) Reset()

func (*ShowTopologyResponse) String 

func (x *ShowTopologyResponse) String() string

type TopologyManagerClient 

type TopologyManagerClient interface {
	// Creates a topology with and responds with topology name and state.
	CreateTopology(ctx context.Context, in *CreateTopologyRequest, opts ...grpc.CallOption) (*CreateTopologyResponse, error)
	// Deletes a topology.
	DeleteTopology(ctx context.Context, in *DeleteTopologyRequest, opts ...grpc.CallOption) (*DeleteTopologyResponse, error)
	// Shows the topology info and responds with the current topology state.
	ShowTopology(ctx context.Context, in *ShowTopologyRequest, opts ...grpc.CallOption) (*ShowTopologyResponse, error)
	// Creates kind cluster and responds with cluster name and state.
	CreateCluster(ctx context.Context, in *CreateClusterRequest, opts ...grpc.CallOption) (*CreateClusterResponse, error)
	// Deletes a kind cluster by cluster name.
	DeleteCluster(ctx context.Context, in *DeleteClusterRequest, opts ...grpc.CallOption) (*DeleteClusterResponse, error)
	// Shows cluster state and topologies deployed in the cluster.
	ShowCluster(ctx context.Context, in *ShowClusterRequest, opts ...grpc.CallOption) (*ShowClusterResponse, error)
}

TopologyManagerClient is the client API for TopologyManager service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewTopologyManagerClient 

func NewTopologyManagerClient(cc grpc.ClientConnInterface) TopologyManagerClient

type TopologyManagerServer 

type TopologyManagerServer interface {
	// Creates a topology with and responds with topology name and state.
	CreateTopology(context.Context, *CreateTopologyRequest) (*CreateTopologyResponse, error)
	// Deletes a topology.
	DeleteTopology(context.Context, *DeleteTopologyRequest) (*DeleteTopologyResponse, error)
	// Shows the topology info and responds with the current topology state.
	ShowTopology(context.Context, *ShowTopologyRequest) (*ShowTopologyResponse, error)
	// Creates kind cluster and responds with cluster name and state.
	CreateCluster(context.Context, *CreateClusterRequest) (*CreateClusterResponse, error)
	// Deletes a kind cluster by cluster name.
	DeleteCluster(context.Context, *DeleteClusterRequest) (*DeleteClusterResponse, error)
	// Shows cluster state and topologies deployed in the cluster.
	ShowCluster(context.Context, *ShowClusterRequest) (*ShowClusterResponse, error)
	// contains filtered or unexported methods
}

TopologyManagerServer is the server API for TopologyManager service. All implementations must embed UnimplementedTopologyManagerServer for forward compatibility

type TopologyState 

type TopologyState int32
const (
	TopologyState_TOPOLOGY_STATE_UNKNOWN  TopologyState = 0
	TopologyState_TOPOLOGY_STATE_CREATING TopologyState = 1
	TopologyState_TOPOLOGY_STATE_RUNNING  TopologyState = 2
	TopologyState_TOPOLOGY_STATE_ERROR    TopologyState = 3
)

func (TopologyState) Descriptor 

func (TopologyState) Descriptor() protoreflect.EnumDescriptor

func (TopologyState) Enum 

func (x TopologyState) Enum() *TopologyState

func (TopologyState) EnumDescriptor deprecated 

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

Deprecated: Use TopologyState.Descriptor instead.

func (TopologyState) Number 

func (x TopologyState) Number() protoreflect.EnumNumber

func (TopologyState) String 

func (x TopologyState) String() string

func (TopologyState) Type 

func (TopologyState) Type() protoreflect.EnumType

type UnimplementedTopologyManagerServer 

type UnimplementedTopologyManagerServer struct {
}

UnimplementedTopologyManagerServer must be embedded to have forward compatible implementations.

func (UnimplementedTopologyManagerServer) CreateCluster 

func (UnimplementedTopologyManagerServer) CreateCluster(context.Context, *CreateClusterRequest) (*CreateClusterResponse, error)

func (UnimplementedTopologyManagerServer) CreateTopology 

func (UnimplementedTopologyManagerServer) CreateTopology(context.Context, *CreateTopologyRequest) (*CreateTopologyResponse, error)

func (UnimplementedTopologyManagerServer) DeleteCluster 

func (UnimplementedTopologyManagerServer) DeleteCluster(context.Context, *DeleteClusterRequest) (*DeleteClusterResponse, error)

func (UnimplementedTopologyManagerServer) DeleteTopology 

func (UnimplementedTopologyManagerServer) DeleteTopology(context.Context, *DeleteTopologyRequest) (*DeleteTopologyResponse, error)

func (UnimplementedTopologyManagerServer) ShowCluster 

func (UnimplementedTopologyManagerServer) ShowCluster(context.Context, *ShowClusterRequest) (*ShowClusterResponse, error)

func (UnimplementedTopologyManagerServer) ShowTopology 

func (UnimplementedTopologyManagerServer) ShowTopology(context.Context, *ShowTopologyRequest) (*ShowTopologyResponse, error)

type UnsafeTopologyManagerServer 

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

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

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.