Help us shape the future of Go! Take the 2026 Go Developer Survey

cluster

package
v0.10.4 Latest Latest
Warning

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

 Go to latest Published: Nov 8, 2018 License: Apache-2.0 Imports: 25 Imported by: 0

Documentation

Overview

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 ClusterCreateFromKubeConfigRequest added in v0.8.0 

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 added in v0.8.0 

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

func (*ClusterCreateFromKubeConfigRequest) GetContext added in v0.8.0 

func (m *ClusterCreateFromKubeConfigRequest) GetContext() string

func (*ClusterCreateFromKubeConfigRequest) GetInCluster added in v0.8.0 

func (m *ClusterCreateFromKubeConfigRequest) GetInCluster() bool

func (*ClusterCreateFromKubeConfigRequest) GetKubeconfig added in v0.8.0 

func (m *ClusterCreateFromKubeConfigRequest) GetKubeconfig() string

func (*ClusterCreateFromKubeConfigRequest) GetUpsert added in v0.8.0 

func (m *ClusterCreateFromKubeConfigRequest) GetUpsert() bool

func (*ClusterCreateFromKubeConfigRequest) Marshal added in v0.8.0 

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

func (*ClusterCreateFromKubeConfigRequest) MarshalTo added in v0.8.0 

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

func (*ClusterCreateFromKubeConfigRequest) ProtoMessage added in v0.8.0 

func (*ClusterCreateFromKubeConfigRequest) ProtoMessage()

func (*ClusterCreateFromKubeConfigRequest) Reset added in v0.8.0 

func (m *ClusterCreateFromKubeConfigRequest) Reset()

func (*ClusterCreateFromKubeConfigRequest) Size added in v0.8.0 

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

func (*ClusterCreateFromKubeConfigRequest) String added in v0.8.0 

func (m *ClusterCreateFromKubeConfigRequest) String() string

func (*ClusterCreateFromKubeConfigRequest) Unmarshal added in v0.8.0 

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

func (*ClusterCreateFromKubeConfigRequest) XXX_DiscardUnknown added in v0.9.0 

func (m *ClusterCreateFromKubeConfigRequest) XXX_DiscardUnknown()

func (*ClusterCreateFromKubeConfigRequest) XXX_Marshal added in v0.9.0 

func (m *ClusterCreateFromKubeConfigRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ClusterCreateFromKubeConfigRequest) XXX_Merge added in v0.9.0 

func (dst *ClusterCreateFromKubeConfigRequest) XXX_Merge(src proto.Message)

func (*ClusterCreateFromKubeConfigRequest) XXX_Size added in v0.9.0 

func (m *ClusterCreateFromKubeConfigRequest) XXX_Size() int

func (*ClusterCreateFromKubeConfigRequest) XXX_Unmarshal added in v0.9.0 

func (m *ClusterCreateFromKubeConfigRequest) XXX_Unmarshal(b []byte) error

type ClusterCreateRequest added in v0.5.0 

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 added in v0.5.0 

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

func (*ClusterCreateRequest) GetCluster added in v0.5.0 

func (m *ClusterCreateRequest) GetCluster() *v1alpha1.Cluster

func (*ClusterCreateRequest) GetUpsert added in v0.6.0 

func (m *ClusterCreateRequest) GetUpsert() bool

func (*ClusterCreateRequest) Marshal added in v0.5.0 

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

func (*ClusterCreateRequest) MarshalTo added in v0.5.0 

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

func (*ClusterCreateRequest) ProtoMessage added in v0.5.0 

func (*ClusterCreateRequest) ProtoMessage()

func (*ClusterCreateRequest) Reset added in v0.5.0 

func (m *ClusterCreateRequest) Reset()

func (*ClusterCreateRequest) Size added in v0.5.0 

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

func (*ClusterCreateRequest) String added in v0.5.0 

func (m *ClusterCreateRequest) String() string

func (*ClusterCreateRequest) Unmarshal added in v0.5.0 

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

func (*ClusterCreateRequest) XXX_DiscardUnknown added in v0.9.0 

func (m *ClusterCreateRequest) XXX_DiscardUnknown()

func (*ClusterCreateRequest) XXX_Marshal added in v0.9.0 

func (m *ClusterCreateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ClusterCreateRequest) XXX_Merge added in v0.9.0 

func (dst *ClusterCreateRequest) XXX_Merge(src proto.Message)

func (*ClusterCreateRequest) XXX_Size added in v0.9.0 

func (m *ClusterCreateRequest) XXX_Size() int

func (*ClusterCreateRequest) XXX_Unmarshal added in v0.9.0 

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 added in v0.3.1 

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

func (*ClusterQuery) MarshalTo added in v0.3.1 

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

func (*ClusterQuery) ProtoMessage 

func (*ClusterQuery) ProtoMessage()

func (*ClusterQuery) Reset 

func (m *ClusterQuery) Reset()

func (*ClusterQuery) Size added in v0.3.1 

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

func (*ClusterQuery) String 

func (m *ClusterQuery) String() string

func (*ClusterQuery) Unmarshal added in v0.3.1 

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

func (*ClusterQuery) XXX_DiscardUnknown added in v0.9.0 

func (m *ClusterQuery) XXX_DiscardUnknown()

func (*ClusterQuery) XXX_Marshal added in v0.9.0 

func (m *ClusterQuery) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ClusterQuery) XXX_Merge added in v0.9.0 

func (dst *ClusterQuery) XXX_Merge(src proto.Message)

func (*ClusterQuery) XXX_Size added in v0.9.0 

func (m *ClusterQuery) XXX_Size() int

func (*ClusterQuery) XXX_Unmarshal added in v0.9.0 

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 added in v0.3.1 

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

func (*ClusterResponse) MarshalTo added in v0.3.1 

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

func (*ClusterResponse) ProtoMessage 

func (*ClusterResponse) ProtoMessage()

func (*ClusterResponse) Reset 

func (m *ClusterResponse) Reset()

func (*ClusterResponse) Size added in v0.3.1 

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

func (*ClusterResponse) String 

func (m *ClusterResponse) String() string

func (*ClusterResponse) Unmarshal added in v0.3.1 

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

func (*ClusterResponse) XXX_DiscardUnknown added in v0.9.0 

func (m *ClusterResponse) XXX_DiscardUnknown()

func (*ClusterResponse) XXX_Marshal added in v0.9.0 

func (m *ClusterResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ClusterResponse) XXX_Merge added in v0.9.0 

func (dst *ClusterResponse) XXX_Merge(src proto.Message)

func (*ClusterResponse) XXX_Size added in v0.9.0 

func (m *ClusterResponse) XXX_Size() int

func (*ClusterResponse) XXX_Unmarshal added in v0.9.0 

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 added in v0.3.1 

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

func (*ClusterUpdateRequest) MarshalTo added in v0.3.1 

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

func (*ClusterUpdateRequest) ProtoMessage 

func (*ClusterUpdateRequest) ProtoMessage()

func (*ClusterUpdateRequest) Reset 

func (m *ClusterUpdateRequest) Reset()

func (*ClusterUpdateRequest) Size added in v0.3.1 

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

func (*ClusterUpdateRequest) String 

func (m *ClusterUpdateRequest) String() string

func (*ClusterUpdateRequest) Unmarshal added in v0.3.1 

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

func (*ClusterUpdateRequest) XXX_DiscardUnknown added in v0.9.0 

func (m *ClusterUpdateRequest) XXX_DiscardUnknown()

func (*ClusterUpdateRequest) XXX_Marshal added in v0.9.0 

func (m *ClusterUpdateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ClusterUpdateRequest) XXX_Merge added in v0.9.0 

func (dst *ClusterUpdateRequest) XXX_Merge(src proto.Message)

func (*ClusterUpdateRequest) XXX_Size added in v0.9.0 

func (m *ClusterUpdateRequest) XXX_Size() int

func (*ClusterUpdateRequest) XXX_Unmarshal added in v0.9.0 

func (m *ClusterUpdateRequest) XXX_Unmarshal(b []byte) error

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) *Server

NewServer returns a new instance of the Cluster service

func (*Server) Create 

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

Create creates a cluster

func (*Server) CreateFromKubeConfig added in v0.8.0 

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) 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, q *ClusterUpdateRequest) (*appv1.Cluster, error)

Update updates a cluster

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.