grpc

Documentation

Index

• type GrpcAdapter
  • func (g *GrpcAdapter) Init(usecases *usecases.Usecases, opts ...grpc.ServerOption)
  • func (g *GrpcAdapter) Serve() error
  • func (g *GrpcAdapter) Stop()
• type KuberGrpcService
  • func (k *KuberGrpcService) CiliumRolloutRestart(ctx context.Context, request *pb.CiliumRolloutRestartRequest) (*pb.CiliumRolloutRestartResponse, error)
  • func (k *KuberGrpcService) DeleteClusterMetadata(ctx context.Context, request *pb.DeleteClusterMetadataRequest) (*pb.DeleteClusterMetadataResponse, error)
  • func (k *KuberGrpcService) DeleteKubeconfig(ctx context.Context, request *pb.DeleteKubeconfigRequest) (*pb.DeleteKubeconfigResponse, error)
  • func (k *KuberGrpcService) DeleteNodes(ctx context.Context, request *pb.DeleteNodesRequest) (*pb.DeleteNodesResponse, error)
  • func (k *KuberGrpcService) DestroyClusterAutoscaler(ctx context.Context, request *pb.DestroyClusterAutoscalerRequest) (*pb.DestroyClusterAutoscalerResponse, error)
  • func (k *KuberGrpcService) PatchClusterInfoConfigMap(ctx context.Context, request *pb.PatchClusterInfoConfigMapRequest) (*pb.PatchClusterInfoConfigMapResponse, error)
  • func (k *KuberGrpcService) PatchNodes(ctx context.Context, request *pb.PatchNodesRequest) (*pb.PatchNodesResponse, error)
  • func (k *KuberGrpcService) RemoveLBScrapeConfig(ctx context.Context, request *pb.RemoveLBScrapeConfigRequest) (*pb.RemoveLBScrapeConfigResponse, error)
  • func (k *KuberGrpcService) SetUpClusterAutoscaler(ctx context.Context, request *pb.SetUpClusterAutoscalerRequest) (*pb.SetUpClusterAutoscalerResponse, error)
  • func (k *KuberGrpcService) SetUpStorage(ctx context.Context, request *pb.SetUpStorageRequest) (*pb.SetUpStorageResponse, error)
  • func (k *KuberGrpcService) StoreClusterMetadata(ctx context.Context, request *pb.StoreClusterMetadataRequest) (*pb.StoreClusterMetadataResponse, error)
  • func (k *KuberGrpcService) StoreKubeconfig(ctx context.Context, request *pb.StoreKubeconfigRequest) (*pb.StoreKubeconfigResponse, error)
  • func (k *KuberGrpcService) StoreLBScrapeConfig(ctx context.Context, request *pb.StoreLBScrapeConfigRequest) (*pb.StoreLBScrapeConfigResponse, error)

Types

type GrpcAdapter

type GrpcAdapter struct {
	HealthServer *health.Server
	// contains filtered or unexported fields
}

func (*GrpcAdapter) Init

func (g *GrpcAdapter) Init(usecases *usecases.Usecases, opts ...grpc.ServerOption)

Init sets up the GrpcAdapter by creating the underlying tcpListener, gRPC server and gRPC health check server.

func (*GrpcAdapter) Serve

func (g *GrpcAdapter) Serve() error

Serve makes the gRPC server start listening for incoming gRPC requests.

func (*GrpcAdapter) Stop

func (g *GrpcAdapter) Stop()

Stop gracefully shuts down the underlying gRPC server and gRCP health-check server.

type KuberGrpcService

type KuberGrpcService struct {
	pb.UnimplementedKuberServiceServer
	// contains filtered or unexported fields
}

func (*KuberGrpcService) CiliumRolloutRestart

func (k *KuberGrpcService) CiliumRolloutRestart(ctx context.Context, request *pb.CiliumRolloutRestartRequest) (*pb.CiliumRolloutRestartResponse, error)

func (*KuberGrpcService) DeleteClusterMetadata

func (k *KuberGrpcService) DeleteClusterMetadata(ctx context.Context, request *pb.DeleteClusterMetadataRequest) (*pb.DeleteClusterMetadataResponse, error)

func (*KuberGrpcService) DeleteKubeconfig

func (k *KuberGrpcService) DeleteKubeconfig(ctx context.Context, request *pb.DeleteKubeconfigRequest) (*pb.DeleteKubeconfigResponse, error)

func (*KuberGrpcService) DeleteNodes

func (k *KuberGrpcService) DeleteNodes(ctx context.Context, request *pb.DeleteNodesRequest) (*pb.DeleteNodesResponse, error)

func (*KuberGrpcService) DestroyClusterAutoscaler

func (k *KuberGrpcService) DestroyClusterAutoscaler(ctx context.Context, request *pb.DestroyClusterAutoscalerRequest) (*pb.DestroyClusterAutoscalerResponse, error)

func (*KuberGrpcService) PatchClusterInfoConfigMap

func (k *KuberGrpcService) PatchClusterInfoConfigMap(ctx context.Context, request *pb.PatchClusterInfoConfigMapRequest) (*pb.PatchClusterInfoConfigMapResponse, error)

func (*KuberGrpcService) PatchNodes

func (k *KuberGrpcService) PatchNodes(ctx context.Context, request *pb.PatchNodesRequest) (*pb.PatchNodesResponse, error)

func (*KuberGrpcService) RemoveLBScrapeConfig

func (k *KuberGrpcService) RemoveLBScrapeConfig(ctx context.Context, request *pb.RemoveLBScrapeConfigRequest) (*pb.RemoveLBScrapeConfigResponse, error)

func (*KuberGrpcService) SetUpClusterAutoscaler

func (k *KuberGrpcService) SetUpClusterAutoscaler(ctx context.Context, request *pb.SetUpClusterAutoscalerRequest) (*pb.SetUpClusterAutoscalerResponse, error)

func (*KuberGrpcService) SetUpStorage

func (k *KuberGrpcService) SetUpStorage(ctx context.Context, request *pb.SetUpStorageRequest) (*pb.SetUpStorageResponse, error)

func (*KuberGrpcService) StoreClusterMetadata

func (k *KuberGrpcService) StoreClusterMetadata(ctx context.Context, request *pb.StoreClusterMetadataRequest) (*pb.StoreClusterMetadataResponse, error)

func (*KuberGrpcService) StoreKubeconfig

func (k *KuberGrpcService) StoreKubeconfig(ctx context.Context, request *pb.StoreKubeconfigRequest) (*pb.StoreKubeconfigResponse, error)

func (*KuberGrpcService) StoreLBScrapeConfig

func (k *KuberGrpcService) StoreLBScrapeConfig(ctx context.Context, request *pb.StoreLBScrapeConfigRequest) (*pb.StoreLBScrapeConfigResponse, error)