upstream

package

v0.136.0 Latest Latest Go to latest Published: Jan 29, 2025 License: AGPL-3.0 Imports: 12 Imported by: 0

Details

View Source

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

View Source

var (
	ErrFailed = errors.New("upstream failed")
)

This section is empty.

type Option func(*Upstream)

func WithAgentEndpoint(agentEndpoint endpoint.Endpoint) Option

func WithLogger(logger logrus.FieldLogger) Option

func WithRPCEndpoint(rpcEndpoint string) Option

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

func New(workerName string, registrationToken string, opts ...Option) (*Upstream, error)

func (upstream *Upstream) AgentEndpoint() endpoint.Endpoint

func (upstream *Upstream) Connect(ctx context.Context) error

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

PerRPCCredentials interface implementation.

func (upstream *Upstream) Name() string

func (upstream *Upstream) Poll(ctx context.Context, request *api.PollRequest) (*api.PollResponse, error)

func (upstream *Upstream) PollIntervalSeconds() uint32

func (upstream *Upstream) QueryRunningTasks(
	ctx context.Context,
	request *api.QueryRunningTasksRequest,
) (*api.QueryRunningTasksResponse, error)

func (upstream *Upstream) Register(ctx context.Context, workerInfo *api.WorkerInfo) error

func (upstream *Upstream) RequireTransportSecurity() bool

PerRPCCredentials interface implementation.

func (upstream *Upstream) SetDisabled(ctx context.Context, disabled bool) error

func (upstream *Upstream) TaskFailed(ctx context.Context, request *api.TaskFailedRequest) error

func (upstream *Upstream) TaskStarted(ctx context.Context, request *api.TaskIdentification) error

func (upstream *Upstream) TaskStopped(ctx context.Context, request *api.TaskIdentification) error

func (upstream *Upstream) WorkerName() string