Documentation ¶
Overview ¶
Package cluster is a reverse proxy.
It translates gRPC into RESTful JSON APIs.
Index ¶
- Variables
- func RegisterClusterServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
- func RegisterClusterServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ClusterServiceClient) error
- func RegisterClusterServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)
- func RegisterClusterServiceServer(s *grpc.Server, srv ClusterServiceServer)
- type ClusterCreateFromKubeConfigRequest
- func (*ClusterCreateFromKubeConfigRequest) Descriptor() ([]byte, []int)
- func (m *ClusterCreateFromKubeConfigRequest) GetContext() string
- func (m *ClusterCreateFromKubeConfigRequest) GetInCluster() bool
- func (m *ClusterCreateFromKubeConfigRequest) GetKubeconfig() string
- func (m *ClusterCreateFromKubeConfigRequest) GetUpsert() bool
- func (m *ClusterCreateFromKubeConfigRequest) Marshal() (dAtA []byte, err error)
- func (m *ClusterCreateFromKubeConfigRequest) MarshalTo(dAtA []byte) (int, error)
- func (*ClusterCreateFromKubeConfigRequest) ProtoMessage()
- func (m *ClusterCreateFromKubeConfigRequest) Reset()
- func (m *ClusterCreateFromKubeConfigRequest) Size() (n int)
- func (m *ClusterCreateFromKubeConfigRequest) String() string
- func (m *ClusterCreateFromKubeConfigRequest) Unmarshal(dAtA []byte) error
- func (m *ClusterCreateFromKubeConfigRequest) XXX_DiscardUnknown()
- func (m *ClusterCreateFromKubeConfigRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *ClusterCreateFromKubeConfigRequest) XXX_Merge(src proto.Message)
- func (m *ClusterCreateFromKubeConfigRequest) XXX_Size() int
- func (m *ClusterCreateFromKubeConfigRequest) XXX_Unmarshal(b []byte) error
- type ClusterCreateRequest
- func (*ClusterCreateRequest) Descriptor() ([]byte, []int)
- func (m *ClusterCreateRequest) GetCluster() *v1alpha1.Cluster
- func (m *ClusterCreateRequest) GetUpsert() bool
- func (m *ClusterCreateRequest) Marshal() (dAtA []byte, err error)
- func (m *ClusterCreateRequest) MarshalTo(dAtA []byte) (int, error)
- func (*ClusterCreateRequest) ProtoMessage()
- func (m *ClusterCreateRequest) Reset()
- func (m *ClusterCreateRequest) Size() (n int)
- func (m *ClusterCreateRequest) String() string
- func (m *ClusterCreateRequest) Unmarshal(dAtA []byte) error
- func (m *ClusterCreateRequest) XXX_DiscardUnknown()
- func (m *ClusterCreateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *ClusterCreateRequest) XXX_Merge(src proto.Message)
- func (m *ClusterCreateRequest) XXX_Size() int
- func (m *ClusterCreateRequest) XXX_Unmarshal(b []byte) error
- type ClusterQuery
- func (*ClusterQuery) Descriptor() ([]byte, []int)
- func (m *ClusterQuery) GetServer() string
- func (m *ClusterQuery) Marshal() (dAtA []byte, err error)
- func (m *ClusterQuery) MarshalTo(dAtA []byte) (int, error)
- func (*ClusterQuery) ProtoMessage()
- func (m *ClusterQuery) Reset()
- func (m *ClusterQuery) Size() (n int)
- func (m *ClusterQuery) String() string
- func (m *ClusterQuery) Unmarshal(dAtA []byte) error
- func (m *ClusterQuery) XXX_DiscardUnknown()
- func (m *ClusterQuery) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *ClusterQuery) XXX_Merge(src proto.Message)
- func (m *ClusterQuery) XXX_Size() int
- func (m *ClusterQuery) XXX_Unmarshal(b []byte) error
- type ClusterResponse
- func (*ClusterResponse) Descriptor() ([]byte, []int)
- func (m *ClusterResponse) Marshal() (dAtA []byte, err error)
- func (m *ClusterResponse) MarshalTo(dAtA []byte) (int, error)
- func (*ClusterResponse) ProtoMessage()
- func (m *ClusterResponse) Reset()
- func (m *ClusterResponse) Size() (n int)
- func (m *ClusterResponse) String() string
- func (m *ClusterResponse) Unmarshal(dAtA []byte) error
- func (m *ClusterResponse) XXX_DiscardUnknown()
- func (m *ClusterResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *ClusterResponse) XXX_Merge(src proto.Message)
- func (m *ClusterResponse) XXX_Size() int
- func (m *ClusterResponse) XXX_Unmarshal(b []byte) error
- type ClusterServiceClient
- type ClusterServiceServer
- type ClusterUpdateRequest
- func (*ClusterUpdateRequest) Descriptor() ([]byte, []int)
- func (m *ClusterUpdateRequest) GetCluster() *v1alpha1.Cluster
- func (m *ClusterUpdateRequest) Marshal() (dAtA []byte, err error)
- func (m *ClusterUpdateRequest) MarshalTo(dAtA []byte) (int, error)
- func (*ClusterUpdateRequest) ProtoMessage()
- func (m *ClusterUpdateRequest) Reset()
- func (m *ClusterUpdateRequest) Size() (n int)
- func (m *ClusterUpdateRequest) String() string
- func (m *ClusterUpdateRequest) Unmarshal(dAtA []byte) error
- func (m *ClusterUpdateRequest) XXX_DiscardUnknown()
- func (m *ClusterUpdateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *ClusterUpdateRequest) XXX_Merge(src proto.Message)
- func (m *ClusterUpdateRequest) XXX_Size() int
- func (m *ClusterUpdateRequest) XXX_Unmarshal(b []byte) error
- type Server
- func (s *Server) Create(ctx context.Context, q *ClusterCreateRequest) (*appv1.Cluster, error)
- func (s *Server) CreateFromKubeConfig(ctx context.Context, q *ClusterCreateFromKubeConfigRequest) (*appv1.Cluster, error)
- func (s *Server) Delete(ctx context.Context, q *ClusterQuery) (*ClusterResponse, error)
- func (s *Server) Get(ctx context.Context, q *ClusterQuery) (*appv1.Cluster, error)
- func (s *Server) List(ctx context.Context, q *ClusterQuery) (*appv1.ClusterList, error)
- func (s *Server) Update(ctx context.Context, q *ClusterUpdateRequest) (*appv1.Cluster, error)
Constants ¶
This section is empty.
Variables ¶
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 ClusterCreateFromKubeConfigRequest ¶
type ClusterCreateFromKubeConfigRequest struct { Kubeconfig string `protobuf:"bytes,1,opt,name=kubeconfig,proto3" json:"kubeconfig,omitempty"` Context string `protobuf:"bytes,2,opt,name=context,proto3" json:"context,omitempty"` Upsert bool `protobuf:"varint,3,opt,name=upsert,proto3" json:"upsert,omitempty"` InCluster bool `protobuf:"varint,4,opt,name=inCluster,proto3" json:"inCluster,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ClusterCreateFromKubeConfigRequest) Descriptor ¶
func (*ClusterCreateFromKubeConfigRequest) Descriptor() ([]byte, []int)
func (*ClusterCreateFromKubeConfigRequest) GetContext ¶
func (m *ClusterCreateFromKubeConfigRequest) GetContext() string
func (*ClusterCreateFromKubeConfigRequest) GetInCluster ¶
func (m *ClusterCreateFromKubeConfigRequest) GetInCluster() bool
func (*ClusterCreateFromKubeConfigRequest) GetKubeconfig ¶
func (m *ClusterCreateFromKubeConfigRequest) GetKubeconfig() string
func (*ClusterCreateFromKubeConfigRequest) GetUpsert ¶
func (m *ClusterCreateFromKubeConfigRequest) GetUpsert() bool
func (*ClusterCreateFromKubeConfigRequest) Marshal ¶
func (m *ClusterCreateFromKubeConfigRequest) Marshal() (dAtA []byte, err error)
func (*ClusterCreateFromKubeConfigRequest) MarshalTo ¶
func (m *ClusterCreateFromKubeConfigRequest) MarshalTo(dAtA []byte) (int, error)
func (*ClusterCreateFromKubeConfigRequest) ProtoMessage ¶
func (*ClusterCreateFromKubeConfigRequest) ProtoMessage()
func (*ClusterCreateFromKubeConfigRequest) Reset ¶
func (m *ClusterCreateFromKubeConfigRequest) Reset()
func (*ClusterCreateFromKubeConfigRequest) Size ¶
func (m *ClusterCreateFromKubeConfigRequest) Size() (n int)
func (*ClusterCreateFromKubeConfigRequest) String ¶
func (m *ClusterCreateFromKubeConfigRequest) String() string
func (*ClusterCreateFromKubeConfigRequest) Unmarshal ¶
func (m *ClusterCreateFromKubeConfigRequest) Unmarshal(dAtA []byte) error
func (*ClusterCreateFromKubeConfigRequest) XXX_DiscardUnknown ¶
func (m *ClusterCreateFromKubeConfigRequest) XXX_DiscardUnknown()
func (*ClusterCreateFromKubeConfigRequest) XXX_Marshal ¶
func (m *ClusterCreateFromKubeConfigRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ClusterCreateFromKubeConfigRequest) XXX_Merge ¶
func (dst *ClusterCreateFromKubeConfigRequest) XXX_Merge(src proto.Message)
func (*ClusterCreateFromKubeConfigRequest) XXX_Size ¶
func (m *ClusterCreateFromKubeConfigRequest) XXX_Size() int
func (*ClusterCreateFromKubeConfigRequest) XXX_Unmarshal ¶
func (m *ClusterCreateFromKubeConfigRequest) XXX_Unmarshal(b []byte) error
type ClusterCreateRequest ¶
type ClusterCreateRequest struct { Cluster *v1alpha1.Cluster `protobuf:"bytes,1,opt,name=cluster" json:"cluster,omitempty"` Upsert bool `protobuf:"varint,2,opt,name=upsert,proto3" json:"upsert,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ClusterCreateRequest) Descriptor ¶
func (*ClusterCreateRequest) Descriptor() ([]byte, []int)
func (*ClusterCreateRequest) GetCluster ¶
func (m *ClusterCreateRequest) GetCluster() *v1alpha1.Cluster
func (*ClusterCreateRequest) GetUpsert ¶
func (m *ClusterCreateRequest) GetUpsert() bool
func (*ClusterCreateRequest) Marshal ¶
func (m *ClusterCreateRequest) Marshal() (dAtA []byte, err error)
func (*ClusterCreateRequest) MarshalTo ¶
func (m *ClusterCreateRequest) MarshalTo(dAtA []byte) (int, error)
func (*ClusterCreateRequest) ProtoMessage ¶
func (*ClusterCreateRequest) ProtoMessage()
func (*ClusterCreateRequest) Reset ¶
func (m *ClusterCreateRequest) Reset()
func (*ClusterCreateRequest) Size ¶
func (m *ClusterCreateRequest) Size() (n int)
func (*ClusterCreateRequest) String ¶
func (m *ClusterCreateRequest) String() string
func (*ClusterCreateRequest) Unmarshal ¶
func (m *ClusterCreateRequest) Unmarshal(dAtA []byte) error
func (*ClusterCreateRequest) XXX_DiscardUnknown ¶
func (m *ClusterCreateRequest) XXX_DiscardUnknown()
func (*ClusterCreateRequest) XXX_Marshal ¶
func (m *ClusterCreateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ClusterCreateRequest) XXX_Merge ¶
func (dst *ClusterCreateRequest) XXX_Merge(src proto.Message)
func (*ClusterCreateRequest) XXX_Size ¶
func (m *ClusterCreateRequest) XXX_Size() int
func (*ClusterCreateRequest) XXX_Unmarshal ¶
func (m *ClusterCreateRequest) XXX_Unmarshal(b []byte) error
type ClusterQuery ¶
type ClusterQuery struct { Server string `protobuf:"bytes,1,opt,name=server,proto3" json:"server,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
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) 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
func (*ClusterQuery) XXX_DiscardUnknown ¶
func (m *ClusterQuery) XXX_DiscardUnknown()
func (*ClusterQuery) XXX_Marshal ¶
func (m *ClusterQuery) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ClusterQuery) XXX_Merge ¶
func (dst *ClusterQuery) XXX_Merge(src proto.Message)
func (*ClusterQuery) XXX_Size ¶
func (m *ClusterQuery) XXX_Size() int
func (*ClusterQuery) XXX_Unmarshal ¶
func (m *ClusterQuery) XXX_Unmarshal(b []byte) error
type ClusterResponse ¶
type ClusterResponse struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ClusterResponse) Descriptor ¶
func (*ClusterResponse) Descriptor() ([]byte, []int)
func (*ClusterResponse) Marshal ¶
func (m *ClusterResponse) Marshal() (dAtA []byte, err 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
func (*ClusterResponse) XXX_DiscardUnknown ¶
func (m *ClusterResponse) XXX_DiscardUnknown()
func (*ClusterResponse) XXX_Marshal ¶
func (m *ClusterResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ClusterResponse) XXX_Merge ¶
func (dst *ClusterResponse) XXX_Merge(src proto.Message)
func (*ClusterResponse) XXX_Size ¶
func (m *ClusterResponse) XXX_Size() int
func (*ClusterResponse) XXX_Unmarshal ¶
func (m *ClusterResponse) XXX_Unmarshal(b []byte) error
type ClusterServiceClient ¶
type ClusterServiceClient interface { // List returns list of clusters List(ctx context.Context, in *ClusterQuery, opts ...grpc.CallOption) (*v1alpha1.ClusterList, error) // Create creates a cluster Create(ctx context.Context, in *ClusterCreateRequest, opts ...grpc.CallOption) (*v1alpha1.Cluster, error) // CreateFromKubeConfig installs the argocd-manager service account into the cluster specified in the given kubeconfig and context CreateFromKubeConfig(ctx context.Context, in *ClusterCreateFromKubeConfigRequest, opts ...grpc.CallOption) (*v1alpha1.Cluster, error) // Get returns a cluster by server address Get(ctx context.Context, in *ClusterQuery, opts ...grpc.CallOption) (*v1alpha1.Cluster, error) // Update updates a cluster Update(ctx context.Context, in *ClusterUpdateRequest, opts ...grpc.CallOption) (*v1alpha1.Cluster, error) // Delete deletes a cluster Delete(ctx context.Context, in *ClusterQuery, opts ...grpc.CallOption) (*ClusterResponse, error) }
func NewClusterServiceClient ¶
func NewClusterServiceClient(cc *grpc.ClientConn) ClusterServiceClient
type ClusterServiceServer ¶
type ClusterServiceServer interface { // List returns list of clusters List(context.Context, *ClusterQuery) (*v1alpha1.ClusterList, error) // Create creates a cluster Create(context.Context, *ClusterCreateRequest) (*v1alpha1.Cluster, error) // CreateFromKubeConfig installs the argocd-manager service account into the cluster specified in the given kubeconfig and context CreateFromKubeConfig(context.Context, *ClusterCreateFromKubeConfigRequest) (*v1alpha1.Cluster, error) // Get returns a cluster by server address Get(context.Context, *ClusterQuery) (*v1alpha1.Cluster, error) // Update updates a cluster Update(context.Context, *ClusterUpdateRequest) (*v1alpha1.Cluster, error) // Delete deletes a cluster Delete(context.Context, *ClusterQuery) (*ClusterResponse, error) }
type ClusterUpdateRequest ¶
type ClusterUpdateRequest struct { Cluster *v1alpha1.Cluster `protobuf:"bytes,1,opt,name=cluster" json:"cluster,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ClusterUpdateRequest) Descriptor ¶
func (*ClusterUpdateRequest) Descriptor() ([]byte, []int)
func (*ClusterUpdateRequest) GetCluster ¶
func (m *ClusterUpdateRequest) GetCluster() *v1alpha1.Cluster
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
func (*ClusterUpdateRequest) XXX_DiscardUnknown ¶
func (m *ClusterUpdateRequest) XXX_DiscardUnknown()
func (*ClusterUpdateRequest) XXX_Marshal ¶
func (m *ClusterUpdateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ClusterUpdateRequest) XXX_Merge ¶
func (dst *ClusterUpdateRequest) XXX_Merge(src proto.Message)
func (*ClusterUpdateRequest) XXX_Size ¶
func (m *ClusterUpdateRequest) XXX_Size() int
func (*ClusterUpdateRequest) XXX_Unmarshal ¶
func (m *ClusterUpdateRequest) XXX_Unmarshal(b []byte) error
type Server ¶
type Server struct {
// contains filtered or unexported fields
}
Server provides a Cluster service
func (*Server) CreateFromKubeConfig ¶
func (s *Server) CreateFromKubeConfig(ctx context.Context, q *ClusterCreateFromKubeConfigRequest) (*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) List ¶
func (s *Server) List(ctx context.Context, q *ClusterQuery) (*appv1.ClusterList, error)
List returns list of clusters