Documentation
¶
Overview ¶
Package ingest is a reverse proxy.
It translates gRPC into RESTful JSON APIs.
Package ingest is a reverse proxy.
It translates gRPC into RESTful JSON APIs.
Index ¶
- Variables
- func RegisterChefIngesterHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
- func RegisterChefIngesterHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ChefIngesterClient) error
- func RegisterChefIngesterHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)
- func RegisterChefIngesterHandlerServer(ctx context.Context, mux *runtime.ServeMux, server ChefIngesterServer) error
- func RegisterChefIngesterServer(s *grpc.Server, srv ChefIngesterServer)
- func RegisterJobSchedulerHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
- func RegisterJobSchedulerHandlerClient(ctx context.Context, mux *runtime.ServeMux, client JobSchedulerClient) error
- func RegisterJobSchedulerHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)
- func RegisterJobSchedulerHandlerServer(ctx context.Context, mux *runtime.ServeMux, server JobSchedulerServer) error
- func RegisterJobSchedulerServer(s *grpc.Server, srv JobSchedulerServer)
- type ChefIngesterClient
- type ChefIngesterServer
- type JobSchedulerClient
- type JobSchedulerServer
- type UnimplementedChefIngesterServer
- func (*UnimplementedChefIngesterServer) GetVersion(context.Context, *version.VersionInfoRequest) (*version.VersionInfo, error)
- func (*UnimplementedChefIngesterServer) ProcessChefAction(context.Context, *request.Action) (*response.ProcessChefActionResponse, error)
- func (*UnimplementedChefIngesterServer) ProcessChefRun(context.Context, *request.Run) (*response.ProcessChefRunResponse, error)
- func (*UnimplementedChefIngesterServer) ProcessLivenessPing(context.Context, *request.Liveness) (*response.ProcessLivenessResponse, error)
- func (*UnimplementedChefIngesterServer) ProcessMultipleNodeDeletes(context.Context, *request.MultipleNodeDeleteRequest) (*response.ProcessMultipleNodeDeleteResponse, error)
- func (*UnimplementedChefIngesterServer) ProcessNodeDelete(context.Context, *request.Delete) (*response.ProcessNodeDeleteResponse, error)
- type UnimplementedJobSchedulerServer
- func (*UnimplementedJobSchedulerServer) ConfigureDeleteNodesScheduler(context.Context, *request.SchedulerConfig) (*response.ConfigureDeleteNodesScheduler, error)
- func (*UnimplementedJobSchedulerServer) ConfigureMissingNodesForDeletionScheduler(context.Context, *request.SchedulerConfig) (*response.ConfigureMissingNodesForDeletionScheduler, error)
- func (*UnimplementedJobSchedulerServer) ConfigureNodesMissingScheduler(context.Context, *request.SchedulerConfig) (*response.ConfigureNodesMissingScheduler, error)
- func (*UnimplementedJobSchedulerServer) GetStatusJobScheduler(context.Context, *request.GetStatusJobScheduler) (*response.JobSchedulerStatus, error)
Constants ¶
This section is empty.
Variables ¶
var File_external_ingest_chef_proto protoreflect.FileDescriptor
var File_external_ingest_job_scheduler_proto protoreflect.FileDescriptor
Functions ¶
func RegisterChefIngesterHandler ¶
func RegisterChefIngesterHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
RegisterChefIngesterHandler registers the http handlers for service ChefIngester to "mux". The handlers forward requests to the grpc endpoint over "conn".
func RegisterChefIngesterHandlerClient ¶
func RegisterChefIngesterHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ChefIngesterClient) error
RegisterChefIngesterHandlerClient registers the http handlers for service ChefIngester to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "ChefIngesterClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "ChefIngesterClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "ChefIngesterClient" to call the correct interceptors.
func RegisterChefIngesterHandlerFromEndpoint ¶
func RegisterChefIngesterHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)
RegisterChefIngesterHandlerFromEndpoint is same as RegisterChefIngesterHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.
func RegisterChefIngesterHandlerServer ¶
func RegisterChefIngesterHandlerServer(ctx context.Context, mux *runtime.ServeMux, server ChefIngesterServer) error
RegisterChefIngesterHandlerServer registers the http handlers for service ChefIngester to "mux". UnaryRPC :call ChefIngesterServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906.
func RegisterChefIngesterServer ¶
func RegisterChefIngesterServer(s *grpc.Server, srv ChefIngesterServer)
func RegisterJobSchedulerHandler ¶
func RegisterJobSchedulerHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
RegisterJobSchedulerHandler registers the http handlers for service JobScheduler to "mux". The handlers forward requests to the grpc endpoint over "conn".
func RegisterJobSchedulerHandlerClient ¶
func RegisterJobSchedulerHandlerClient(ctx context.Context, mux *runtime.ServeMux, client JobSchedulerClient) error
RegisterJobSchedulerHandlerClient registers the http handlers for service JobScheduler to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "JobSchedulerClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "JobSchedulerClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "JobSchedulerClient" to call the correct interceptors.
func RegisterJobSchedulerHandlerFromEndpoint ¶
func RegisterJobSchedulerHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)
RegisterJobSchedulerHandlerFromEndpoint is same as RegisterJobSchedulerHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.
func RegisterJobSchedulerHandlerServer ¶
func RegisterJobSchedulerHandlerServer(ctx context.Context, mux *runtime.ServeMux, server JobSchedulerServer) error
RegisterJobSchedulerHandlerServer registers the http handlers for service JobScheduler to "mux". UnaryRPC :call JobSchedulerServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906.
func RegisterJobSchedulerServer ¶
func RegisterJobSchedulerServer(s *grpc.Server, srv JobSchedulerServer)
Types ¶
type ChefIngesterClient ¶
type ChefIngesterClient interface {
ProcessChefRun(ctx context.Context, in *request.Run, opts ...grpc.CallOption) (*response.ProcessChefRunResponse, error)
ProcessChefAction(ctx context.Context, in *request.Action, opts ...grpc.CallOption) (*response.ProcessChefActionResponse, error)
ProcessNodeDelete(ctx context.Context, in *request.Delete, opts ...grpc.CallOption) (*response.ProcessNodeDeleteResponse, error)
ProcessMultipleNodeDeletes(ctx context.Context, in *request.MultipleNodeDeleteRequest, opts ...grpc.CallOption) (*response.ProcessMultipleNodeDeleteResponse, error)
ProcessLivenessPing(ctx context.Context, in *request.Liveness, opts ...grpc.CallOption) (*response.ProcessLivenessResponse, error)
GetVersion(ctx context.Context, in *version.VersionInfoRequest, opts ...grpc.CallOption) (*version.VersionInfo, error)
}
ChefIngesterClient is the client API for ChefIngester service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewChefIngesterClient ¶
func NewChefIngesterClient(cc grpc.ClientConnInterface) ChefIngesterClient
type ChefIngesterServer ¶
type ChefIngesterServer interface {
ProcessChefRun(context.Context, *request.Run) (*response.ProcessChefRunResponse, error)
ProcessChefAction(context.Context, *request.Action) (*response.ProcessChefActionResponse, error)
ProcessNodeDelete(context.Context, *request.Delete) (*response.ProcessNodeDeleteResponse, error)
ProcessMultipleNodeDeletes(context.Context, *request.MultipleNodeDeleteRequest) (*response.ProcessMultipleNodeDeleteResponse, error)
ProcessLivenessPing(context.Context, *request.Liveness) (*response.ProcessLivenessResponse, error)
GetVersion(context.Context, *version.VersionInfoRequest) (*version.VersionInfo, error)
}
ChefIngesterServer is the server API for ChefIngester service.
type JobSchedulerClient ¶
type JobSchedulerClient interface {
GetStatusJobScheduler(ctx context.Context, in *request.GetStatusJobScheduler, opts ...grpc.CallOption) (*response.JobSchedulerStatus, error)
ConfigureNodesMissingScheduler(ctx context.Context, in *request.SchedulerConfig, opts ...grpc.CallOption) (*response.ConfigureNodesMissingScheduler, error)
ConfigureDeleteNodesScheduler(ctx context.Context, in *request.SchedulerConfig, opts ...grpc.CallOption) (*response.ConfigureDeleteNodesScheduler, error)
ConfigureMissingNodesForDeletionScheduler(ctx context.Context, in *request.SchedulerConfig, opts ...grpc.CallOption) (*response.ConfigureMissingNodesForDeletionScheduler, error)
}
JobSchedulerClient is the client API for JobScheduler service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewJobSchedulerClient ¶
func NewJobSchedulerClient(cc grpc.ClientConnInterface) JobSchedulerClient
type JobSchedulerServer ¶
type JobSchedulerServer interface {
GetStatusJobScheduler(context.Context, *request.GetStatusJobScheduler) (*response.JobSchedulerStatus, error)
ConfigureNodesMissingScheduler(context.Context, *request.SchedulerConfig) (*response.ConfigureNodesMissingScheduler, error)
ConfigureDeleteNodesScheduler(context.Context, *request.SchedulerConfig) (*response.ConfigureDeleteNodesScheduler, error)
ConfigureMissingNodesForDeletionScheduler(context.Context, *request.SchedulerConfig) (*response.ConfigureMissingNodesForDeletionScheduler, error)
}
JobSchedulerServer is the server API for JobScheduler service.
type UnimplementedChefIngesterServer ¶
type UnimplementedChefIngesterServer struct {
}
UnimplementedChefIngesterServer can be embedded to have forward compatible implementations.
func (*UnimplementedChefIngesterServer) GetVersion ¶
func (*UnimplementedChefIngesterServer) GetVersion(context.Context, *version.VersionInfoRequest) (*version.VersionInfo, error)
func (*UnimplementedChefIngesterServer) ProcessChefAction ¶
func (*UnimplementedChefIngesterServer) ProcessChefAction(context.Context, *request.Action) (*response.ProcessChefActionResponse, error)
func (*UnimplementedChefIngesterServer) ProcessChefRun ¶
func (*UnimplementedChefIngesterServer) ProcessChefRun(context.Context, *request.Run) (*response.ProcessChefRunResponse, error)
func (*UnimplementedChefIngesterServer) ProcessLivenessPing ¶
func (*UnimplementedChefIngesterServer) ProcessLivenessPing(context.Context, *request.Liveness) (*response.ProcessLivenessResponse, error)
func (*UnimplementedChefIngesterServer) ProcessMultipleNodeDeletes ¶
func (*UnimplementedChefIngesterServer) ProcessMultipleNodeDeletes(context.Context, *request.MultipleNodeDeleteRequest) (*response.ProcessMultipleNodeDeleteResponse, error)
func (*UnimplementedChefIngesterServer) ProcessNodeDelete ¶
func (*UnimplementedChefIngesterServer) ProcessNodeDelete(context.Context, *request.Delete) (*response.ProcessNodeDeleteResponse, error)
type UnimplementedJobSchedulerServer ¶
type UnimplementedJobSchedulerServer struct {
}
UnimplementedJobSchedulerServer can be embedded to have forward compatible implementations.
func (*UnimplementedJobSchedulerServer) ConfigureDeleteNodesScheduler ¶
func (*UnimplementedJobSchedulerServer) ConfigureDeleteNodesScheduler(context.Context, *request.SchedulerConfig) (*response.ConfigureDeleteNodesScheduler, error)
func (*UnimplementedJobSchedulerServer) ConfigureMissingNodesForDeletionScheduler ¶
func (*UnimplementedJobSchedulerServer) ConfigureMissingNodesForDeletionScheduler(context.Context, *request.SchedulerConfig) (*response.ConfigureMissingNodesForDeletionScheduler, error)
func (*UnimplementedJobSchedulerServer) ConfigureNodesMissingScheduler ¶
func (*UnimplementedJobSchedulerServer) ConfigureNodesMissingScheduler(context.Context, *request.SchedulerConfig) (*response.ConfigureNodesMissingScheduler, error)
func (*UnimplementedJobSchedulerServer) GetStatusJobScheduler ¶
func (*UnimplementedJobSchedulerServer) GetStatusJobScheduler(context.Context, *request.GetStatusJobScheduler) (*response.JobSchedulerStatus, error)
Source Files
Directories