Documentation
¶
Index ¶
- func IsMissingParameterError(err string) bool
- type Dialer
- type Options
- type Provisioners
- type Server
- func (p *Server) Close() error
- func (p *Server) CompleteJob(ctx context.Context, in *proto.CompletedJob) error
- func (p *Server) FailJob(ctx context.Context, in *proto.FailedJob) error
- func (p *Server) Shutdown(ctx context.Context) error
- func (p *Server) UpdateJob(ctx context.Context, in *proto.UpdateJobRequest) (*proto.UpdateJobResponse, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func IsMissingParameterError ¶
IsMissingParameterError returns whether the error message provided is a missing parameter error. This can indicate to consumers that they should check parameters.
Types ¶
type Dialer ¶
type Dialer func(ctx context.Context) (proto.DRPCProvisionerDaemonClient, error)
Dialer represents the function to create a daemon client connection.
type Options ¶
type Options struct { Filesystem afero.Fs Logger slog.Logger ForceCancelInterval time.Duration UpdateInterval time.Duration PollInterval time.Duration Provisioners Provisioners WorkDirectory string }
Options provides customizations to the behavior of a provisioner daemon.
type Provisioners ¶
type Provisioners map[string]sdkproto.DRPCProvisionerClient
Provisioners maps provisioner ID to implementation.
type Server ¶
type Server struct {
// contains filtered or unexported fields
}
func (*Server) CompleteJob ¶ added in v0.7.7
func (*Server) Shutdown ¶
Shutdown triggers a graceful exit of each registered provisioner. It exits when an active job stops.
func (*Server) UpdateJob ¶ added in v0.7.7
func (p *Server) UpdateJob(ctx context.Context, in *proto.UpdateJobRequest) (*proto.UpdateJobResponse, error)
Click to show internal directories.
Click to hide internal directories.