controller

package

Go to main page

Versions in this module

v0

v0.2.1

Aug 23, 2024

v0.2.0

Aug 20, 2024

v0.1.18

May 6, 2024

Changes in this version

+ type CdnosSpec struct

+ Operator *Manifest

+ func (*CdnosSpec) Descriptor() ([]byte, []int)

+ func (*CdnosSpec) ProtoMessage()

+ func (x *CdnosSpec) GetOperator() *Manifest

+ func (x *CdnosSpec) ProtoReflect() protoreflect.Message

+ func (x *CdnosSpec) Reset()

+ func (x *CdnosSpec) String() string

type ControllerSpec

+ func (x *ControllerSpec) GetCdnos() *CdnosSpec

+ type ControllerSpec_Cdnos struct

+ Cdnos *CdnosSpec

type CreateClusterRequest

+ func (x *CreateClusterRequest) GetKubeadm() *KubeadmSpec

+ type CreateClusterRequest_Kubeadm struct

+ Kubeadm *KubeadmSpec

+ type JoinClusterRequest struct

+ ApiServerEndpoint string

+ CredentialProviderConfig string

+ CriSocket string

+ DiscoveryTokenCaCertHash string

+ Token string

+ func (*JoinClusterRequest) Descriptor() ([]byte, []int)

+ func (*JoinClusterRequest) ProtoMessage()

+ func (x *JoinClusterRequest) GetApiServerEndpoint() string

+ func (x *JoinClusterRequest) GetCredentialProviderConfig() string

+ func (x *JoinClusterRequest) GetCriSocket() string

+ func (x *JoinClusterRequest) GetDiscoveryTokenCaCertHash() string

+ func (x *JoinClusterRequest) GetToken() string

+ func (x *JoinClusterRequest) ProtoReflect() protoreflect.Message

+ func (x *JoinClusterRequest) Reset()

+ func (x *JoinClusterRequest) String() string

+ type JoinClusterResponse struct

+ func (*JoinClusterResponse) Descriptor() ([]byte, []int)

+ func (*JoinClusterResponse) ProtoMessage()

+ func (x *JoinClusterResponse) ProtoReflect() protoreflect.Message

+ func (x *JoinClusterResponse) Reset()

+ func (x *JoinClusterResponse) String() string

+ type KubeadmSpec struct

+ AllowControlPlaneScheduling bool

+ CredentialProviderConfig string

+ CriSocket string

+ Network string

+ PodNetworkAddOnManifest *Manifest

+ PodNetworkCidr string

+ TokenTtl string

+ func (*KubeadmSpec) Descriptor() ([]byte, []int)

+ func (*KubeadmSpec) ProtoMessage()

+ func (x *KubeadmSpec) GetAllowControlPlaneScheduling() bool

+ func (x *KubeadmSpec) GetCredentialProviderConfig() string

+ func (x *KubeadmSpec) GetCriSocket() string

+ func (x *KubeadmSpec) GetNetwork() string

+ func (x *KubeadmSpec) GetPodNetworkAddOnManifest() *Manifest

+ func (x *KubeadmSpec) GetPodNetworkCidr() string

+ func (x *KubeadmSpec) GetTokenTtl() string

+ func (x *KubeadmSpec) ProtoReflect() protoreflect.Message

+ func (x *KubeadmSpec) Reset()

+ func (x *KubeadmSpec) String() string

type ShowClusterResponse

+ ApiServerEndpoint string

+ CriSocket string

+ DiscoveryTokenCaCertHash string

+ Token string

+ func (x *ShowClusterResponse) GetApiServerEndpoint() string

+ func (x *ShowClusterResponse) GetCriSocket() string

+ func (x *ShowClusterResponse) GetDiscoveryTokenCaCertHash() string

+ func (x *ShowClusterResponse) GetToken() string

type TopologyManagerClient

+ JoinCluster func(ctx context.Context, in *JoinClusterRequest, opts ...grpc.CallOption) (*JoinClusterResponse, error)

type TopologyManagerServer

+ JoinCluster func(context.Context, *JoinClusterRequest) (*JoinClusterResponse, error)

type UnimplementedTopologyManagerServer

+ func (UnimplementedTopologyManagerServer) JoinCluster(context.Context, *JoinClusterRequest) (*JoinClusterResponse, error)

v0.1.17

Feb 20, 2024

v0.1.16

Dec 14, 2023

Changes in this version

+ type ApplyClusterRequest struct

+ Config []byte

+ Name string

+ func (*ApplyClusterRequest) Descriptor() ([]byte, []int)

+ func (*ApplyClusterRequest) ProtoMessage()

+ func (x *ApplyClusterRequest) GetConfig() []byte

+ func (x *ApplyClusterRequest) GetName() string

+ func (x *ApplyClusterRequest) ProtoReflect() protoreflect.Message

+ func (x *ApplyClusterRequest) Reset()

+ func (x *ApplyClusterRequest) String() string

+ type ApplyClusterResponse struct

+ func (*ApplyClusterResponse) Descriptor() ([]byte, []int)

+ func (*ApplyClusterResponse) ProtoMessage()

+ func (x *ApplyClusterResponse) ProtoReflect() protoreflect.Message

+ func (x *ApplyClusterResponse) Reset()

+ func (x *ApplyClusterResponse) String() string

type TopologyManagerClient

+ ApplyCluster func(ctx context.Context, in *ApplyClusterRequest, opts ...grpc.CallOption) (*ApplyClusterResponse, error)

type TopologyManagerServer

+ ApplyCluster func(context.Context, *ApplyClusterRequest) (*ApplyClusterResponse, error)

type UnimplementedTopologyManagerServer

+ func (UnimplementedTopologyManagerServer) ApplyCluster(context.Context, *ApplyClusterRequest) (*ApplyClusterResponse, error)

v0.1.15

Sep 21, 2023

v0.1.14

Jul 27, 2023

v0.1.13

Jun 5, 2023

v0.1.12

May 11, 2023

v0.1.11

Apr 19, 2023

v0.1.10

Mar 28, 2023

v0.1.9

Mar 16, 2023

v0.1.8

Mar 14, 2023

Changes in this version

type CEOSLabSpec

+ Operator *Manifest

+ func (x *CEOSLabSpec) GetOperator() *Manifest

type IxiaTGSpec

+ CfgMap *Manifest

+ Operator *Manifest

+ func (x *IxiaTGSpec) GetCfgMap() *Manifest

+ func (x *IxiaTGSpec) GetOperator() *Manifest

type LemmingSpec

+ Operator *Manifest

+ func (x *LemmingSpec) GetOperator() *Manifest

+ type Manifest struct

+ ManifestData isManifest_ManifestData

+ func (*Manifest) Descriptor() ([]byte, []int)

+ func (*Manifest) ProtoMessage()

+ func (m *Manifest) GetManifestData() isManifest_ManifestData

+ func (x *Manifest) GetData() []byte

+ func (x *Manifest) GetFile() string

+ func (x *Manifest) ProtoReflect() protoreflect.Message

+ func (x *Manifest) Reset()

+ func (x *Manifest) String() string

+ type Manifest_Data struct

+ Data []byte

+ type Manifest_File struct

+ File string

type MeshnetSpec

+ Manifest *Manifest

+ func (x *MeshnetSpec) GetManifest() *Manifest

type MetallbSpec

+ Manifest *Manifest

+ func (x *MetallbSpec) GetManifest() *Manifest

type SRLinuxSpec

+ Operator *Manifest

+ func (x *SRLinuxSpec) GetOperator() *Manifest

v0.1.7

Dec 20, 2022

Changes in this version

+ type CEOSLabSpec struct

+ ManifestDir string

+ func (*CEOSLabSpec) Descriptor() ([]byte, []int)

+ func (*CEOSLabSpec) ProtoMessage()

+ func (x *CEOSLabSpec) GetManifestDir() string

+ func (x *CEOSLabSpec) ProtoReflect() protoreflect.Message

+ func (x *CEOSLabSpec) Reset()

+ func (x *CEOSLabSpec) String() string

type ControllerSpec

+ func (x *ControllerSpec) GetCeoslab() *CEOSLabSpec

+ func (x *ControllerSpec) GetLemming() *LemmingSpec

+ type ControllerSpec_Ceoslab struct

+ Ceoslab *CEOSLabSpec

+ type ControllerSpec_Lemming struct

+ Lemming *LemmingSpec

type CreateClusterRequest

+ func (x *CreateClusterRequest) GetExternal() *ExternalSpec

+ type CreateClusterRequest_External struct

+ External *ExternalSpec

+ type ExternalSpec struct

+ Network string

+ func (*ExternalSpec) Descriptor() ([]byte, []int)

+ func (*ExternalSpec) ProtoMessage()

+ func (x *ExternalSpec) GetNetwork() string

+ func (x *ExternalSpec) ProtoReflect() protoreflect.Message

+ func (x *ExternalSpec) Reset()

+ func (x *ExternalSpec) String() string

+ type LemmingSpec struct

+ ManifestDir string

+ func (*LemmingSpec) Descriptor() ([]byte, []int)

+ func (*LemmingSpec) ProtoMessage()

+ func (x *LemmingSpec) GetManifestDir() string

+ func (x *LemmingSpec) ProtoReflect() protoreflect.Message

+ func (x *LemmingSpec) Reset()

+ func (x *LemmingSpec) String() string

v0.1.6

Sep 14, 2022

v0.1.5

Sep 1, 2022

v0.1.4

Aug 29, 2022

v0.1.3

Aug 18, 2022

Changes in this version

type ClusterState

+ const ClusterState_CLUSTER_STATE_UNSPECIFIED

type ControllerSpec

+ func (x *ControllerSpec) GetSrlinux() *SRLinuxSpec

+ type ControllerSpec_Srlinux struct

+ Srlinux *SRLinuxSpec

type KindSpec

+ AdditionalManifests []string

+ Config string

+ func (x *KindSpec) GetAdditionalManifests() []string

+ func (x *KindSpec) GetConfig() string

+ type PushConfigRequest struct

+ Config []byte

+ DeviceName string

+ TopologyName string

+ func (*PushConfigRequest) Descriptor() ([]byte, []int)

+ func (*PushConfigRequest) ProtoMessage()

+ func (x *PushConfigRequest) GetConfig() []byte

+ func (x *PushConfigRequest) GetDeviceName() string

+ func (x *PushConfigRequest) GetTopologyName() string

+ func (x *PushConfigRequest) ProtoReflect() protoreflect.Message

+ func (x *PushConfigRequest) Reset()

+ func (x *PushConfigRequest) String() string

+ type PushConfigResponse struct

+ func (*PushConfigResponse) Descriptor() ([]byte, []int)

+ func (*PushConfigResponse) ProtoMessage()

+ func (x *PushConfigResponse) ProtoReflect() protoreflect.Message

+ func (x *PushConfigResponse) Reset()

+ func (x *PushConfigResponse) String() string

+ type ResetConfigRequest struct

+ DeviceName string

+ TopologyName string

+ func (*ResetConfigRequest) Descriptor() ([]byte, []int)

+ func (*ResetConfigRequest) ProtoMessage()

+ func (x *ResetConfigRequest) GetDeviceName() string

+ func (x *ResetConfigRequest) GetTopologyName() string

+ func (x *ResetConfigRequest) ProtoReflect() protoreflect.Message

+ func (x *ResetConfigRequest) Reset()

+ func (x *ResetConfigRequest) String() string

+ type ResetConfigResponse struct

+ func (*ResetConfigResponse) Descriptor() ([]byte, []int)

+ func (*ResetConfigResponse) ProtoMessage()

+ func (x *ResetConfigResponse) ProtoReflect() protoreflect.Message

+ func (x *ResetConfigResponse) Reset()

+ func (x *ResetConfigResponse) String() string

+ type SRLinuxSpec struct

+ ManifestDir string

+ func (*SRLinuxSpec) Descriptor() ([]byte, []int)

+ func (*SRLinuxSpec) ProtoMessage()

+ func (x *SRLinuxSpec) GetManifestDir() string

+ func (x *SRLinuxSpec) ProtoReflect() protoreflect.Message

+ func (x *SRLinuxSpec) Reset()

+ func (x *SRLinuxSpec) String() string

type TopologyManagerClient

+ PushConfig func(ctx context.Context, in *PushConfigRequest, opts ...grpc.CallOption) (*PushConfigResponse, error)

+ ResetConfig func(ctx context.Context, in *ResetConfigRequest, opts ...grpc.CallOption) (*ResetConfigResponse, error)

type TopologyManagerServer

+ PushConfig func(context.Context, *PushConfigRequest) (*PushConfigResponse, error)

+ ResetConfig func(context.Context, *ResetConfigRequest) (*ResetConfigResponse, error)

type TopologyState

+ const TopologyState_TOPOLOGY_STATE_UNSPECIFIED

type UnimplementedTopologyManagerServer

+ func (UnimplementedTopologyManagerServer) PushConfig(context.Context, *PushConfigRequest) (*PushConfigResponse, error)

+ func (UnimplementedTopologyManagerServer) ResetConfig(context.Context, *ResetConfigRequest) (*ResetConfigResponse, error)

v0.1.2

Jun 30, 2022

v0.1.1

Jun 29, 2022

Changes in this version

+ var ClusterState_name = map[int32]string

+ var ClusterState_value = map[string]int32

+ var File_controller_proto protoreflect.FileDescriptor

+ var TopologyManager_ServiceDesc = grpc.ServiceDesc

+ var TopologyState_name = map[int32]string

+ var TopologyState_value = map[string]int32

+ func RegisterTopologyManagerServer(s grpc.ServiceRegistrar, srv TopologyManagerServer)

+ type ClusterState int32

+ const ClusterState_CLUSTER_STATE_CREATING

+ const ClusterState_CLUSTER_STATE_ERROR

+ const ClusterState_CLUSTER_STATE_RUNNING

+ const ClusterState_CLUSTER_STATE_UNKNOWN

+ func (ClusterState) Descriptor() protoreflect.EnumDescriptor

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

+ func (ClusterState) Type() protoreflect.EnumType

+ func (x ClusterState) Enum() *ClusterState

+ func (x ClusterState) Number() protoreflect.EnumNumber

+ func (x ClusterState) String() string

+ type ControllerSpec struct

+ Spec isControllerSpec_Spec

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

+ func (*ControllerSpec) ProtoMessage()

+ func (m *ControllerSpec) GetSpec() isControllerSpec_Spec

+ func (x *ControllerSpec) GetIxiatg() *IxiaTGSpec

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

+ func (x *ControllerSpec) Reset()

+ func (x *ControllerSpec) String() string

+ type ControllerSpec_Ixiatg struct

+ Ixiatg *IxiaTGSpec

+ type CreateClusterRequest struct

+ ClusterSpec isCreateClusterRequest_ClusterSpec

+ CniSpec isCreateClusterRequest_CniSpec

+ ControllerSpecs []*ControllerSpec

+ IngressSpec isCreateClusterRequest_IngressSpec

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

+ func (*CreateClusterRequest) ProtoMessage()

+ func (m *CreateClusterRequest) GetClusterSpec() isCreateClusterRequest_ClusterSpec

+ func (m *CreateClusterRequest) GetCniSpec() isCreateClusterRequest_CniSpec

+ func (m *CreateClusterRequest) GetIngressSpec() isCreateClusterRequest_IngressSpec

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

+ func (x *CreateClusterRequest) GetKind() *KindSpec

+ func (x *CreateClusterRequest) GetMeshnet() *MeshnetSpec

+ func (x *CreateClusterRequest) GetMetallb() *MetallbSpec

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

+ func (x *CreateClusterRequest) Reset()

+ func (x *CreateClusterRequest) String() string

+ type CreateClusterRequest_Kind struct

+ Kind *KindSpec

+ type CreateClusterRequest_Meshnet struct

+ Meshnet *MeshnetSpec

+ type CreateClusterRequest_Metallb struct

+ Metallb *MetallbSpec

+ type CreateClusterResponse struct

+ Name string

+ State ClusterState

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

+ func (*CreateClusterResponse) ProtoMessage()

+ func (x *CreateClusterResponse) GetName() string

+ func (x *CreateClusterResponse) GetState() ClusterState

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

+ func (x *CreateClusterResponse) Reset()

+ func (x *CreateClusterResponse) String() string

+ type CreateTopologyRequest struct

+ Kubecfg string

+ Topology *topo.Topology

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

+ func (*CreateTopologyRequest) ProtoMessage()

+ func (x *CreateTopologyRequest) GetKubecfg() string

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

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

+ func (x *CreateTopologyRequest) Reset()

+ func (x *CreateTopologyRequest) String() string

+ type CreateTopologyResponse struct

+ State TopologyState

+ TopologyName string

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

+ func (*CreateTopologyResponse) ProtoMessage()

+ func (x *CreateTopologyResponse) GetState() TopologyState

+ func (x *CreateTopologyResponse) GetTopologyName() string

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

+ func (x *CreateTopologyResponse) Reset()

+ func (x *CreateTopologyResponse) String() string

+ type DeleteClusterRequest struct

+ Name string

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

+ func (*DeleteClusterRequest) ProtoMessage()

+ func (x *DeleteClusterRequest) GetName() string

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

+ func (x *DeleteClusterRequest) Reset()

+ func (x *DeleteClusterRequest) String() string

+ type DeleteClusterResponse struct

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

+ func (*DeleteClusterResponse) ProtoMessage()

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

+ func (x *DeleteClusterResponse) Reset()

+ func (x *DeleteClusterResponse) String() string

+ type DeleteTopologyRequest struct

+ TopologyName string

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

+ func (*DeleteTopologyRequest) ProtoMessage()

+ func (x *DeleteTopologyRequest) GetTopologyName() string

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

+ func (x *DeleteTopologyRequest) Reset()

+ func (x *DeleteTopologyRequest) String() string

+ type DeleteTopologyResponse struct

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

+ func (*DeleteTopologyResponse) ProtoMessage()

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

+ func (x *DeleteTopologyResponse) Reset()

+ func (x *DeleteTopologyResponse) String() string

+ type IxiaTGConfigMap struct

+ Images []*IxiaTGImage

+ Release string

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

+ func (*IxiaTGConfigMap) ProtoMessage()

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

+ func (x *IxiaTGConfigMap) GetRelease() string

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

+ func (x *IxiaTGConfigMap) Reset()

+ func (x *IxiaTGConfigMap) String() string

+ type IxiaTGImage struct

+ Name string

+ Path string

+ Tag string

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

+ func (*IxiaTGImage) ProtoMessage()

+ func (x *IxiaTGImage) GetName() string

+ func (x *IxiaTGImage) GetPath() string

+ func (x *IxiaTGImage) GetTag() string

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

+ func (x *IxiaTGImage) Reset()

+ func (x *IxiaTGImage) String() string

+ type IxiaTGSpec struct

+ ConfigMap *IxiaTGConfigMap

+ ManifestDir string

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

+ func (*IxiaTGSpec) ProtoMessage()

+ func (x *IxiaTGSpec) GetConfigMap() *IxiaTGConfigMap

+ func (x *IxiaTGSpec) GetManifestDir() string

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

+ func (x *IxiaTGSpec) Reset()

+ func (x *IxiaTGSpec) String() string

+ type KindSpec struct

+ ContainerImages map[string]string

+ GoogleArtifactRegistries []string

+ Image string

+ Kubecfg string

+ Name string

+ Recycle bool

+ Retain bool

+ Version string

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

+ func (*KindSpec) ProtoMessage()

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

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

+ func (x *KindSpec) GetImage() string

+ func (x *KindSpec) GetKubecfg() string

+ func (x *KindSpec) GetName() string

+ func (x *KindSpec) GetRecycle() bool

+ func (x *KindSpec) GetRetain() bool

+ func (x *KindSpec) GetVersion() string

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

+ func (x *KindSpec) Reset()

+ func (x *KindSpec) String() string

+ type MeshnetSpec struct

+ Image string

+ ManifestDir string

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

+ func (*MeshnetSpec) ProtoMessage()

+ func (x *MeshnetSpec) GetImage() string

+ func (x *MeshnetSpec) GetManifestDir() string

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

+ func (x *MeshnetSpec) Reset()

+ func (x *MeshnetSpec) String() string

+ type MetallbSpec struct

+ IpCount int32

+ ManifestDir string

+ Version string

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

+ func (*MetallbSpec) ProtoMessage()

+ func (x *MetallbSpec) GetIpCount() int32

+ func (x *MetallbSpec) GetManifestDir() string

+ func (x *MetallbSpec) GetVersion() string

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

+ func (x *MetallbSpec) Reset()

+ func (x *MetallbSpec) String() string

+ type ShowClusterRequest struct

+ Name string

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

+ func (*ShowClusterRequest) ProtoMessage()

+ func (x *ShowClusterRequest) GetName() string

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

+ func (x *ShowClusterRequest) Reset()

+ func (x *ShowClusterRequest) String() string

+ type ShowClusterResponse struct

+ State ClusterState

+ TopologyNames []string

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

+ func (*ShowClusterResponse) ProtoMessage()

+ func (x *ShowClusterResponse) GetState() ClusterState

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

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

+ func (x *ShowClusterResponse) Reset()

+ func (x *ShowClusterResponse) String() string

+ type ShowTopologyRequest struct

+ TopologyName string

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

+ func (*ShowTopologyRequest) ProtoMessage()

+ func (x *ShowTopologyRequest) GetTopologyName() string

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

+ func (x *ShowTopologyRequest) Reset()

+ func (x *ShowTopologyRequest) String() string

+ type ShowTopologyResponse struct

+ State TopologyState

+ Topology *topo.Topology

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

+ func (*ShowTopologyResponse) ProtoMessage()

+ func (x *ShowTopologyResponse) GetState() TopologyState

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

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

+ func (x *ShowTopologyResponse) Reset()

+ func (x *ShowTopologyResponse) String() string

+ type TopologyManagerClient interface

+ CreateCluster func(ctx context.Context, in *CreateClusterRequest, opts ...grpc.CallOption) (*CreateClusterResponse, error)

+ CreateTopology func(ctx context.Context, in *CreateTopologyRequest, opts ...grpc.CallOption) (*CreateTopologyResponse, error)

+ DeleteCluster func(ctx context.Context, in *DeleteClusterRequest, opts ...grpc.CallOption) (*DeleteClusterResponse, error)

+ DeleteTopology func(ctx context.Context, in *DeleteTopologyRequest, opts ...grpc.CallOption) (*DeleteTopologyResponse, error)

+ ShowCluster func(ctx context.Context, in *ShowClusterRequest, opts ...grpc.CallOption) (*ShowClusterResponse, error)

+ ShowTopology func(ctx context.Context, in *ShowTopologyRequest, opts ...grpc.CallOption) (*ShowTopologyResponse, error)

+ func NewTopologyManagerClient(cc grpc.ClientConnInterface) TopologyManagerClient

+ type TopologyManagerServer interface

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

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

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

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

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

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

+ type TopologyState int32

+ const TopologyState_TOPOLOGY_STATE_CREATING

+ const TopologyState_TOPOLOGY_STATE_ERROR

+ const TopologyState_TOPOLOGY_STATE_RUNNING

+ const TopologyState_TOPOLOGY_STATE_UNKNOWN

+ func (TopologyState) Descriptor() protoreflect.EnumDescriptor

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

+ func (TopologyState) Type() protoreflect.EnumType

+ func (x TopologyState) Enum() *TopologyState

+ func (x TopologyState) Number() protoreflect.EnumNumber

+ func (x TopologyState) String() string

+ type UnimplementedTopologyManagerServer struct

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

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

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

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

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

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

+ type UnsafeTopologyManagerServer interface

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