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

    View Source
    var (
    	ErrInvalidLengthCluster = fmt.Errorf("proto: negative length found during unmarshaling")
    	ErrIntOverflowCluster   = fmt.Errorf("proto: integer overflow")
    )

    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 ClusterQuery

          type ClusterQuery struct {
          	Server string `protobuf:"bytes,1,opt,name=server,proto3" 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) Marshal

            func (m *ClusterQuery) Marshal() (dAtA []byte, err error)

            func (*ClusterQuery) MarshalTo

            func (m *ClusterQuery) MarshalTo(dAtA []byte) (int, error)

            func (*ClusterQuery) ProtoMessage

            func (*ClusterQuery) ProtoMessage()

            func (*ClusterQuery) Reset

            func (m *ClusterQuery) Reset()

            func (*ClusterQuery) Size

            func (m *ClusterQuery) Size() (n int)

            func (*ClusterQuery) String

            func (m *ClusterQuery) String() string

            func (*ClusterQuery) Unmarshal

            func (m *ClusterQuery) Unmarshal(dAtA []byte) error

            type ClusterResponse

            type ClusterResponse struct {
            }

            func (*ClusterResponse) Descriptor

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

            func (*ClusterResponse) Marshal

            func (m *ClusterResponse) Marshal() (dAtA []byte, err error)

            func (*ClusterResponse) MarshalTo

            func (m *ClusterResponse) MarshalTo(dAtA []byte) (int, error)

            func (*ClusterResponse) ProtoMessage

            func (*ClusterResponse) ProtoMessage()

            func (*ClusterResponse) Reset

            func (m *ClusterResponse) Reset()

            func (*ClusterResponse) Size

            func (m *ClusterResponse) Size() (n int)

            func (*ClusterResponse) String

            func (m *ClusterResponse) String() string

            func (*ClusterResponse) Unmarshal

            func (m *ClusterResponse) Unmarshal(dAtA []byte) error

            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)
            }

            func NewClusterServiceClient

            func NewClusterServiceClient(cc *grpc.ClientConn) ClusterServiceClient

            type ClusterUpdateRequest

            type ClusterUpdateRequest struct {
            	Server  string                                                             `protobuf:"bytes,1,opt,name=server,proto3" 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) GetServer

            func (m *ClusterUpdateRequest) GetServer() string

            func (*ClusterUpdateRequest) Marshal

            func (m *ClusterUpdateRequest) Marshal() (dAtA []byte, err error)

            func (*ClusterUpdateRequest) MarshalTo

            func (m *ClusterUpdateRequest) MarshalTo(dAtA []byte) (int, error)

            func (*ClusterUpdateRequest) ProtoMessage

            func (*ClusterUpdateRequest) ProtoMessage()

            func (*ClusterUpdateRequest) Reset

            func (m *ClusterUpdateRequest) Reset()

            func (*ClusterUpdateRequest) Size

            func (m *ClusterUpdateRequest) Size() (n int)

            func (*ClusterUpdateRequest) String

            func (m *ClusterUpdateRequest) String() string

            func (*ClusterUpdateRequest) Unmarshal

            func (m *ClusterUpdateRequest) Unmarshal(dAtA []byte) error

            type Server

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

              Server provides a Cluster service

              func NewServer

              func NewServer(db db.ArgoDB) *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) 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)

                            Directories

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