worker

package

v0.23.0 Latest Latest Go to latest Published: Dec 24, 2020 License: MPL-2.0 Imports: 15 Imported by: 0

Details

View Source

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

View Source

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

This section is empty.

type Option func(*Worker)

func WithLabels(labels map[string]string) Option

func WithName(name string) Option

func WithRPCEndpoint(rpcEndpoint string) Option

func WithRegistrationToken(registrationToken string) Option

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

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

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

PerRPCCredentials interface implementation.

func (worker *Worker) RequireTransportSecurity() bool

PerRPCCredentials interface implementation.

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