cluster

package
v0.0.0-...-bb2f907 Latest Latest
Warning

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

 Go to latest Published: Jul 24, 2023 License: Apache-2.0 Imports: 13 Imported by: 9

Documentation

Index

Constants

View Source 
const CONTEXT_CLUSTER_APP = "network-intents"
View Source 
const CONTEXT_CLUSTER_RESOURCE = "network-intents"
View Source 
const SEPARATOR = "+"

Variables

This section is empty.

Functions

This section is empty.

Types

type Cluster 

type Cluster struct {
	Metadata mtypes.Metadata   `json:"metadata"`
	Spec     mtypes.GitOpsSpec `json:"spec,omitempty"`
}

type ClusterClient 

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

ClusterClient implements the Manager It will also be used to maintain some localized state

func NewClusterClient 

func NewClusterClient() *ClusterClient

NewClusterClient returns an instance of the ClusterClient which implements the Manager

func (*ClusterClient) CreateCluster 

func (v *ClusterClient) CreateCluster(ctx context.Context, provider string, p Cluster, q ClusterContent) (Cluster, error)

CreateCluster - create a new Cluster for a cluster-provider

func (*ClusterClient) CreateClusterKvPairs 

func (v *ClusterClient) CreateClusterKvPairs(ctx context.Context, provider string, cluster string, p ClusterKvPairs, exists bool) (ClusterKvPairs, error)

CreateClusterKvPairs - Create a New Cluster KV pairs document

func (*ClusterClient) CreateClusterLabel 

func (v *ClusterClient) CreateClusterLabel(ctx context.Context, provider string, cluster string, p ClusterLabel, exists bool) (ClusterLabel, error)

CreateClusterLabel - create a new Cluster Label mongo document for a cluster-provider/cluster

func (*ClusterClient) CreateClusterProvider 

func (v *ClusterClient) CreateClusterProvider(ctx context.Context, p ClusterProvider, exists bool) (ClusterProvider, error)

CreateClusterProvider - create a new Cluster Provider

func (*ClusterClient) CreateClusterSyncObjects 

func (v *ClusterClient) CreateClusterSyncObjects(ctx context.Context, provider string, p mtypes.ClusterSyncObjects, exists bool) (mtypes.ClusterSyncObjects, error)

CreateClusterSyncObjects - Create a New Cluster sync objects document

func (*ClusterClient) DeleteCluster 

func (v *ClusterClient) DeleteCluster(ctx context.Context, provider, name string) error

DeleteCluster the Cluster from database

func (*ClusterClient) DeleteClusterKvPairs 

func (v *ClusterClient) DeleteClusterKvPairs(ctx context.Context, provider, cluster, kvpair string) error

DeleteClusterKvPairs the ClusterKvPairs from database

func (*ClusterClient) DeleteClusterLabel 

func (v *ClusterClient) DeleteClusterLabel(ctx context.Context, provider, cluster, label string) error

DeleteClusterLabel ... Delete the Cluster Label from database

func (*ClusterClient) DeleteClusterProvider 

func (v *ClusterClient) DeleteClusterProvider(ctx context.Context, name string) error

DeleteClusterProvider the ClusterProvider from database

func (*ClusterClient) DeleteClusterSyncObjects 

func (v *ClusterClient) DeleteClusterSyncObjects(ctx context.Context, provider, syncobject string) error

DeleteClusterSyncObjects the ClusterSyncObjects from database

func (*ClusterClient) GetAllClusterKvPairs 

func (v *ClusterClient) GetAllClusterKvPairs(ctx context.Context, provider, cluster string) ([]ClusterKvPairs, error)

GetAllClusterKvPairs returns the Cluster Kv Pairs for corresponding provider and cluster

func (*ClusterClient) GetAllClusterSyncObjects 

func (v *ClusterClient) GetAllClusterSyncObjects(ctx context.Context, provider string) ([]mtypes.ClusterSyncObjects, error)

GetAllClusterSyncObjects returns the Cluster Sync Objects for corresponding provider

func (*ClusterClient) GetAllClustersAndLabels 

func (v *ClusterClient) GetAllClustersAndLabels(ctx context.Context, provider string) ([]ClusterWithLabels, error)

GetAllClustersAndLabels returns all the the clusters and their labels

func (*ClusterClient) GetCluster 

func (v *ClusterClient) GetCluster(ctx context.Context, provider, name string) (Cluster, error)

GetCluster returns the Cluster for corresponding provider and name

func (*ClusterClient) GetClusterContent 

func (v *ClusterClient) GetClusterContent(ctx context.Context, provider, name string) (ClusterContent, error)

GetClusterContent returns the ClusterContent for corresponding provider and name

func (*ClusterClient) GetClusterKvPairs 

func (v *ClusterClient) GetClusterKvPairs(ctx context.Context, provider, cluster, kvpair string) (ClusterKvPairs, error)

GetClusterKvPairs returns the Cluster KeyValue pair for corresponding provider, cluster and KV pair name

func (*ClusterClient) GetClusterKvPairsValue 

func (v *ClusterClient) GetClusterKvPairsValue(ctx context.Context, provider, cluster, kvpair, kvkey string) (interface{}, error)

GetClusterKvPairsValue returns the value of the key from the corresponding provider, cluster and KV pair name

func (*ClusterClient) GetClusterLabel 

func (v *ClusterClient) GetClusterLabel(ctx context.Context, provider, cluster, label string) (ClusterLabel, error)

GetClusterLabel returns the Cluster for corresponding provider, cluster and label

func (*ClusterClient) GetClusterLabels 

func (v *ClusterClient) GetClusterLabels(ctx context.Context, provider, cluster string) ([]ClusterLabel, error)

GetClusterLabels returns the Cluster Labels for corresponding provider and cluster

func (*ClusterClient) GetClusterProvider 

func (v *ClusterClient) GetClusterProvider(ctx context.Context, name string) (ClusterProvider, error)

GetClusterProvider returns the ClusterProvider for corresponding name

func (*ClusterClient) GetClusterProviders 

func (v *ClusterClient) GetClusterProviders(ctx context.Context) ([]ClusterProvider, error)

GetClusterProviderList returns all of the ClusterProvider for corresponding name

func (*ClusterClient) GetClusterState 

func (v *ClusterClient) GetClusterState(ctx context.Context, provider, name string) (state.StateInfo, error)

GetClusterState returns the StateInfo structure for corresponding cluster provider and cluster

func (*ClusterClient) GetClusterSyncObjects 

func (v *ClusterClient) GetClusterSyncObjects(ctx context.Context, provider, syncobject string) (mtypes.ClusterSyncObjects, error)

GetClusterSyncObjects returns the Cluster Sync objects for corresponding provider and sync object name

func (*ClusterClient) GetClusterSyncObjectsValue 

func (v *ClusterClient) GetClusterSyncObjectsValue(ctx context.Context, provider, syncobject, syncobjectkey string) (interface{}, error)

GetClusterSyncObjectsValue returns the value of the key from the corresponding provider and Sync Object name

func (*ClusterClient) GetClusters 

func (v *ClusterClient) GetClusters(ctx context.Context, provider string) ([]Cluster, error)

GetClusters returns all the Clusters for corresponding provider

func (*ClusterClient) GetClustersWithLabel 

func (v *ClusterClient) GetClustersWithLabel(ctx context.Context, provider, label string) ([]string, error)

GetClustersWithLabel returns all the Clusters with Labels for provider Support Query like /cluster-providers/{Provider}/clusters?label={label}

type ClusterContent 

type ClusterContent struct {
	Kubeconfig string `json:"kubeconfig"`
}

type ClusterKey 

type ClusterKey struct {
	ClusterProviderName string `json:"clusterProvider"`
	ClusterName         string `json:"cluster"`
}

ClusterKey is the key structure that is used in the database

type ClusterKvPairs 

type ClusterKvPairs struct {
	Metadata mtypes.Metadata `json:"metadata"`
	Spec     ClusterKvSpec   `json:"spec"`
}

type ClusterKvPairsKey 

type ClusterKvPairsKey struct {
	ClusterProviderName string `json:"clusterProvider"`
	ClusterName         string `json:"cluster"`
	ClusterKvPairsName  string `json:"clusterKv"`
}

ClusterKvPairsKey is the key structure that is used in the database

type ClusterKvSpec 

type ClusterKvSpec struct {
	Kv []map[string]interface{} `json:"kv"`
}

type ClusterLabel 

type ClusterLabel struct {
	LabelName string `json:"clusterLabel"`
}

type ClusterLabelKey 

type ClusterLabelKey struct {
	ClusterProviderName string `json:"clusterProvider"`
	ClusterName         string `json:"cluster"`
	ClusterLabelName    string `json:"clusterLabel"`
}

ClusterLabelKey is the key structure that is used in the database

type ClusterManager 

type ClusterManager interface {
	CreateClusterProvider(ctx context.Context, pr ClusterProvider, exists bool) (ClusterProvider, error)
	GetClusterProvider(ctx context.Context, name string) (ClusterProvider, error)
	GetClusterProviders(ctx context.Context) ([]ClusterProvider, error)
	DeleteClusterProvider(ctx context.Context, name string) error
	CreateCluster(ctx context.Context, provider string, pr Cluster, qr ClusterContent) (Cluster, error)
	GetCluster(ctx context.Context, provider, name string) (Cluster, error)
	GetClusterContent(ctx context.Context, provider, name string) (ClusterContent, error)
	GetClusterState(ctx context.Context, provider, name string) (state.StateInfo, error)
	GetClusters(ctx context.Context, provider string) ([]Cluster, error)
	GetClustersWithLabel(ctx context.Context, provider, label string) ([]string, error)
	GetAllClustersAndLabels(ctx context.Context, provider string) ([]ClusterWithLabels, error)
	DeleteCluster(ctx context.Context, provider, name string) error
	CreateClusterLabel(ctx context.Context, provider, cluster string, pr ClusterLabel, exists bool) (ClusterLabel, error)
	GetClusterLabel(ctx context.Context, provider, cluster, label string) (ClusterLabel, error)
	GetClusterLabels(ctx context.Context, provider, cluster string) ([]ClusterLabel, error)
	DeleteClusterLabel(ctx context.Context, provider, cluster, label string) error
	CreateClusterKvPairs(ctx context.Context, provider, cluster string, pr ClusterKvPairs, exists bool) (ClusterKvPairs, error)
	GetClusterKvPairs(ctx context.Context, provider, cluster, kvpair string) (ClusterKvPairs, error)
	GetClusterKvPairsValue(ctx context.Context, provider, cluster, kvpair, kvkey string) (interface{}, error)
	GetAllClusterKvPairs(ctx context.Context, provider, cluster string) ([]ClusterKvPairs, error)
	DeleteClusterKvPairs(ctx context.Context, provider, cluster, kvpair string) error
	CreateClusterSyncObjects(ctx context.Context, provider string, pr mtypes.ClusterSyncObjects, exists bool) (mtypes.ClusterSyncObjects, error)
	GetClusterSyncObjects(ctx context.Context, provider, syncobject string) (mtypes.ClusterSyncObjects, error)
	GetClusterSyncObjectsValue(ctx context.Context, provider, syncobject, syncobjectkey string) (interface{}, error)
	GetAllClusterSyncObjects(ctx context.Context, provider string) ([]mtypes.ClusterSyncObjects, error)
	DeleteClusterSyncObjects(ctx context.Context, provider, syncobject string) error
}

ClusterManager is an interface exposes the Cluster functionality

type ClusterProvider 

type ClusterProvider struct {
	Metadata mtypes.Metadata `json:"metadata"`
}

ClusterProvider contains the parameters needed for ClusterProviders

type ClusterProviderKey 

type ClusterProviderKey struct {
	ClusterProviderName string `json:"clusterProvider"`
}

ClusterProviderKey is the key structure that is used in the database

type ClusterWithLabels 

type ClusterWithLabels struct {
	Metadata mtypes.Metadata `json:"metadata"`
	Labels   []ClusterLabel  `json:"labels"`
}

type LabelKey 

type LabelKey struct {
	ClusterProviderName string `json:"clusterProvider"`
	ClusterLabelName    string `json:"clusterLabel"`
}

LabelKey is the key structure that is used in the database

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.