worker

Documentation

Index

• Constants
• Variables
• type Option
  • func WithAgentEndpoint(agentEndpoint endpoint.Endpoint) Option
  • func WithLabels(labels map[string]string) Option
  • func WithLogger(logger logrus.FieldLogger) Option
  • func WithName(name string) Option
  • func WithRPCEndpoint(rpcEndpoint string) Option
  • func WithRegistrationToken(registrationToken string) Option
• type Worker
  • func New(opts ...Option) (*Worker, error)
  • func (worker *Worker) GetRequestMetadata(ctx context.Context, uri ...string) (map[string]string, error)
  • func (worker *Worker) Pause(ctx context.Context, wait bool) error
  • func (worker *Worker) RequireTransportSecurity() bool
  • func (worker *Worker) Resume(ctx context.Context) error
  • func (worker *Worker) Run(ctx context.Context) error

Constants

const (
	DefaultRPCEndpoint = "https://grpc.cirrus-ci.com:443"
)

Variables

var (
	ErrWorker   = errors.New("worker failed")
	ErrShutdown = errors.New("worker is shutting down")
)

Types

type Option

type Option func(*Worker)

func WithAgentEndpoint

func WithAgentEndpoint(agentEndpoint endpoint.Endpoint) Option

func WithLabels

func WithLabels(labels map[string]string) Option

func WithLogger

func WithLogger(logger logrus.FieldLogger) Option

func WithName

func WithName(name string) Option

func WithRPCEndpoint

func WithRPCEndpoint(rpcEndpoint string) Option

func WithRegistrationToken

func WithRegistrationToken(registrationToken string) Option

type Worker

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

func New

func New(opts ...Option) (*Worker, error)

func (*Worker) GetRequestMetadata

func (worker *Worker) GetRequestMetadata(ctx context.Context, uri ...string) (map[string]string, error)

PerRPCCredentials interface implementation.

func (*Worker) Pause

func (worker *Worker) Pause(ctx context.Context, wait bool) error

func (*Worker) RequireTransportSecurity

func (worker *Worker) RequireTransportSecurity() bool

PerRPCCredentials interface implementation.

func (*Worker) Resume

func (worker *Worker) Resume(ctx context.Context) error

func (*Worker) Run

func (worker *Worker) Run(ctx context.Context) error