frontend

Documentation

Overview

Package frontend exposes the primary pRPC API of qscheduler app.

Index

• Variables
• func InstallServices(apiServer *prpc.Server)
• type BatchedQSchedulerServer
  • func NewBatchedServer() *BatchedQSchedulerServer
  • func (s *BatchedQSchedulerServer) AssignTasks(ctx context.Context, r *swarming.AssignTasksRequest) (resp *swarming.AssignTasksResponse, err error)
  • func (s *BatchedQSchedulerServer) GetCallbacks(ctx context.Context, r *swarming.GetCallbacksRequest) (resp *swarming.GetCallbacksResponse, err error)
  • func (s *BatchedQSchedulerServer) GetCancellations(ctx context.Context, r *swarming.GetCancellationsRequest) (resp *swarming.GetCancellationsResponse, err error)
  • func (s *BatchedQSchedulerServer) NotifyTasks(ctx context.Context, r *swarming.NotifyTasksRequest) (resp *swarming.NotifyTasksResponse, err error)
• type QSchedulerAdminServerImpl
  • func (s *QSchedulerAdminServerImpl) CreateAccount(ctx context.Context, r *qscheduler.CreateAccountRequest) (resp *qscheduler.CreateAccountResponse, err error)
  • func (s *QSchedulerAdminServerImpl) CreateSchedulerPool(ctx context.Context, r *qscheduler.CreateSchedulerPoolRequest) (resp *qscheduler.CreateSchedulerPoolResponse, err error)
  • func (s *QSchedulerAdminServerImpl) DeleteAccount(ctx context.Context, r *qscheduler.DeleteAccountRequest) (resp *qscheduler.DeleteAccountResponse, err error)
  • func (s *QSchedulerAdminServerImpl) DeleteSchedulerPool(ctx context.Context, r *qscheduler.DeleteSchedulerPoolRequest) (resp *qscheduler.DeleteSchedulerPoolResponse, err error)
  • func (s *QSchedulerAdminServerImpl) ModAccount(ctx context.Context, r *qscheduler.ModAccountRequest) (resp *qscheduler.ModAccountResponse, err error)
  • func (s *QSchedulerAdminServerImpl) ModSchedulerPool(ctx context.Context, r *qscheduler.ModSchedulerPoolRequest) (resp *qscheduler.ModSchedulerPoolResponse, err error)
  • func (s *QSchedulerAdminServerImpl) Wipe(ctx context.Context, r *qscheduler.WipeRequest) (resp *qscheduler.WipeResponse, err error)
• type QSchedulerViewServerImpl
  • func (s *QSchedulerViewServerImpl) InspectPool(ctx context.Context, r *qscheduler.InspectPoolRequest) (resp *qscheduler.InspectPoolResponse, err error)
  • func (s *QSchedulerViewServerImpl) ListAccounts(ctx context.Context, r *qscheduler.ListAccountsRequest) (resp *qscheduler.ListAccountsResponse, err error)

Variables

var SkipAuthorization = false

SkipAuthorization is set to true when running in dev server locally.

Functions

func InstallServices

func InstallServices(apiServer *prpc.Server)

InstallServices installs the services implemented by the frontend package.

Types

type BatchedQSchedulerServer

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

BatchedQSchedulerServer implements the QSchedulerServer interface.

This implementation batches concurrent read-write requests for a given scheduler.

func NewBatchedServer

func NewBatchedServer() *BatchedQSchedulerServer

NewBatchedServer initializes a new BatchedQSchedulerServer

func (*BatchedQSchedulerServer) AssignTasks

func (s *BatchedQSchedulerServer) AssignTasks(ctx context.Context, r *swarming.AssignTasksRequest) (resp *swarming.AssignTasksResponse, err error)

AssignTasks implements QSchedulerServer.

func (*BatchedQSchedulerServer) GetCallbacks

func (s *BatchedQSchedulerServer) GetCallbacks(ctx context.Context, r *swarming.GetCallbacksRequest) (resp *swarming.GetCallbacksResponse, err error)

GetCallbacks implements QSchedulerServer.

func (*BatchedQSchedulerServer) GetCancellations

func (s *BatchedQSchedulerServer) GetCancellations(ctx context.Context, r *swarming.GetCancellationsRequest) (resp *swarming.GetCancellationsResponse, err error)

GetCancellations implements QSchedulerServer.

func (*BatchedQSchedulerServer) NotifyTasks

func (s *BatchedQSchedulerServer) NotifyTasks(ctx context.Context, r *swarming.NotifyTasksRequest) (resp *swarming.NotifyTasksResponse, err error)

NotifyTasks implements QSchedulerServer.

type QSchedulerAdminServerImpl

type QSchedulerAdminServerImpl struct{}

QSchedulerAdminServerImpl implements QSchedulerAdminServer.

func (*QSchedulerAdminServerImpl) CreateAccount

func (s *QSchedulerAdminServerImpl) CreateAccount(ctx context.Context, r *qscheduler.CreateAccountRequest) (resp *qscheduler.CreateAccountResponse, err error)

CreateAccount implements QSchedulerAdminServer.

func (*QSchedulerAdminServerImpl) CreateSchedulerPool

func (s *QSchedulerAdminServerImpl) CreateSchedulerPool(ctx context.Context, r *qscheduler.CreateSchedulerPoolRequest) (resp *qscheduler.CreateSchedulerPoolResponse, err error)

CreateSchedulerPool implements QSchedulerAdminServer.

func (*QSchedulerAdminServerImpl) DeleteAccount

func (s *QSchedulerAdminServerImpl) DeleteAccount(ctx context.Context, r *qscheduler.DeleteAccountRequest) (resp *qscheduler.DeleteAccountResponse, err error)

DeleteAccount implements QSchedulerAdminServer.

func (*QSchedulerAdminServerImpl) DeleteSchedulerPool

func (s *QSchedulerAdminServerImpl) DeleteSchedulerPool(ctx context.Context, r *qscheduler.DeleteSchedulerPoolRequest) (resp *qscheduler.DeleteSchedulerPoolResponse, err error)

DeleteSchedulerPool implements QSchedulerAdminServer.

func (*QSchedulerAdminServerImpl) ModAccount

func (s *QSchedulerAdminServerImpl) ModAccount(ctx context.Context, r *qscheduler.ModAccountRequest) (resp *qscheduler.ModAccountResponse, err error)

ModAccount implements QSchedulerAdminServer.

func (*QSchedulerAdminServerImpl) ModSchedulerPool

func (s *QSchedulerAdminServerImpl) ModSchedulerPool(ctx context.Context, r *qscheduler.ModSchedulerPoolRequest) (resp *qscheduler.ModSchedulerPoolResponse, err error)

ModSchedulerPool implements QSchedulerAdminServer.

func (*QSchedulerAdminServerImpl) Wipe

func (s *QSchedulerAdminServerImpl) Wipe(ctx context.Context, r *qscheduler.WipeRequest) (resp *qscheduler.WipeResponse, err error)

Wipe implements QSchedulerAdminServer.

type QSchedulerViewServerImpl

type QSchedulerViewServerImpl struct{}

QSchedulerViewServerImpl implements QSchedulerViewServer.

func (*QSchedulerViewServerImpl) InspectPool

func (s *QSchedulerViewServerImpl) InspectPool(ctx context.Context, r *qscheduler.InspectPoolRequest) (resp *qscheduler.InspectPoolResponse, err error)

InspectPool implements QSchedulerAdminServer.

func (*QSchedulerViewServerImpl) ListAccounts

func (s *QSchedulerViewServerImpl) ListAccounts(ctx context.Context, r *qscheduler.ListAccountsRequest) (resp *qscheduler.ListAccountsResponse, err error)

ListAccounts implements QSchedulerAdminServer.