frontend

Documentation

Overview

Package frontend exposes the primary pRPC API of qscheduler app.

Index

• Variables
• func InstallServices(apiServer grpc.ServiceRegistrar)
• 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 grpc.ServiceRegistrar)

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.