Documentation
¶
Index ¶
- type Options
- type ProtocolError
- type PullOptions
- type RegistrationClient
- func (c *RegistrationClient) Complete(ctx context.Context, schedulerEndpoint string, ...) error
- func (c *RegistrationClient) Heartbeat(ctx context.Context, schedulerEndpoint, workerID string) error
- func (c *RegistrationClient) Pull(ctx context.Context, schedulerEndpoint, workerID string) (*workerproto.Command, error)
- func (c *RegistrationClient) Register(ctx context.Context, schedulerEndpoint string, ...) error
- type RegistrationOptions
- type Service
- func (s *Service) ConsumeQueue(ctx context.Context, broker executor.QueueBroker, queue string, ...) error
- func (s *Service) Descriptor(base workerproto.WorkerDescriptor) workerproto.WorkerDescriptor
- func (s *Service) Enabled() bool
- func (s *Service) Handler() http.Handler
- func (s *Service) MaintainPull(ctx context.Context, opts PullOptions) error
- func (s *Service) MaintainRegistration(ctx context.Context, opts RegistrationOptions) error
- func (s *Service) RegisterExecutor(exec executor.Executor) error
- func (s *Service) Registry() *executor.Registry
- func (s *Service) UnitRegistry() *workerunit.Registry
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Options ¶
type Options struct {
Enabled bool
RegisterBuiltins bool
Registry *executor.Registry
UnitRegistry *workerunit.Registry
CredentialResolver credential.Resolver
}
type ProtocolError ¶ added in v1.2.11
type ProtocolError struct {
StatusCode int
Response workerproto.ErrorResponse
}
func (*ProtocolError) Error ¶ added in v1.2.11
func (e *ProtocolError) Error() string
type PullOptions ¶ added in v1.2.11
type PullOptions struct {
SchedulerEndpoint string
Descriptor workerproto.WorkerDescriptor
Interval time.Duration
RetryInterval time.Duration
Concurrency int
Client *RegistrationClient
}
type RegistrationClient ¶
type RegistrationClient struct {
// contains filtered or unexported fields
}
func NewRegistrationClient ¶
func NewRegistrationClient(client *http.Client) *RegistrationClient
func (*RegistrationClient) Complete ¶ added in v1.2.11
func (c *RegistrationClient) Complete(ctx context.Context, schedulerEndpoint string, completion workerproto.CompleteRequest) error
func (*RegistrationClient) Heartbeat ¶
func (c *RegistrationClient) Heartbeat(ctx context.Context, schedulerEndpoint, workerID string) error
func (*RegistrationClient) Pull ¶ added in v1.2.11
func (c *RegistrationClient) Pull(ctx context.Context, schedulerEndpoint, workerID string) (*workerproto.Command, error)
func (*RegistrationClient) Register ¶
func (c *RegistrationClient) Register(ctx context.Context, schedulerEndpoint string, worker workerproto.WorkerDescriptor) error
type RegistrationOptions ¶
type RegistrationOptions struct {
SchedulerEndpoint string
Descriptor workerproto.WorkerDescriptor
Interval time.Duration
Client *RegistrationClient
}
type Service ¶
type Service struct {
// contains filtered or unexported fields
}
Service is the embedded worker runtime. It can be disabled when the deployment wants the scheduler to delegate execution to standalone worker processes only.
func NewService ¶
func (*Service) ConsumeQueue ¶
func (*Service) Descriptor ¶
func (s *Service) Descriptor(base workerproto.WorkerDescriptor) workerproto.WorkerDescriptor
func (*Service) MaintainPull ¶ added in v1.2.11
func (s *Service) MaintainPull(ctx context.Context, opts PullOptions) error
MaintainPull registers an outbound-only worker, leases commands from the scheduler, and retries completion with the same command_id until acknowledged.
func (*Service) MaintainRegistration ¶
func (s *Service) MaintainRegistration(ctx context.Context, opts RegistrationOptions) error
func (*Service) UnitRegistry ¶
func (s *Service) UnitRegistry() *workerunit.Registry
Source Files
¶
Directories
Click to show internal directories.
Click to hide internal directories.