cluster

Documentation

Index

• type Server
  • func NewServer(db db.ArgoDB, enf *rbac.Enforcer, cache *servercache.Cache, ...) *Server
  • func (s *Server) Create(ctx context.Context, q *cluster.ClusterCreateRequest) (*appv1.Cluster, error)
  • func (s *Server) Delete(ctx context.Context, q *cluster.ClusterQuery) (*cluster.ClusterResponse, error)
  • func (s *Server) Get(ctx context.Context, q *cluster.ClusterQuery) (*appv1.Cluster, error)
  • func (s *Server) InvalidateCache(ctx context.Context, q *cluster.ClusterQuery) (*appv1.Cluster, error)
  • func (s *Server) List(ctx context.Context, q *cluster.ClusterQuery) (*appv1.ClusterList, error)
  • func (s *Server) RotateAuth(ctx context.Context, q *cluster.ClusterQuery) (*cluster.ClusterResponse, error)
  • func (s *Server) Update(ctx context.Context, q *cluster.ClusterUpdateRequest) (*appv1.Cluster, error)

Types

type Server

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

Server provides a Cluster service

func NewServer

func NewServer(db db.ArgoDB, enf *rbac.Enforcer, cache *servercache.Cache, kubectl kube.Kubectl) *Server

NewServer returns a new instance of the Cluster service

func (*Server) Create

func (s *Server) Create(ctx context.Context, q *cluster.ClusterCreateRequest) (*appv1.Cluster, error)

Create creates a cluster

func (*Server) Delete

func (s *Server) Delete(ctx context.Context, q *cluster.ClusterQuery) (*cluster.ClusterResponse, error)

Delete deletes a cluster by server/name

func (*Server) Get

func (s *Server) Get(ctx context.Context, q *cluster.ClusterQuery) (*appv1.Cluster, error)

Get returns a cluster from a query

func (*Server) InvalidateCache

func (s *Server) InvalidateCache(ctx context.Context, q *cluster.ClusterQuery) (*appv1.Cluster, error)

InvalidateCache invalidates cluster cache

func (*Server) List

func (s *Server) List(ctx context.Context, q *cluster.ClusterQuery) (*appv1.ClusterList, error)

List returns list of clusters

func (*Server) RotateAuth

func (s *Server) RotateAuth(ctx context.Context, q *cluster.ClusterQuery) (*cluster.ClusterResponse, error)

RotateAuth rotates the bearer token used for a cluster

func (*Server) Update

func (s *Server) Update(ctx context.Context, q *cluster.ClusterUpdateRequest) (*appv1.Cluster, error)

Update updates a cluster