grpc

Documentation

Index

• type AnsiblerGrpcService
  • func (a *AnsiblerGrpcService) InstallNodeRequirements(_ context.Context, request *pb.InstallRequest) (*pb.InstallResponse, error)
  • func (a *AnsiblerGrpcService) InstallVPN(_ context.Context, request *pb.InstallRequest) (*pb.InstallResponse, error)
  • func (a *AnsiblerGrpcService) RemoveClaudieUtilities(_ context.Context, request *pb.RemoveClaudieUtilitiesRequest) (*pb.RemoveClaudieUtilitiesResponse, error)
  • func (a *AnsiblerGrpcService) SetUpLoadbalancers(_ context.Context, request *pb.SetUpLBRequest) (*pb.SetUpLBResponse, error)
  • func (a *AnsiblerGrpcService) TeardownLoadBalancers(ctx context.Context, request *pb.TeardownLBRequest) (*pb.TeardownLBResponse, error)
  • func (a *AnsiblerGrpcService) UpdateAPIEndpoint(_ context.Context, request *pb.UpdateAPIEndpointRequest) (*pb.UpdateAPIEndpointResponse, error)
  • func (a *AnsiblerGrpcService) UpdateNoProxyEnvsInKubernetes(_ context.Context, request *pb.UpdateNoProxyEnvsInKubernetesRequest) (*pb.UpdateNoProxyEnvsInKubernetesResponse, error)
  • func (a *AnsiblerGrpcService) UpdateProxyEnvsOnNodes(_ context.Context, request *pb.UpdateProxyEnvsOnNodesRequest) (*pb.UpdateProxyEnvsOnNodesResponse, error)
• type GrpcAdapter
  • func CreateGrpcAdapter(usecases *usecases.Usecases, opts ...grpc.ServerOption) *GrpcAdapter
  • func (g *GrpcAdapter) Serve() error
  • func (g *GrpcAdapter) Stop()

Types

type AnsiblerGrpcService

type AnsiblerGrpcService struct {
	pb.UnimplementedAnsiblerServiceServer
	// contains filtered or unexported fields
}

func (*AnsiblerGrpcService) InstallNodeRequirements

func (a *AnsiblerGrpcService) InstallNodeRequirements(_ context.Context, request *pb.InstallRequest) (*pb.InstallResponse, error)

func (*AnsiblerGrpcService) InstallVPN

func (a *AnsiblerGrpcService) InstallVPN(_ context.Context, request *pb.InstallRequest) (*pb.InstallResponse, error)

func (*AnsiblerGrpcService) RemoveClaudieUtilities

func (a *AnsiblerGrpcService) RemoveClaudieUtilities(_ context.Context, request *pb.RemoveClaudieUtilitiesRequest) (*pb.RemoveClaudieUtilitiesResponse, error)

func (*AnsiblerGrpcService) SetUpLoadbalancers

func (a *AnsiblerGrpcService) SetUpLoadbalancers(_ context.Context, request *pb.SetUpLBRequest) (*pb.SetUpLBResponse, error)

func (*AnsiblerGrpcService) TeardownLoadBalancers

func (a *AnsiblerGrpcService) TeardownLoadBalancers(ctx context.Context, request *pb.TeardownLBRequest) (*pb.TeardownLBResponse, error)

func (*AnsiblerGrpcService) UpdateAPIEndpoint

func (a *AnsiblerGrpcService) UpdateAPIEndpoint(_ context.Context, request *pb.UpdateAPIEndpointRequest) (*pb.UpdateAPIEndpointResponse, error)

func (*AnsiblerGrpcService) UpdateNoProxyEnvsInKubernetes

func (a *AnsiblerGrpcService) UpdateNoProxyEnvsInKubernetes(_ context.Context, request *pb.UpdateNoProxyEnvsInKubernetesRequest) (*pb.UpdateNoProxyEnvsInKubernetesResponse, error)

func (*AnsiblerGrpcService) UpdateProxyEnvsOnNodes

func (a *AnsiblerGrpcService) UpdateProxyEnvsOnNodes(_ context.Context, request *pb.UpdateProxyEnvsOnNodesRequest) (*pb.UpdateProxyEnvsOnNodesResponse, error)

type GrpcAdapter

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

func CreateGrpcAdapter

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

CreateGrpcAdapter return new gRPC adapter for Ansibler.

func (*GrpcAdapter) Serve

func (g *GrpcAdapter) Serve() error

Serve starts a gRPC server and blocks until the server stops serving.

func (*GrpcAdapter) Stop

func (g *GrpcAdapter) Stop()

Stop terminates the gRPC server.