grpc

Documentation

Index

• func LoadTLSClientCredentials() (credentials.TransportCredentials, error)
• func LoadTLSCredentials() (credentials.TransportCredentials, error)
• func NewTlSServer() (*grpc.Server, error)
• type ResourcesServiceServer
  • func NewResourcesServiceServer() *ResourcesServiceServer
  • func (s *ResourcesServiceServer) CreateDigitalOcean(ctx context.Context, req *pb.CreateRequest) (*pb.CreateResponse, error)
  • func (s *ResourcesServiceServer) List(ctx context.Context, req *pb.ListRequest) (*pb.ListResponse, error)
  • func (s *ResourcesServiceServer) Liveness(ctx context.Context, req *pb.LivenessRequest) (*pb.LivenessResponse, error)
  • func (s *ResourcesServiceServer) Status(ctx context.Context, req *pb.StatusRequest) (*pb.StatusResponse, error)
  • func (s *ResourcesServiceServer) Submit(ctx context.Context, _req *pb.SubmitRequest) (*pb.SubmitResponse, error)

Functions

func LoadTLSClientCredentials

func LoadTLSClientCredentials() (credentials.TransportCredentials, error)

func LoadTLSCredentials

func LoadTLSCredentials() (credentials.TransportCredentials, error)

func NewTlSServer

func NewTlSServer() (*grpc.Server, error)

Types

type ResourcesServiceServer

type ResourcesServiceServer struct {
	Close chan os.Signal
	Error chan error

	pb.UnimplementedResourcesServer
	// contains filtered or unexported fields
}

func NewResourcesServiceServer

func NewResourcesServiceServer() *ResourcesServiceServer

func (*ResourcesServiceServer) CreateDigitalOcean

func (s *ResourcesServiceServer) CreateDigitalOcean(ctx context.Context, req *pb.CreateRequest) (*pb.CreateResponse, error)

func (*ResourcesServiceServer) List

func (s *ResourcesServiceServer) List(ctx context.Context, req *pb.ListRequest) (*pb.ListResponse, error)

func (*ResourcesServiceServer) Liveness

func (s *ResourcesServiceServer) Liveness(ctx context.Context, req *pb.LivenessRequest) (*pb.LivenessResponse, error)

func (*ResourcesServiceServer) Status

func (s *ResourcesServiceServer) Status(ctx context.Context, req *pb.StatusRequest) (*pb.StatusResponse, error)

func (*ResourcesServiceServer) Submit

func (s *ResourcesServiceServer) Submit(ctx context.Context, _req *pb.SubmitRequest) (*pb.SubmitResponse, error)