cluster

package
v0.3.0 Latest Latest
Warning

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

 Go to latest Published: Apr 23, 2018 License: Apache-2.0 Imports: 29 Imported by: 0

Documentation

Overview

Package cluster is a generated protocol buffer package.

Cluster Service

Cluster Service API performs CRUD actions against cluster resources

It is generated from these files: 

server/cluster/cluster.proto

It has these top-level messages: 

ClusterQuery
ClusterResponse
ClusterUpdateRequest

Package cluster is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterClusterServiceHandler 

func RegisterClusterServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterClusterServiceHandler registers the http handlers for service ClusterService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterClusterServiceHandlerClient 

func RegisterClusterServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ClusterServiceClient) error

RegisterClusterServiceHandler registers the http handlers for service ClusterService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "ClusterServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "ClusterServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "ClusterServiceClient" to call the correct interceptors.

func RegisterClusterServiceHandlerFromEndpoint 

func RegisterClusterServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterClusterServiceHandlerFromEndpoint is same as RegisterClusterServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterClusterServiceServer 

func RegisterClusterServiceServer(s *grpc.Server, srv ClusterServiceServer)

Types

type ClusterEvent added in v0.3.0 

type ClusterEvent struct {
	Type    watch.EventType
	Cluster *appv1.Cluster
}

ClusterEvent contains information about cluster event

type ClusterQuery 

type ClusterQuery struct {
	Server string `protobuf:"bytes,1,opt,name=server" json:"server,omitempty"`
}

ClusterQuery is a query for cluster resources

func (*ClusterQuery) Descriptor 

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

func (*ClusterQuery) GetServer 

func (m *ClusterQuery) GetServer() string

func (*ClusterQuery) ProtoMessage 

func (*ClusterQuery) ProtoMessage()

func (*ClusterQuery) Reset 

func (m *ClusterQuery) Reset()

func (*ClusterQuery) String 

func (m *ClusterQuery) String() string

type ClusterResponse 

type ClusterResponse struct {
}

func (*ClusterResponse) Descriptor 

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

func (*ClusterResponse) ProtoMessage 

func (*ClusterResponse) ProtoMessage()

func (*ClusterResponse) Reset 

func (m *ClusterResponse) Reset()

func (*ClusterResponse) String 

func (m *ClusterResponse) String() string

type ClusterServiceClient 

type ClusterServiceClient interface {
	// List returns list of clusters
	List(ctx context.Context, in *ClusterQuery, opts ...grpc.CallOption) (*github_com_argoproj_argo_cd_pkg_apis_application_v1alpha1.ClusterList, error)
	// Create creates a cluster
	Create(ctx context.Context, in *github_com_argoproj_argo_cd_pkg_apis_application_v1alpha1.Cluster, opts ...grpc.CallOption) (*github_com_argoproj_argo_cd_pkg_apis_application_v1alpha1.Cluster, error)
	// Get returns a cluster by server address
	Get(ctx context.Context, in *ClusterQuery, opts ...grpc.CallOption) (*github_com_argoproj_argo_cd_pkg_apis_application_v1alpha1.Cluster, error)
	// Update updates a cluster
	Update(ctx context.Context, in *github_com_argoproj_argo_cd_pkg_apis_application_v1alpha1.Cluster, opts ...grpc.CallOption) (*github_com_argoproj_argo_cd_pkg_apis_application_v1alpha1.Cluster, error)
	// Update updates a cluster (special handler intended to be used only by the gRPC gateway)
	UpdateREST(ctx context.Context, in *ClusterUpdateRequest, opts ...grpc.CallOption) (*github_com_argoproj_argo_cd_pkg_apis_application_v1alpha1.Cluster, error)
	// Delete updates a cluster
	Delete(ctx context.Context, in *ClusterQuery, opts ...grpc.CallOption) (*ClusterResponse, error)
	// ListPods returns pods in a cluster
	ListPods(ctx context.Context, in *ClusterQuery, opts ...grpc.CallOption) (*k8s_io_api_core_v1.PodList, error)
}

func NewClusterServiceClient 

func NewClusterServiceClient(cc *grpc.ClientConn) ClusterServiceClient

type ClusterServiceServer 

type ClusterServiceServer interface {
	// List returns list of clusters
	List(context.Context, *ClusterQuery) (*github_com_argoproj_argo_cd_pkg_apis_application_v1alpha1.ClusterList, error)
	// Create creates a cluster
	Create(context.Context, *github_com_argoproj_argo_cd_pkg_apis_application_v1alpha1.Cluster) (*github_com_argoproj_argo_cd_pkg_apis_application_v1alpha1.Cluster, error)
	// Get returns a cluster by server address
	Get(context.Context, *ClusterQuery) (*github_com_argoproj_argo_cd_pkg_apis_application_v1alpha1.Cluster, error)
	// Update updates a cluster
	Update(context.Context, *github_com_argoproj_argo_cd_pkg_apis_application_v1alpha1.Cluster) (*github_com_argoproj_argo_cd_pkg_apis_application_v1alpha1.Cluster, error)
	// Update updates a cluster (special handler intended to be used only by the gRPC gateway)
	UpdateREST(context.Context, *ClusterUpdateRequest) (*github_com_argoproj_argo_cd_pkg_apis_application_v1alpha1.Cluster, error)
	// Delete updates a cluster
	Delete(context.Context, *ClusterQuery) (*ClusterResponse, error)
	// ListPods returns pods in a cluster
	ListPods(context.Context, *ClusterQuery) (*k8s_io_api_core_v1.PodList, error)
}

type ClusterUpdateRequest 

type ClusterUpdateRequest struct {
	Server  string                                                             `protobuf:"bytes,1,opt,name=server" json:"server,omitempty"`
	Cluster *github_com_argoproj_argo_cd_pkg_apis_application_v1alpha1.Cluster `protobuf:"bytes,2,opt,name=cluster" json:"cluster,omitempty"`
}

func (*ClusterUpdateRequest) Descriptor 

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

func (*ClusterUpdateRequest) GetCluster 

func (m *ClusterUpdateRequest) GetCluster() *github_com_argoproj_argo_cd_pkg_apis_application_v1alpha1.Cluster

func (*ClusterUpdateRequest) GetServer 

func (m *ClusterUpdateRequest) GetServer() string

func (*ClusterUpdateRequest) ProtoMessage 

func (*ClusterUpdateRequest) ProtoMessage()

func (*ClusterUpdateRequest) Reset 

func (m *ClusterUpdateRequest) Reset()

func (*ClusterUpdateRequest) String 

func (m *ClusterUpdateRequest) String() string

type Server 

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

Server provides a Cluster service

func NewServer 

func NewServer(namespace string, kubeclientset kubernetes.Interface, appclientset appclientset.Interface) *Server

NewServer returns a new instance of the Cluster service

func (*Server) Create 

func (s *Server) Create(ctx context.Context, c *appv1.Cluster) (*appv1.Cluster, error)

Create creates a cluster

func (*Server) Delete 

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

Delete deletes a cluster by name

func (*Server) Get 

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

Get returns a cluster from a query

func (*Server) List 

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

List returns list of clusters

func (*Server) ListPods 

func (s *Server) ListPods(ctx context.Context, q *ClusterQuery) (*apiv1.PodList, error)

ListPods returns application related pods in a cluster

func (*Server) Update 

func (s *Server) Update(ctx context.Context, c *appv1.Cluster) (*appv1.Cluster, error)

Update updates a cluster

func (*Server) UpdateREST 

func (s *Server) UpdateREST(ctx context.Context, r *ClusterUpdateRequest) (*appv1.Cluster, error)

UpdateREST updates a cluster (special handler intended to be used only by the gRPC gateway)

func (*Server) WatchClusters added in v0.3.0 

func (s *Server) WatchClusters(ctx context.Context, callback func(*ClusterEvent)) error

WatchClusters allow watching for cluster events

Source Files

View all Source files

Directories

Path Synopsis
Code generated by mockery v1.0.0
 Code generated by mockery v1.0.0

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.