qscheduler

package
v0.0.0-...-e560ebb Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 13, 2021 License: BSD-3-Clause Imports: 14 Imported by: 0

Documentation

Overview

Package qscheduler contains service definitions for the qscheduler app.

Index

Constants

This section is empty.

Variables

View Source 
var File_infra_qscheduler_service_api_qscheduler_v1_admin_proto protoreflect.FileDescriptor

Functions

func FileDescriptorSet 

func FileDescriptorSet() *descriptorpb.FileDescriptorSet

FileDescriptorSet returns a descriptor set for this proto package, which includes all defined services, and all transitive dependencies.

Will not return nil.

Do NOT modify the returned descriptor.

func RegisterQSchedulerAdminServer 

func RegisterQSchedulerAdminServer(s prpc.Registrar, srv QSchedulerAdminServer)

func RegisterQSchedulerViewServer 

func RegisterQSchedulerViewServer(s prpc.Registrar, srv QSchedulerViewServer)

Types

type CreateAccountRequest 

type CreateAccountRequest struct {

	// PoolID is the id of the scheduler to create an account within.
	PoolId string `protobuf:"bytes,1,opt,name=pool_id,json=poolId,proto3" json:"pool_id,omitempty"`
	// AccountId is the unique id of the account (within the given pool).
	AccountId string `protobuf:"bytes,2,opt,name=account_id,json=accountId,proto3" json:"account_id,omitempty"`
	// Config is the quota account config for the quota account to create.
	Config *protos.AccountConfig `protobuf:"bytes,3,opt,name=config,proto3" json:"config,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateAccountRequest) Descriptor deprecated 

func (*CreateAccountRequest) Descriptor() ([]byte, []int)

Deprecated: Use CreateAccountRequest.ProtoReflect.Descriptor instead.

func (*CreateAccountRequest) GetAccountId 

func (x *CreateAccountRequest) GetAccountId() string

func (*CreateAccountRequest) GetConfig 

func (x *CreateAccountRequest) GetConfig() *protos.AccountConfig

func (*CreateAccountRequest) GetPoolId 

func (x *CreateAccountRequest) GetPoolId() string

func (*CreateAccountRequest) ProtoMessage 

func (*CreateAccountRequest) ProtoMessage()

func (*CreateAccountRequest) ProtoReflect 

func (x *CreateAccountRequest) ProtoReflect() protoreflect.Message

func (*CreateAccountRequest) Reset 

func (x *CreateAccountRequest) Reset()

func (*CreateAccountRequest) String 

func (x *CreateAccountRequest) String() string

type CreateAccountResponse 

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

func (*CreateAccountResponse) Descriptor deprecated 

func (*CreateAccountResponse) Descriptor() ([]byte, []int)

Deprecated: Use CreateAccountResponse.ProtoReflect.Descriptor instead.

func (*CreateAccountResponse) ProtoMessage 

func (*CreateAccountResponse) ProtoMessage()

func (*CreateAccountResponse) ProtoReflect 

func (x *CreateAccountResponse) ProtoReflect() protoreflect.Message

func (*CreateAccountResponse) Reset 

func (x *CreateAccountResponse) Reset()

func (*CreateAccountResponse) String 

func (x *CreateAccountResponse) String() string

type CreateSchedulerPoolRequest 

type CreateSchedulerPoolRequest struct {

	// PoolId is the unique id of this scheduler pool.
	PoolId string `protobuf:"bytes,1,opt,name=pool_id,json=poolId,proto3" json:"pool_id,omitempty"`
	// Deprecated, calls will fail if this is specified. Instead, create a pool
	// and then modify its config with later calls.
	//
	// Deprecated: Do not use.
	Config *protos.SchedulerConfig `protobuf:"bytes,2,opt,name=config,proto3" json:"config,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateSchedulerPoolRequest) Descriptor deprecated 

func (*CreateSchedulerPoolRequest) Descriptor() ([]byte, []int)

Deprecated: Use CreateSchedulerPoolRequest.ProtoReflect.Descriptor instead.

func (*CreateSchedulerPoolRequest) GetConfig deprecated 

func (x *CreateSchedulerPoolRequest) GetConfig() *protos.SchedulerConfig

Deprecated: Do not use.

func (*CreateSchedulerPoolRequest) GetPoolId 

func (x *CreateSchedulerPoolRequest) GetPoolId() string

func (*CreateSchedulerPoolRequest) ProtoMessage 

func (*CreateSchedulerPoolRequest) ProtoMessage()

func (*CreateSchedulerPoolRequest) ProtoReflect 

func (x *CreateSchedulerPoolRequest) ProtoReflect() protoreflect.Message

func (*CreateSchedulerPoolRequest) Reset 

func (x *CreateSchedulerPoolRequest) Reset()

func (*CreateSchedulerPoolRequest) String 

func (x *CreateSchedulerPoolRequest) String() string

type CreateSchedulerPoolResponse 

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

func (*CreateSchedulerPoolResponse) Descriptor deprecated 

func (*CreateSchedulerPoolResponse) Descriptor() ([]byte, []int)

Deprecated: Use CreateSchedulerPoolResponse.ProtoReflect.Descriptor instead.

func (*CreateSchedulerPoolResponse) ProtoMessage 

func (*CreateSchedulerPoolResponse) ProtoMessage()

func (*CreateSchedulerPoolResponse) ProtoReflect 

func (x *CreateSchedulerPoolResponse) ProtoReflect() protoreflect.Message

func (*CreateSchedulerPoolResponse) Reset 

func (x *CreateSchedulerPoolResponse) Reset()

func (*CreateSchedulerPoolResponse) String 

func (x *CreateSchedulerPoolResponse) String() string

type DecoratedQSchedulerAdmin 

type DecoratedQSchedulerAdmin struct {
	// Service is the service to decorate.
	Service QSchedulerAdminServer
	// Prelude is called for each method before forwarding the call to Service.
	// If Prelude returns an error, then the call is skipped and the error is
	// processed via the Postlude (if one is defined), or it is returned directly.
	Prelude func(ctx context.Context, methodName string, req proto.Message) (context.Context, error)
	// Postlude is called for each method after Service has processed the call, or
	// after the Prelude has returned an error. This takes the the Service's
	// response proto (which may be nil) and/or any error. The decorated
	// service will return the response (possibly mutated) and error that Postlude
	// returns.
	Postlude func(ctx context.Context, methodName string, rsp proto.Message, err error) error
}

func (*DecoratedQSchedulerAdmin) CreateAccount 

func (s *DecoratedQSchedulerAdmin) CreateAccount(ctx context.Context, req *CreateAccountRequest) (rsp *CreateAccountResponse, err error)

func (*DecoratedQSchedulerAdmin) CreateSchedulerPool 

func (s *DecoratedQSchedulerAdmin) CreateSchedulerPool(ctx context.Context, req *CreateSchedulerPoolRequest) (rsp *CreateSchedulerPoolResponse, err error)

func (*DecoratedQSchedulerAdmin) DeleteAccount 

func (s *DecoratedQSchedulerAdmin) DeleteAccount(ctx context.Context, req *DeleteAccountRequest) (rsp *DeleteAccountResponse, err error)

func (*DecoratedQSchedulerAdmin) DeleteSchedulerPool 

func (s *DecoratedQSchedulerAdmin) DeleteSchedulerPool(ctx context.Context, req *DeleteSchedulerPoolRequest) (rsp *DeleteSchedulerPoolResponse, err error)

func (*DecoratedQSchedulerAdmin) ModAccount 

func (s *DecoratedQSchedulerAdmin) ModAccount(ctx context.Context, req *ModAccountRequest) (rsp *ModAccountResponse, err error)

func (*DecoratedQSchedulerAdmin) ModSchedulerPool 

func (s *DecoratedQSchedulerAdmin) ModSchedulerPool(ctx context.Context, req *ModSchedulerPoolRequest) (rsp *ModSchedulerPoolResponse, err error)

func (*DecoratedQSchedulerAdmin) Wipe 

func (s *DecoratedQSchedulerAdmin) Wipe(ctx context.Context, req *WipeRequest) (rsp *WipeResponse, err error)

type DecoratedQSchedulerView 

type DecoratedQSchedulerView struct {
	// Service is the service to decorate.
	Service QSchedulerViewServer
	// Prelude is called for each method before forwarding the call to Service.
	// If Prelude returns an error, then the call is skipped and the error is
	// processed via the Postlude (if one is defined), or it is returned directly.
	Prelude func(ctx context.Context, methodName string, req proto.Message) (context.Context, error)
	// Postlude is called for each method after Service has processed the call, or
	// after the Prelude has returned an error. This takes the the Service's
	// response proto (which may be nil) and/or any error. The decorated
	// service will return the response (possibly mutated) and error that Postlude
	// returns.
	Postlude func(ctx context.Context, methodName string, rsp proto.Message, err error) error
}

func (*DecoratedQSchedulerView) InspectPool 

func (s *DecoratedQSchedulerView) InspectPool(ctx context.Context, req *InspectPoolRequest) (rsp *InspectPoolResponse, err error)

func (*DecoratedQSchedulerView) ListAccounts 

func (s *DecoratedQSchedulerView) ListAccounts(ctx context.Context, req *ListAccountsRequest) (rsp *ListAccountsResponse, err error)

type DeleteAccountRequest 

type DeleteAccountRequest struct {
	PoolId    string `protobuf:"bytes,1,opt,name=pool_id,json=poolId,proto3" json:"pool_id,omitempty"`
	AccountId string `protobuf:"bytes,2,opt,name=account_id,json=accountId,proto3" json:"account_id,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteAccountRequest) Descriptor deprecated 

func (*DeleteAccountRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeleteAccountRequest.ProtoReflect.Descriptor instead.

func (*DeleteAccountRequest) GetAccountId 

func (x *DeleteAccountRequest) GetAccountId() string

func (*DeleteAccountRequest) GetPoolId 

func (x *DeleteAccountRequest) GetPoolId() string

func (*DeleteAccountRequest) ProtoMessage 

func (*DeleteAccountRequest) ProtoMessage()

func (*DeleteAccountRequest) ProtoReflect 

func (x *DeleteAccountRequest) ProtoReflect() protoreflect.Message

func (*DeleteAccountRequest) Reset 

func (x *DeleteAccountRequest) Reset()

func (*DeleteAccountRequest) String 

func (x *DeleteAccountRequest) String() string

type DeleteAccountResponse 

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

func (*DeleteAccountResponse) Descriptor deprecated 

func (*DeleteAccountResponse) Descriptor() ([]byte, []int)

Deprecated: Use DeleteAccountResponse.ProtoReflect.Descriptor instead.

func (*DeleteAccountResponse) ProtoMessage 

func (*DeleteAccountResponse) ProtoMessage()

func (*DeleteAccountResponse) ProtoReflect 

func (x *DeleteAccountResponse) ProtoReflect() protoreflect.Message

func (*DeleteAccountResponse) Reset 

func (x *DeleteAccountResponse) Reset()

func (*DeleteAccountResponse) String 

func (x *DeleteAccountResponse) String() string

type DeleteSchedulerPoolRequest 

type DeleteSchedulerPoolRequest struct {
	PoolId string `protobuf:"bytes,1,opt,name=pool_id,json=poolId,proto3" json:"pool_id,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteSchedulerPoolRequest) Descriptor deprecated 

func (*DeleteSchedulerPoolRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeleteSchedulerPoolRequest.ProtoReflect.Descriptor instead.

func (*DeleteSchedulerPoolRequest) GetPoolId 

func (x *DeleteSchedulerPoolRequest) GetPoolId() string

func (*DeleteSchedulerPoolRequest) ProtoMessage 

func (*DeleteSchedulerPoolRequest) ProtoMessage()

func (*DeleteSchedulerPoolRequest) ProtoReflect 

func (x *DeleteSchedulerPoolRequest) ProtoReflect() protoreflect.Message

func (*DeleteSchedulerPoolRequest) Reset 

func (x *DeleteSchedulerPoolRequest) Reset()

func (*DeleteSchedulerPoolRequest) String 

func (x *DeleteSchedulerPoolRequest) String() string

type DeleteSchedulerPoolResponse 

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

func (*DeleteSchedulerPoolResponse) Descriptor deprecated 

func (*DeleteSchedulerPoolResponse) Descriptor() ([]byte, []int)

Deprecated: Use DeleteSchedulerPoolResponse.ProtoReflect.Descriptor instead.

func (*DeleteSchedulerPoolResponse) ProtoMessage 

func (*DeleteSchedulerPoolResponse) ProtoMessage()

func (*DeleteSchedulerPoolResponse) ProtoReflect 

func (x *DeleteSchedulerPoolResponse) ProtoReflect() protoreflect.Message

func (*DeleteSchedulerPoolResponse) Reset 

func (x *DeleteSchedulerPoolResponse) Reset()

func (*DeleteSchedulerPoolResponse) String 

func (x *DeleteSchedulerPoolResponse) String() string

type InspectPoolRequest 

type InspectPoolRequest struct {
	PoolId string `protobuf:"bytes,1,opt,name=pool_id,json=poolId,proto3" json:"pool_id,omitempty"`
	// contains filtered or unexported fields
}

func (*InspectPoolRequest) Descriptor deprecated 

func (*InspectPoolRequest) Descriptor() ([]byte, []int)

Deprecated: Use InspectPoolRequest.ProtoReflect.Descriptor instead.

func (*InspectPoolRequest) GetPoolId 

func (x *InspectPoolRequest) GetPoolId() string

func (*InspectPoolRequest) ProtoMessage 

func (*InspectPoolRequest) ProtoMessage()

func (*InspectPoolRequest) ProtoReflect 

func (x *InspectPoolRequest) ProtoReflect() protoreflect.Message

func (*InspectPoolRequest) Reset 

func (x *InspectPoolRequest) Reset()

func (*InspectPoolRequest) String 

func (x *InspectPoolRequest) String() string

type InspectPoolResponse 

type InspectPoolResponse struct {

	// NumWaitingTasks is the number of waiting tasks.
	NumWaitingTasks int32 `protobuf:"varint,1,opt,name=num_waiting_tasks,json=numWaitingTasks,proto3" json:"num_waiting_tasks,omitempty"`
	// NumRunningTasks is the number of running tasks.
	NumRunningTasks int32 `protobuf:"varint,2,opt,name=num_running_tasks,json=numRunningTasks,proto3" json:"num_running_tasks,omitempty"`
	// IdleBots is the number of idle bots.
	NumIdleBots int32 `protobuf:"varint,3,opt,name=num_idle_bots,json=numIdleBots,proto3" json:"num_idle_bots,omitempty"`
	// AccountBalances is the set of balances for all accounts.
	AccountBalances map[string]*protos.SchedulerState_Balance `` /* 194-byte string literal not displayed */
	// RunningTasks is a description of the running tasks according to
	// quotascheduler.
	RunningTasks []*InspectPoolResponse_RunningTask `protobuf:"bytes,5,rep,name=running_tasks,json=runningTasks,proto3" json:"running_tasks,omitempty"`
	// WaitingTasks is a description of the tasks that are waiting
	// according to quotascheduler.
	WaitingTasks []*InspectPoolResponse_WaitingTask `protobuf:"bytes,6,rep,name=waiting_tasks,json=waitingTasks,proto3" json:"waiting_tasks,omitempty"`
	// IdleBots is a description of the idle bots according to quotascheduler.
	IdleBots []*InspectPoolResponse_IdleBot `protobuf:"bytes,7,rep,name=idle_bots,json=idleBots,proto3" json:"idle_bots,omitempty"`
	// AccountConfigs is a description of the account configs.
	AccountConfigs map[string]*protos.AccountConfig `` /* 191-byte string literal not displayed */
	// DisablePreemption indicates whether preemption is disabled.
	DisablePreemption bool `protobuf:"varint,10,opt,name=disable_preemption,json=disablePreemption,proto3" json:"disable_preemption,omitempty"`
	// contains filtered or unexported fields
}

func (*InspectPoolResponse) Descriptor deprecated 

func (*InspectPoolResponse) Descriptor() ([]byte, []int)

Deprecated: Use InspectPoolResponse.ProtoReflect.Descriptor instead.

func (*InspectPoolResponse) GetAccountBalances 

func (x *InspectPoolResponse) GetAccountBalances() map[string]*protos.SchedulerState_Balance

func (*InspectPoolResponse) GetAccountConfigs 

func (x *InspectPoolResponse) GetAccountConfigs() map[string]*protos.AccountConfig

func (*InspectPoolResponse) GetDisablePreemption 

func (x *InspectPoolResponse) GetDisablePreemption() bool

func (*InspectPoolResponse) GetIdleBots 

func (x *InspectPoolResponse) GetIdleBots() []*InspectPoolResponse_IdleBot

func (*InspectPoolResponse) GetNumIdleBots 

func (x *InspectPoolResponse) GetNumIdleBots() int32

func (*InspectPoolResponse) GetNumRunningTasks 

func (x *InspectPoolResponse) GetNumRunningTasks() int32

func (*InspectPoolResponse) GetNumWaitingTasks 

func (x *InspectPoolResponse) GetNumWaitingTasks() int32

func (*InspectPoolResponse) GetRunningTasks 

func (x *InspectPoolResponse) GetRunningTasks() []*InspectPoolResponse_RunningTask

func (*InspectPoolResponse) GetWaitingTasks 

func (x *InspectPoolResponse) GetWaitingTasks() []*InspectPoolResponse_WaitingTask

func (*InspectPoolResponse) ProtoMessage 

func (*InspectPoolResponse) ProtoMessage()

func (*InspectPoolResponse) ProtoReflect 

func (x *InspectPoolResponse) ProtoReflect() protoreflect.Message

func (*InspectPoolResponse) Reset 

func (x *InspectPoolResponse) Reset()

func (*InspectPoolResponse) String 

func (x *InspectPoolResponse) String() string

type InspectPoolResponse_IdleBot 

type InspectPoolResponse_IdleBot struct {

	// Id is the id of the bot.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Dimensions are the dimensions of the bot.
	Dimensions []string `protobuf:"bytes,2,rep,name=dimensions,proto3" json:"dimensions,omitempty"`
	// Age in seconds of bot, measured from the last time at which the
	// idle state was confirmed.
	AgeSeconds int32 `protobuf:"varint,3,opt,name=age_seconds,json=ageSeconds,proto3" json:"age_seconds,omitempty"`
	// contains filtered or unexported fields
}

func (*InspectPoolResponse_IdleBot) Descriptor deprecated 

func (*InspectPoolResponse_IdleBot) Descriptor() ([]byte, []int)

Deprecated: Use InspectPoolResponse_IdleBot.ProtoReflect.Descriptor instead.

func (*InspectPoolResponse_IdleBot) GetAgeSeconds 

func (x *InspectPoolResponse_IdleBot) GetAgeSeconds() int32

func (*InspectPoolResponse_IdleBot) GetDimensions 

func (x *InspectPoolResponse_IdleBot) GetDimensions() []string

func (*InspectPoolResponse_IdleBot) GetId 

func (x *InspectPoolResponse_IdleBot) GetId() string

func (*InspectPoolResponse_IdleBot) ProtoMessage 

func (*InspectPoolResponse_IdleBot) ProtoMessage()

func (*InspectPoolResponse_IdleBot) ProtoReflect 

func (x *InspectPoolResponse_IdleBot) ProtoReflect() protoreflect.Message

func (*InspectPoolResponse_IdleBot) Reset 

func (x *InspectPoolResponse_IdleBot) Reset()

func (*InspectPoolResponse_IdleBot) String 

func (x *InspectPoolResponse_IdleBot) String() string

type InspectPoolResponse_RunningTask 

type InspectPoolResponse_RunningTask struct {

	// Id is the id of the request.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// BotId is the id of the bot running the request.
	BotId string `protobuf:"bytes,2,opt,name=bot_id,json=botId,proto3" json:"bot_id,omitempty"`
	// Priority is the current quotascheduler priority that the task is
	// running at.
	Priority int32 `protobuf:"varint,3,opt,name=priority,proto3" json:"priority,omitempty"`
	// AccountID is the account id of the request.
	AccountId string `protobuf:"bytes,4,opt,name=account_id,json=accountId,proto3" json:"account_id,omitempty"`
	// Age in seconds of the task, measured from the last time at which
	// the running state was confirmed.
	AgeSeconds int32 `protobuf:"varint,5,opt,name=age_seconds,json=ageSeconds,proto3" json:"age_seconds,omitempty"`
	// contains filtered or unexported fields
}

func (*InspectPoolResponse_RunningTask) Descriptor deprecated 

func (*InspectPoolResponse_RunningTask) Descriptor() ([]byte, []int)

Deprecated: Use InspectPoolResponse_RunningTask.ProtoReflect.Descriptor instead.

func (*InspectPoolResponse_RunningTask) GetAccountId 

func (x *InspectPoolResponse_RunningTask) GetAccountId() string

func (*InspectPoolResponse_RunningTask) GetAgeSeconds 

func (x *InspectPoolResponse_RunningTask) GetAgeSeconds() int32

func (*InspectPoolResponse_RunningTask) GetBotId 

func (x *InspectPoolResponse_RunningTask) GetBotId() string

func (*InspectPoolResponse_RunningTask) GetId 

func (x *InspectPoolResponse_RunningTask) GetId() string

func (*InspectPoolResponse_RunningTask) GetPriority 

func (x *InspectPoolResponse_RunningTask) GetPriority() int32

func (*InspectPoolResponse_RunningTask) ProtoMessage 

func (*InspectPoolResponse_RunningTask) ProtoMessage()

func (*InspectPoolResponse_RunningTask) ProtoReflect 

func (x *InspectPoolResponse_RunningTask) ProtoReflect() protoreflect.Message

func (*InspectPoolResponse_RunningTask) Reset 

func (x *InspectPoolResponse_RunningTask) Reset()

func (*InspectPoolResponse_RunningTask) String 

func (x *InspectPoolResponse_RunningTask) String() string

type InspectPoolResponse_WaitingTask 

type InspectPoolResponse_WaitingTask struct {

	// Id is the id of the request.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// AccountID is the account id of the request.
	AccountId string `protobuf:"bytes,2,opt,name=account_id,json=accountId,proto3" json:"account_id,omitempty"`
	// Age in seconds of waiting task, measured from the last time at
	// which the waiting state was confirmed.
	AgeSeconds int32 `protobuf:"varint,3,opt,name=age_seconds,json=ageSeconds,proto3" json:"age_seconds,omitempty"`
	// contains filtered or unexported fields
}

func (*InspectPoolResponse_WaitingTask) Descriptor deprecated 

func (*InspectPoolResponse_WaitingTask) Descriptor() ([]byte, []int)

Deprecated: Use InspectPoolResponse_WaitingTask.ProtoReflect.Descriptor instead.

func (*InspectPoolResponse_WaitingTask) GetAccountId 

func (x *InspectPoolResponse_WaitingTask) GetAccountId() string

func (*InspectPoolResponse_WaitingTask) GetAgeSeconds 

func (x *InspectPoolResponse_WaitingTask) GetAgeSeconds() int32

func (*InspectPoolResponse_WaitingTask) GetId 

func (x *InspectPoolResponse_WaitingTask) GetId() string

func (*InspectPoolResponse_WaitingTask) ProtoMessage 

func (*InspectPoolResponse_WaitingTask) ProtoMessage()

func (*InspectPoolResponse_WaitingTask) ProtoReflect 

func (x *InspectPoolResponse_WaitingTask) ProtoReflect() protoreflect.Message

func (*InspectPoolResponse_WaitingTask) Reset 

func (x *InspectPoolResponse_WaitingTask) Reset()

func (*InspectPoolResponse_WaitingTask) String 

func (x *InspectPoolResponse_WaitingTask) String() string

type ListAccountsRequest 

type ListAccountsRequest struct {

	// PoolID is the id of the scheduler to list accounts from.
	PoolId string `protobuf:"bytes,1,opt,name=pool_id,json=poolId,proto3" json:"pool_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ListAccountsRequest) Descriptor deprecated 

func (*ListAccountsRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListAccountsRequest.ProtoReflect.Descriptor instead.

func (*ListAccountsRequest) GetPoolId 

func (x *ListAccountsRequest) GetPoolId() string

func (*ListAccountsRequest) ProtoMessage 

func (*ListAccountsRequest) ProtoMessage()

func (*ListAccountsRequest) ProtoReflect 

func (x *ListAccountsRequest) ProtoReflect() protoreflect.Message

func (*ListAccountsRequest) Reset 

func (x *ListAccountsRequest) Reset()

func (*ListAccountsRequest) String 

func (x *ListAccountsRequest) String() string

type ListAccountsResponse 

type ListAccountsResponse struct {
	Accounts map[string]*protos.AccountConfig `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ListAccountsResponse) Descriptor deprecated 

func (*ListAccountsResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListAccountsResponse.ProtoReflect.Descriptor instead.

func (*ListAccountsResponse) GetAccounts 

func (x *ListAccountsResponse) GetAccounts() map[string]*protos.AccountConfig

func (*ListAccountsResponse) ProtoMessage 

func (*ListAccountsResponse) ProtoMessage()

func (*ListAccountsResponse) ProtoReflect 

func (x *ListAccountsResponse) ProtoReflect() protoreflect.Message

func (*ListAccountsResponse) Reset 

func (x *ListAccountsResponse) Reset()

func (*ListAccountsResponse) String 

func (x *ListAccountsResponse) String() string

type ModAccountRequest 

type ModAccountRequest struct {
	PoolId           string                 `protobuf:"bytes,1,opt,name=pool_id,json=poolId,proto3" json:"pool_id,omitempty"`
	AccountId        string                 `protobuf:"bytes,2,opt,name=account_id,json=accountId,proto3" json:"account_id,omitempty"`
	ChargeRate       []float32              `protobuf:"fixed32,3,rep,packed,name=charge_rate,json=chargeRate,proto3" json:"charge_rate,omitempty"`
	MaxChargeSeconds *wrapperspb.FloatValue `protobuf:"bytes,4,opt,name=max_charge_seconds,json=maxChargeSeconds,proto3" json:"max_charge_seconds,omitempty"`
	MaxFanout        *wrapperspb.Int32Value `protobuf:"bytes,5,opt,name=max_fanout,json=maxFanout,proto3" json:"max_fanout,omitempty"`
	DisableFreeTasks *wrapperspb.BoolValue  `protobuf:"bytes,6,opt,name=disable_free_tasks,json=disableFreeTasks,proto3" json:"disable_free_tasks,omitempty"`
	// If true, reset this account's balance to 0.
	ResetBalance       bool                    `protobuf:"varint,7,opt,name=reset_balance,json=resetBalance,proto3" json:"reset_balance,omitempty"`
	Description        *wrapperspb.StringValue `protobuf:"bytes,8,opt,name=description,proto3" json:"description,omitempty"`
	PerLabelTaskLimits map[string]int32        `` /* 208-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ModAccountRequest) Descriptor deprecated 

func (*ModAccountRequest) Descriptor() ([]byte, []int)

Deprecated: Use ModAccountRequest.ProtoReflect.Descriptor instead.

func (*ModAccountRequest) GetAccountId 

func (x *ModAccountRequest) GetAccountId() string

func (*ModAccountRequest) GetChargeRate 

func (x *ModAccountRequest) GetChargeRate() []float32

func (*ModAccountRequest) GetDescription 

func (x *ModAccountRequest) GetDescription() *wrapperspb.StringValue

func (*ModAccountRequest) GetDisableFreeTasks 

func (x *ModAccountRequest) GetDisableFreeTasks() *wrapperspb.BoolValue

func (*ModAccountRequest) GetMaxChargeSeconds 

func (x *ModAccountRequest) GetMaxChargeSeconds() *wrapperspb.FloatValue

func (*ModAccountRequest) GetMaxFanout 

func (x *ModAccountRequest) GetMaxFanout() *wrapperspb.Int32Value

func (*ModAccountRequest) GetPerLabelTaskLimits 

func (x *ModAccountRequest) GetPerLabelTaskLimits() map[string]int32

func (*ModAccountRequest) GetPoolId 

func (x *ModAccountRequest) GetPoolId() string

func (*ModAccountRequest) GetResetBalance 

func (x *ModAccountRequest) GetResetBalance() bool

func (*ModAccountRequest) ProtoMessage 

func (*ModAccountRequest) ProtoMessage()

func (*ModAccountRequest) ProtoReflect 

func (x *ModAccountRequest) ProtoReflect() protoreflect.Message

func (*ModAccountRequest) Reset 

func (x *ModAccountRequest) Reset()

func (*ModAccountRequest) String 

func (x *ModAccountRequest) String() string

type ModAccountResponse 

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

func (*ModAccountResponse) Descriptor deprecated 

func (*ModAccountResponse) Descriptor() ([]byte, []int)

Deprecated: Use ModAccountResponse.ProtoReflect.Descriptor instead.

func (*ModAccountResponse) ProtoMessage 

func (*ModAccountResponse) ProtoMessage()

func (*ModAccountResponse) ProtoReflect 

func (x *ModAccountResponse) ProtoReflect() protoreflect.Message

func (*ModAccountResponse) Reset 

func (x *ModAccountResponse) Reset()

func (*ModAccountResponse) String 

func (x *ModAccountResponse) String() string

type ModSchedulerPoolRequest 

type ModSchedulerPoolRequest struct {
	PoolId               string                 `protobuf:"bytes,1,opt,name=pool_id,json=poolId,proto3" json:"pool_id,omitempty"`
	DisablePreemption    *wrapperspb.BoolValue  `protobuf:"bytes,2,opt,name=disable_preemption,json=disablePreemption,proto3" json:"disable_preemption,omitempty"`
	BotExpirationSeconds *wrapperspb.Int32Value `protobuf:"bytes,3,opt,name=bot_expiration_seconds,json=botExpirationSeconds,proto3" json:"bot_expiration_seconds,omitempty"`
	// contains filtered or unexported fields
}

func (*ModSchedulerPoolRequest) Descriptor deprecated 

func (*ModSchedulerPoolRequest) Descriptor() ([]byte, []int)

Deprecated: Use ModSchedulerPoolRequest.ProtoReflect.Descriptor instead.

func (*ModSchedulerPoolRequest) GetBotExpirationSeconds 

func (x *ModSchedulerPoolRequest) GetBotExpirationSeconds() *wrapperspb.Int32Value

func (*ModSchedulerPoolRequest) GetDisablePreemption 

func (x *ModSchedulerPoolRequest) GetDisablePreemption() *wrapperspb.BoolValue

func (*ModSchedulerPoolRequest) GetPoolId 

func (x *ModSchedulerPoolRequest) GetPoolId() string

func (*ModSchedulerPoolRequest) ProtoMessage 

func (*ModSchedulerPoolRequest) ProtoMessage()

func (*ModSchedulerPoolRequest) ProtoReflect 

func (x *ModSchedulerPoolRequest) ProtoReflect() protoreflect.Message

func (*ModSchedulerPoolRequest) Reset 

func (x *ModSchedulerPoolRequest) Reset()

func (*ModSchedulerPoolRequest) String 

func (x *ModSchedulerPoolRequest) String() string

type ModSchedulerPoolResponse 

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

func (*ModSchedulerPoolResponse) Descriptor deprecated 

func (*ModSchedulerPoolResponse) Descriptor() ([]byte, []int)

Deprecated: Use ModSchedulerPoolResponse.ProtoReflect.Descriptor instead.

func (*ModSchedulerPoolResponse) ProtoMessage 

func (*ModSchedulerPoolResponse) ProtoMessage()

func (*ModSchedulerPoolResponse) ProtoReflect 

func (x *ModSchedulerPoolResponse) ProtoReflect() protoreflect.Message

func (*ModSchedulerPoolResponse) Reset 

func (x *ModSchedulerPoolResponse) Reset()

func (*ModSchedulerPoolResponse) String 

func (x *ModSchedulerPoolResponse) String() string

type QSchedulerAdminClient 

type QSchedulerAdminClient interface {
	// CreateSchedulerPool creates a scheduler, with the given configuration
	// options.
	CreateSchedulerPool(ctx context.Context, in *CreateSchedulerPoolRequest, opts ...grpc.CallOption) (*CreateSchedulerPoolResponse, error)
	// CreateAccount creates a quota account within a scheduler, with the
	// given configuration options.
	CreateAccount(ctx context.Context, in *CreateAccountRequest, opts ...grpc.CallOption) (*CreateAccountResponse, error)
	// Wipe wipes out the state of a scheduler.
	//
	// This endpoint is intended for debug purposes, and may go away at any
	// point. May have significant correctness or performance impact on
	// scheduler.
	Wipe(ctx context.Context, in *WipeRequest, opts ...grpc.CallOption) (*WipeResponse, error)
	// ModAccount modifies an account.
	ModAccount(ctx context.Context, in *ModAccountRequest, opts ...grpc.CallOption) (*ModAccountResponse, error)
	// ModSchedulerPool modifies a scheduler.
	ModSchedulerPool(ctx context.Context, in *ModSchedulerPoolRequest, opts ...grpc.CallOption) (*ModSchedulerPoolResponse, error)
	// DeleteAccount deletes an account.
	DeleteAccount(ctx context.Context, in *DeleteAccountRequest, opts ...grpc.CallOption) (*DeleteAccountResponse, error)
	// DeleteSchedulerPool deletes a scheduler.
	DeleteSchedulerPool(ctx context.Context, in *DeleteSchedulerPoolRequest, opts ...grpc.CallOption) (*DeleteSchedulerPoolResponse, error)
}

QSchedulerAdminClient is the client API for QSchedulerAdmin service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewQSchedulerAdminClient 

func NewQSchedulerAdminClient(cc grpc.ClientConnInterface) QSchedulerAdminClient

func NewQSchedulerAdminPRPCClient 

func NewQSchedulerAdminPRPCClient(client *prpc.Client) QSchedulerAdminClient

type QSchedulerAdminServer 

type QSchedulerAdminServer interface {
	// CreateSchedulerPool creates a scheduler, with the given configuration
	// options.
	CreateSchedulerPool(context.Context, *CreateSchedulerPoolRequest) (*CreateSchedulerPoolResponse, error)
	// CreateAccount creates a quota account within a scheduler, with the
	// given configuration options.
	CreateAccount(context.Context, *CreateAccountRequest) (*CreateAccountResponse, error)
	// Wipe wipes out the state of a scheduler.
	//
	// This endpoint is intended for debug purposes, and may go away at any
	// point. May have significant correctness or performance impact on
	// scheduler.
	Wipe(context.Context, *WipeRequest) (*WipeResponse, error)
	// ModAccount modifies an account.
	ModAccount(context.Context, *ModAccountRequest) (*ModAccountResponse, error)
	// ModSchedulerPool modifies a scheduler.
	ModSchedulerPool(context.Context, *ModSchedulerPoolRequest) (*ModSchedulerPoolResponse, error)
	// DeleteAccount deletes an account.
	DeleteAccount(context.Context, *DeleteAccountRequest) (*DeleteAccountResponse, error)
	// DeleteSchedulerPool deletes a scheduler.
	DeleteSchedulerPool(context.Context, *DeleteSchedulerPoolRequest) (*DeleteSchedulerPoolResponse, error)
}

QSchedulerAdminServer is the server API for QSchedulerAdmin service.

type QSchedulerViewClient 

type QSchedulerViewClient interface {
	// ListAccounts returns the set of accounts for a given scheduler.
	ListAccounts(ctx context.Context, in *ListAccountsRequest, opts ...grpc.CallOption) (*ListAccountsResponse, error)
	// InspectPool returns a description of the state of a scheduler, for debugging
	// or diagnostic purposes.
	InspectPool(ctx context.Context, in *InspectPoolRequest, opts ...grpc.CallOption) (*InspectPoolResponse, error)
}

QSchedulerViewClient is the client API for QSchedulerView service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewQSchedulerViewClient 

func NewQSchedulerViewClient(cc grpc.ClientConnInterface) QSchedulerViewClient

func NewQSchedulerViewPRPCClient 

func NewQSchedulerViewPRPCClient(client *prpc.Client) QSchedulerViewClient

type QSchedulerViewServer 

type QSchedulerViewServer interface {
	// ListAccounts returns the set of accounts for a given scheduler.
	ListAccounts(context.Context, *ListAccountsRequest) (*ListAccountsResponse, error)
	// InspectPool returns a description of the state of a scheduler, for debugging
	// or diagnostic purposes.
	InspectPool(context.Context, *InspectPoolRequest) (*InspectPoolResponse, error)
}

QSchedulerViewServer is the server API for QSchedulerView service.

type UnimplementedQSchedulerAdminServer 

type UnimplementedQSchedulerAdminServer struct {
}

UnimplementedQSchedulerAdminServer can be embedded to have forward compatible implementations.

func (*UnimplementedQSchedulerAdminServer) CreateAccount 

func (*UnimplementedQSchedulerAdminServer) CreateAccount(context.Context, *CreateAccountRequest) (*CreateAccountResponse, error)

func (*UnimplementedQSchedulerAdminServer) CreateSchedulerPool 

func (*UnimplementedQSchedulerAdminServer) CreateSchedulerPool(context.Context, *CreateSchedulerPoolRequest) (*CreateSchedulerPoolResponse, error)

func (*UnimplementedQSchedulerAdminServer) DeleteAccount 

func (*UnimplementedQSchedulerAdminServer) DeleteAccount(context.Context, *DeleteAccountRequest) (*DeleteAccountResponse, error)

func (*UnimplementedQSchedulerAdminServer) DeleteSchedulerPool 

func (*UnimplementedQSchedulerAdminServer) DeleteSchedulerPool(context.Context, *DeleteSchedulerPoolRequest) (*DeleteSchedulerPoolResponse, error)

func (*UnimplementedQSchedulerAdminServer) ModAccount 

func (*UnimplementedQSchedulerAdminServer) ModAccount(context.Context, *ModAccountRequest) (*ModAccountResponse, error)

func (*UnimplementedQSchedulerAdminServer) ModSchedulerPool 

func (*UnimplementedQSchedulerAdminServer) ModSchedulerPool(context.Context, *ModSchedulerPoolRequest) (*ModSchedulerPoolResponse, error)

func (*UnimplementedQSchedulerAdminServer) Wipe 

func (*UnimplementedQSchedulerAdminServer) Wipe(context.Context, *WipeRequest) (*WipeResponse, error)

type UnimplementedQSchedulerViewServer 

type UnimplementedQSchedulerViewServer struct {
}

UnimplementedQSchedulerViewServer can be embedded to have forward compatible implementations.

func (*UnimplementedQSchedulerViewServer) InspectPool 

func (*UnimplementedQSchedulerViewServer) InspectPool(context.Context, *InspectPoolRequest) (*InspectPoolResponse, error)

func (*UnimplementedQSchedulerViewServer) ListAccounts 

func (*UnimplementedQSchedulerViewServer) ListAccounts(context.Context, *ListAccountsRequest) (*ListAccountsResponse, error)

type WipeRequest 

type WipeRequest struct {

	// PoolID is the id of the scheduler to wipe.
	PoolId string `protobuf:"bytes,1,opt,name=pool_id,json=poolId,proto3" json:"pool_id,omitempty"`
	// contains filtered or unexported fields
}

func (*WipeRequest) Descriptor deprecated 

func (*WipeRequest) Descriptor() ([]byte, []int)

Deprecated: Use WipeRequest.ProtoReflect.Descriptor instead.

func (*WipeRequest) GetPoolId 

func (x *WipeRequest) GetPoolId() string

func (*WipeRequest) ProtoMessage 

func (*WipeRequest) ProtoMessage()

func (*WipeRequest) ProtoReflect 

func (x *WipeRequest) ProtoReflect() protoreflect.Message

func (*WipeRequest) Reset 

func (x *WipeRequest) Reset()

func (*WipeRequest) String 

func (x *WipeRequest) String() string

type WipeResponse 

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

func (*WipeResponse) Descriptor deprecated 

func (*WipeResponse) Descriptor() ([]byte, []int)

Deprecated: Use WipeResponse.ProtoReflect.Descriptor instead.

func (*WipeResponse) ProtoMessage 

func (*WipeResponse) ProtoMessage()

func (*WipeResponse) ProtoReflect 

func (x *WipeResponse) ProtoReflect() protoreflect.Message

func (*WipeResponse) Reset 

func (x *WipeResponse) Reset()

func (*WipeResponse) String 

func (x *WipeResponse) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.