cluster

Documentation

Index

• type ServiceClient
• type ServiceClientImpl
  • func NewServiceClientImpl(logger *zap.SugaredLogger, argoCdConnection connection.ArgoCDConnectionManager) *ServiceClientImpl
  • func (c ServiceClientImpl) Create(ctx context.Context, query *cluster.ClusterCreateRequest) (*v1alpha1.Cluster, error)
  • func (c ServiceClientImpl) CreateFromKubeConfig(ctx context.Context, query *cluster.ClusterCreateRequest) (*v1alpha1.Cluster, error)
  • func (c ServiceClientImpl) Delete(ctx context.Context, query *cluster.ClusterQuery) (*cluster.ClusterResponse, error)
  • func (c ServiceClientImpl) Get(ctx context.Context, query *cluster.ClusterQuery) (*v1alpha1.Cluster, error)
  • func (c ServiceClientImpl) List(ctx context.Context, query *cluster.ClusterQuery) (*v1alpha1.ClusterList, error)
  • func (c ServiceClientImpl) Update(ctx context.Context, query *cluster.ClusterUpdateRequest) (*v1alpha1.Cluster, error)

Types

type ServiceClient

type ServiceClient interface {
	// List returns list of clusters
	List(ctx context.Context, query *cluster.ClusterQuery) (*v1alpha1.ClusterList, error)
	// Create creates a cluster
	Create(ctx context.Context, query *cluster.ClusterCreateRequest) (*v1alpha1.Cluster, error)
	// CreateFromKubeConfig installs the argocd-manager service account into the cluster specified in the given kubeconfig and context
	CreateFromKubeConfig(ctx context.Context, query *cluster.ClusterCreateRequest) (*v1alpha1.Cluster, error)
	// Get returns a cluster by server address
	Get(ctx context.Context, query *cluster.ClusterQuery) (*v1alpha1.Cluster, error)
	// Update updates a cluster
	Update(ctx context.Context, query *cluster.ClusterUpdateRequest) (*v1alpha1.Cluster, error)
	// Delete deletes a cluster
	Delete(ctx context.Context, query *cluster.ClusterQuery) (*cluster.ClusterResponse, error)
}

type ServiceClientImpl

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

func NewServiceClientImpl

func NewServiceClientImpl(logger *zap.SugaredLogger, argoCdConnection connection.ArgoCDConnectionManager) *ServiceClientImpl

func (ServiceClientImpl) Create

func (c ServiceClientImpl) Create(ctx context.Context, query *cluster.ClusterCreateRequest) (*v1alpha1.Cluster, error)

func (ServiceClientImpl) CreateFromKubeConfig

func (c ServiceClientImpl) CreateFromKubeConfig(ctx context.Context, query *cluster.ClusterCreateRequest) (*v1alpha1.Cluster, error)

func (ServiceClientImpl) Delete

func (c ServiceClientImpl) Delete(ctx context.Context, query *cluster.ClusterQuery) (*cluster.ClusterResponse, error)

func (ServiceClientImpl) Get

func (c ServiceClientImpl) Get(ctx context.Context, query *cluster.ClusterQuery) (*v1alpha1.Cluster, error)

func (ServiceClientImpl) List

func (c ServiceClientImpl) List(ctx context.Context, query *cluster.ClusterQuery) (*v1alpha1.ClusterList, error)

func (ServiceClientImpl) Update

func (c ServiceClientImpl) Update(ctx context.Context, query *cluster.ClusterUpdateRequest) (*v1alpha1.Cluster, error)