grpc

Documentation

Index

• type GrpcAdapter
  • func (g *GrpcAdapter) Init(usecases *usecases.Usecases)
  • func (g *GrpcAdapter) Serve() error
  • func (g *GrpcAdapter) Stop()
• type OperatorGrpcService
  • func (f *OperatorGrpcService) SendAutoscalerEvent(ctx context.Context, request *pb.SendAutoscalerEventRequest) (*pb.SendAutoscalerEventResponse, error)

Types

type GrpcAdapter

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

func (*GrpcAdapter) Init

func (g *GrpcAdapter) Init(usecases *usecases.Usecases)

Init will create the underlying gRPC server and the gRPC healthcheck server

func (*GrpcAdapter) Serve

func (g *GrpcAdapter) Serve() error

Serve will create a service goroutine for each connection

func (*GrpcAdapter) Stop

func (g *GrpcAdapter) Stop()

Stop will gracefully shutdown the gRPC server

type OperatorGrpcService

type OperatorGrpcService struct {
	pb.UnimplementedOperatorServiceServer
	// contains filtered or unexported fields
}

func (*OperatorGrpcService) SendAutoscalerEvent

func (f *OperatorGrpcService) SendAutoscalerEvent(ctx context.Context, request *pb.SendAutoscalerEventRequest) (*pb.SendAutoscalerEventResponse, error)