dbaasv1beta1

package
v2.10.1+incompatible Latest Latest
Warning

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

 Go to latest Published: Sep 17, 2020 License: AGPL-3.0 Imports: 15 Imported by: 0

Documentation

Overview

Package dbaasv1beta1 is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterKubernetesHandler 

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

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

func RegisterKubernetesHandlerClient 

func RegisterKubernetesHandlerClient(ctx context.Context, mux *runtime.ServeMux, client KubernetesClient) error

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

func RegisterKubernetesHandlerFromEndpoint 

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

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

func RegisterKubernetesHandlerServer 

func RegisterKubernetesHandlerServer(ctx context.Context, mux *runtime.ServeMux, server KubernetesServer) error

RegisterKubernetesHandlerServer registers the http handlers for service Kubernetes to "mux". UnaryRPC :call KubernetesServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906.

func RegisterKubernetesServer 

func RegisterKubernetesServer(s *grpc.Server, srv KubernetesServer)

Types

type KubeAuth 

type KubeAuth struct {
	// Kubeconfig file content.
	Kubeconfig           string   `protobuf:"bytes,1,opt,name=kubeconfig,proto3" json:"kubeconfig,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

KubeAuth represents Kubernetes / kubectl authentication and authorization information.

func (*KubeAuth) Descriptor 

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

func (*KubeAuth) GetKubeconfig 

func (m *KubeAuth) GetKubeconfig() string

func (*KubeAuth) ProtoMessage 

func (*KubeAuth) ProtoMessage()

func (*KubeAuth) Reset 

func (m *KubeAuth) Reset()

func (*KubeAuth) String 

func (m *KubeAuth) String() string

func (*KubeAuth) Validate 

func (this *KubeAuth) Validate() error

func (*KubeAuth) XXX_DiscardUnknown 

func (m *KubeAuth) XXX_DiscardUnknown()

func (*KubeAuth) XXX_Marshal 

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

func (*KubeAuth) XXX_Merge 

func (m *KubeAuth) XXX_Merge(src proto.Message)

func (*KubeAuth) XXX_Size 

func (m *KubeAuth) XXX_Size() int

func (*KubeAuth) XXX_Unmarshal 

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

type KubernetesClient 

type KubernetesClient interface {
	// ListKubernetesClusters returns a list of all registered Kubernetes clusters.
	ListKubernetesClusters(ctx context.Context, in *ListKubernetesClustersRequest, opts ...grpc.CallOption) (*ListKubernetesClustersResponse, error)
	// RegisterKubernetesCluster registers an existing Kubernetes cluster in PMM.
	RegisterKubernetesCluster(ctx context.Context, in *RegisterKubernetesClusterRequest, opts ...grpc.CallOption) (*RegisterKubernetesClusterResponse, error)
	// UnregisterKubernetesCluster removes a registered Kubernetes cluster from PMM.
	UnregisterKubernetesCluster(ctx context.Context, in *UnregisterKubernetesClusterRequest, opts ...grpc.CallOption) (*UnregisterKubernetesClusterResponse, error)
}

KubernetesClient is the client API for Kubernetes service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewKubernetesClient 

func NewKubernetesClient(cc grpc.ClientConnInterface) KubernetesClient

type KubernetesServer 

type KubernetesServer interface {
	// ListKubernetesClusters returns a list of all registered Kubernetes clusters.
	ListKubernetesClusters(context.Context, *ListKubernetesClustersRequest) (*ListKubernetesClustersResponse, error)
	// RegisterKubernetesCluster registers an existing Kubernetes cluster in PMM.
	RegisterKubernetesCluster(context.Context, *RegisterKubernetesClusterRequest) (*RegisterKubernetesClusterResponse, error)
	// UnregisterKubernetesCluster removes a registered Kubernetes cluster from PMM.
	UnregisterKubernetesCluster(context.Context, *UnregisterKubernetesClusterRequest) (*UnregisterKubernetesClusterResponse, error)
}

KubernetesServer is the server API for Kubernetes service.

type ListKubernetesClustersRequest 

type ListKubernetesClustersRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListKubernetesClustersRequest) Descriptor 

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

func (*ListKubernetesClustersRequest) ProtoMessage 

func (*ListKubernetesClustersRequest) ProtoMessage()

func (*ListKubernetesClustersRequest) Reset 

func (m *ListKubernetesClustersRequest) Reset()

func (*ListKubernetesClustersRequest) String 

func (m *ListKubernetesClustersRequest) String() string

func (*ListKubernetesClustersRequest) Validate 

func (this *ListKubernetesClustersRequest) Validate() error

func (*ListKubernetesClustersRequest) XXX_DiscardUnknown 

func (m *ListKubernetesClustersRequest) XXX_DiscardUnknown()

func (*ListKubernetesClustersRequest) XXX_Marshal 

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

func (*ListKubernetesClustersRequest) XXX_Merge 

func (m *ListKubernetesClustersRequest) XXX_Merge(src proto.Message)

func (*ListKubernetesClustersRequest) XXX_Size 

func (m *ListKubernetesClustersRequest) XXX_Size() int

func (*ListKubernetesClustersRequest) XXX_Unmarshal 

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

type ListKubernetesClustersResponse 

type ListKubernetesClustersResponse struct {
	// Kubernetes clusters.
	KubernetesClusters   []*ListKubernetesClustersResponse_Cluster `protobuf:"bytes,1,rep,name=kubernetes_clusters,json=kubernetesClusters,proto3" json:"kubernetes_clusters,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                                  `json:"-"`
	XXX_unrecognized     []byte                                    `json:"-"`
	XXX_sizecache        int32                                     `json:"-"`
}

func (*ListKubernetesClustersResponse) Descriptor 

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

func (*ListKubernetesClustersResponse) GetKubernetesClusters 

func (m *ListKubernetesClustersResponse) GetKubernetesClusters() []*ListKubernetesClustersResponse_Cluster

func (*ListKubernetesClustersResponse) ProtoMessage 

func (*ListKubernetesClustersResponse) ProtoMessage()

func (*ListKubernetesClustersResponse) Reset 

func (m *ListKubernetesClustersResponse) Reset()

func (*ListKubernetesClustersResponse) String 

func (m *ListKubernetesClustersResponse) String() string

func (*ListKubernetesClustersResponse) Validate 

func (this *ListKubernetesClustersResponse) Validate() error

func (*ListKubernetesClustersResponse) XXX_DiscardUnknown 

func (m *ListKubernetesClustersResponse) XXX_DiscardUnknown()

func (*ListKubernetesClustersResponse) XXX_Marshal 

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

func (*ListKubernetesClustersResponse) XXX_Merge 

func (m *ListKubernetesClustersResponse) XXX_Merge(src proto.Message)

func (*ListKubernetesClustersResponse) XXX_Size 

func (m *ListKubernetesClustersResponse) XXX_Size() int

func (*ListKubernetesClustersResponse) XXX_Unmarshal 

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

type ListKubernetesClustersResponse_Cluster 

type ListKubernetesClustersResponse_Cluster struct {
	// Kubernetes cluster name.
	KubernetesClusterName string   `` /* 126-byte string literal not displayed */
	XXX_NoUnkeyedLiteral  struct{} `json:"-"`
	XXX_unrecognized      []byte   `json:"-"`
	XXX_sizecache         int32    `json:"-"`
}

Cluster contains public info about kubernetes cluster.

func (*ListKubernetesClustersResponse_Cluster) Descriptor 

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

func (*ListKubernetesClustersResponse_Cluster) GetKubernetesClusterName 

func (m *ListKubernetesClustersResponse_Cluster) GetKubernetesClusterName() string

func (*ListKubernetesClustersResponse_Cluster) ProtoMessage 

func (*ListKubernetesClustersResponse_Cluster) ProtoMessage()

func (*ListKubernetesClustersResponse_Cluster) Reset 

func (m *ListKubernetesClustersResponse_Cluster) Reset()

func (*ListKubernetesClustersResponse_Cluster) String 

func (m *ListKubernetesClustersResponse_Cluster) String() string

func (*ListKubernetesClustersResponse_Cluster) Validate 

func (this *ListKubernetesClustersResponse_Cluster) Validate() error

func (*ListKubernetesClustersResponse_Cluster) XXX_DiscardUnknown 

func (m *ListKubernetesClustersResponse_Cluster) XXX_DiscardUnknown()

func (*ListKubernetesClustersResponse_Cluster) XXX_Marshal 

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

func (*ListKubernetesClustersResponse_Cluster) XXX_Merge 

func (m *ListKubernetesClustersResponse_Cluster) XXX_Merge(src proto.Message)

func (*ListKubernetesClustersResponse_Cluster) XXX_Size 

func (m *ListKubernetesClustersResponse_Cluster) XXX_Size() int

func (*ListKubernetesClustersResponse_Cluster) XXX_Unmarshal 

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

type RegisterKubernetesClusterRequest 

type RegisterKubernetesClusterRequest struct {
	// Kubernetes cluster name.
	KubernetesClusterName string `` /* 126-byte string literal not displayed */
	// Kubernetes auth.
	KubeAuth             *KubeAuth `protobuf:"bytes,2,opt,name=kube_auth,json=kubeAuth,proto3" json:"kube_auth,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*RegisterKubernetesClusterRequest) Descriptor 

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

func (*RegisterKubernetesClusterRequest) GetKubeAuth 

func (m *RegisterKubernetesClusterRequest) GetKubeAuth() *KubeAuth

func (*RegisterKubernetesClusterRequest) GetKubernetesClusterName 

func (m *RegisterKubernetesClusterRequest) GetKubernetesClusterName() string

func (*RegisterKubernetesClusterRequest) ProtoMessage 

func (*RegisterKubernetesClusterRequest) ProtoMessage()

func (*RegisterKubernetesClusterRequest) Reset 

func (m *RegisterKubernetesClusterRequest) Reset()

func (*RegisterKubernetesClusterRequest) String 

func (m *RegisterKubernetesClusterRequest) String() string

func (*RegisterKubernetesClusterRequest) Validate 

func (this *RegisterKubernetesClusterRequest) Validate() error

func (*RegisterKubernetesClusterRequest) XXX_DiscardUnknown 

func (m *RegisterKubernetesClusterRequest) XXX_DiscardUnknown()

func (*RegisterKubernetesClusterRequest) XXX_Marshal 

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

func (*RegisterKubernetesClusterRequest) XXX_Merge 

func (m *RegisterKubernetesClusterRequest) XXX_Merge(src proto.Message)

func (*RegisterKubernetesClusterRequest) XXX_Size 

func (m *RegisterKubernetesClusterRequest) XXX_Size() int

func (*RegisterKubernetesClusterRequest) XXX_Unmarshal 

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

type RegisterKubernetesClusterResponse 

type RegisterKubernetesClusterResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RegisterKubernetesClusterResponse) Descriptor 

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

func (*RegisterKubernetesClusterResponse) ProtoMessage 

func (*RegisterKubernetesClusterResponse) ProtoMessage()

func (*RegisterKubernetesClusterResponse) Reset 

func (m *RegisterKubernetesClusterResponse) Reset()

func (*RegisterKubernetesClusterResponse) String 

func (m *RegisterKubernetesClusterResponse) String() string

func (*RegisterKubernetesClusterResponse) Validate 

func (this *RegisterKubernetesClusterResponse) Validate() error

func (*RegisterKubernetesClusterResponse) XXX_DiscardUnknown 

func (m *RegisterKubernetesClusterResponse) XXX_DiscardUnknown()

func (*RegisterKubernetesClusterResponse) XXX_Marshal 

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

func (*RegisterKubernetesClusterResponse) XXX_Merge 

func (m *RegisterKubernetesClusterResponse) XXX_Merge(src proto.Message)

func (*RegisterKubernetesClusterResponse) XXX_Size 

func (m *RegisterKubernetesClusterResponse) XXX_Size() int

func (*RegisterKubernetesClusterResponse) XXX_Unmarshal 

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

type UnimplementedKubernetesServer 

type UnimplementedKubernetesServer struct {
}

UnimplementedKubernetesServer can be embedded to have forward compatible implementations.

func (*UnimplementedKubernetesServer) ListKubernetesClusters 

func (*UnimplementedKubernetesServer) ListKubernetesClusters(ctx context.Context, req *ListKubernetesClustersRequest) (*ListKubernetesClustersResponse, error)

func (*UnimplementedKubernetesServer) RegisterKubernetesCluster 

func (*UnimplementedKubernetesServer) RegisterKubernetesCluster(ctx context.Context, req *RegisterKubernetesClusterRequest) (*RegisterKubernetesClusterResponse, error)

func (*UnimplementedKubernetesServer) UnregisterKubernetesCluster 

func (*UnimplementedKubernetesServer) UnregisterKubernetesCluster(ctx context.Context, req *UnregisterKubernetesClusterRequest) (*UnregisterKubernetesClusterResponse, error)

type UnregisterKubernetesClusterRequest 

type UnregisterKubernetesClusterRequest struct {
	// Kubernetes cluster name.
	KubernetesClusterName string   `` /* 126-byte string literal not displayed */
	XXX_NoUnkeyedLiteral  struct{} `json:"-"`
	XXX_unrecognized      []byte   `json:"-"`
	XXX_sizecache         int32    `json:"-"`
}

func (*UnregisterKubernetesClusterRequest) Descriptor 

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

func (*UnregisterKubernetesClusterRequest) GetKubernetesClusterName 

func (m *UnregisterKubernetesClusterRequest) GetKubernetesClusterName() string

func (*UnregisterKubernetesClusterRequest) ProtoMessage 

func (*UnregisterKubernetesClusterRequest) ProtoMessage()

func (*UnregisterKubernetesClusterRequest) Reset 

func (m *UnregisterKubernetesClusterRequest) Reset()

func (*UnregisterKubernetesClusterRequest) String 

func (m *UnregisterKubernetesClusterRequest) String() string

func (*UnregisterKubernetesClusterRequest) Validate 

func (this *UnregisterKubernetesClusterRequest) Validate() error

func (*UnregisterKubernetesClusterRequest) XXX_DiscardUnknown 

func (m *UnregisterKubernetesClusterRequest) XXX_DiscardUnknown()

func (*UnregisterKubernetesClusterRequest) XXX_Marshal 

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

func (*UnregisterKubernetesClusterRequest) XXX_Merge 

func (m *UnregisterKubernetesClusterRequest) XXX_Merge(src proto.Message)

func (*UnregisterKubernetesClusterRequest) XXX_Size 

func (m *UnregisterKubernetesClusterRequest) XXX_Size() int

func (*UnregisterKubernetesClusterRequest) XXX_Unmarshal 

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

type UnregisterKubernetesClusterResponse 

type UnregisterKubernetesClusterResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UnregisterKubernetesClusterResponse) Descriptor 

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

func (*UnregisterKubernetesClusterResponse) ProtoMessage 

func (*UnregisterKubernetesClusterResponse) ProtoMessage()

func (*UnregisterKubernetesClusterResponse) Reset 

func (m *UnregisterKubernetesClusterResponse) Reset()

func (*UnregisterKubernetesClusterResponse) String 

func (m *UnregisterKubernetesClusterResponse) String() string

func (*UnregisterKubernetesClusterResponse) Validate 

func (this *UnregisterKubernetesClusterResponse) Validate() error

func (*UnregisterKubernetesClusterResponse) XXX_DiscardUnknown 

func (m *UnregisterKubernetesClusterResponse) XXX_DiscardUnknown()

func (*UnregisterKubernetesClusterResponse) XXX_Marshal 

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

func (*UnregisterKubernetesClusterResponse) XXX_Merge 

func (m *UnregisterKubernetesClusterResponse) XXX_Merge(src proto.Message)

func (*UnregisterKubernetesClusterResponse) XXX_Size 

func (m *UnregisterKubernetesClusterResponse) XXX_Size() int

func (*UnregisterKubernetesClusterResponse) XXX_Unmarshal 

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

Source Files

View all Source files

Directories

Path Synopsis
json
client
client/kubernetes

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.