buildqueuestate

package
v0.0.0-...-8a43a77 Latest Latest
Warning

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

 Go to latest Published: Oct 30, 2024 License: Apache-2.0 Imports: 14 Imported by: 2

Documentation

Index

Constants

View Source 
const (
	BuildQueueState_GetOperation_FullMethodName           = "/buildbarn.buildqueuestate.BuildQueueState/GetOperation"
	BuildQueueState_ListOperations_FullMethodName         = "/buildbarn.buildqueuestate.BuildQueueState/ListOperations"
	BuildQueueState_KillOperations_FullMethodName         = "/buildbarn.buildqueuestate.BuildQueueState/KillOperations"
	BuildQueueState_ListPlatformQueues_FullMethodName     = "/buildbarn.buildqueuestate.BuildQueueState/ListPlatformQueues"
	BuildQueueState_ListInvocationChildren_FullMethodName = "/buildbarn.buildqueuestate.BuildQueueState/ListInvocationChildren"
	BuildQueueState_ListQueuedOperations_FullMethodName   = "/buildbarn.buildqueuestate.BuildQueueState/ListQueuedOperations"
	BuildQueueState_ListWorkers_FullMethodName            = "/buildbarn.buildqueuestate.BuildQueueState/ListWorkers"
	BuildQueueState_TerminateWorkers_FullMethodName       = "/buildbarn.buildqueuestate.BuildQueueState/TerminateWorkers"
	BuildQueueState_ListDrains_FullMethodName             = "/buildbarn.buildqueuestate.BuildQueueState/ListDrains"
	BuildQueueState_AddDrain_FullMethodName               = "/buildbarn.buildqueuestate.BuildQueueState/AddDrain"
	BuildQueueState_RemoveDrain_FullMethodName            = "/buildbarn.buildqueuestate.BuildQueueState/RemoveDrain"
)

Variables

View Source 
var (
	ListInvocationChildrenRequest_Filter_name = map[int32]string{
		0: "ALL",
		1: "ACTIVE",
		2: "QUEUED",
	}
	ListInvocationChildrenRequest_Filter_value = map[string]int32{
		"ALL":    0,
		"ACTIVE": 1,
		"QUEUED": 2,
	}
)

Enum value maps for ListInvocationChildrenRequest_Filter.

View Source 
var BuildQueueState_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "buildbarn.buildqueuestate.BuildQueueState",
	HandlerType: (*BuildQueueStateServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetOperation",
			Handler:    _BuildQueueState_GetOperation_Handler,
		},
		{
			MethodName: "ListOperations",
			Handler:    _BuildQueueState_ListOperations_Handler,
		},
		{
			MethodName: "KillOperations",
			Handler:    _BuildQueueState_KillOperations_Handler,
		},
		{
			MethodName: "ListPlatformQueues",
			Handler:    _BuildQueueState_ListPlatformQueues_Handler,
		},
		{
			MethodName: "ListInvocationChildren",
			Handler:    _BuildQueueState_ListInvocationChildren_Handler,
		},
		{
			MethodName: "ListQueuedOperations",
			Handler:    _BuildQueueState_ListQueuedOperations_Handler,
		},
		{
			MethodName: "ListWorkers",
			Handler:    _BuildQueueState_ListWorkers_Handler,
		},
		{
			MethodName: "TerminateWorkers",
			Handler:    _BuildQueueState_TerminateWorkers_Handler,
		},
		{
			MethodName: "ListDrains",
			Handler:    _BuildQueueState_ListDrains_Handler,
		},
		{
			MethodName: "AddDrain",
			Handler:    _BuildQueueState_AddDrain_Handler,
		},
		{
			MethodName: "RemoveDrain",
			Handler:    _BuildQueueState_RemoveDrain_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "pkg/proto/buildqueuestate/buildqueuestate.proto",
}

BuildQueueState_ServiceDesc is the grpc.ServiceDesc for BuildQueueState service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_pkg_proto_buildqueuestate_buildqueuestate_proto protoreflect.FileDescriptor

Functions

func RegisterBuildQueueStateServer 

func RegisterBuildQueueStateServer(s grpc.ServiceRegistrar, srv BuildQueueStateServer)

Types

type AddOrRemoveDrainRequest 

type AddOrRemoveDrainRequest struct {
	SizeClassQueueName *SizeClassQueueName `protobuf:"bytes,1,opt,name=size_class_queue_name,json=sizeClassQueueName,proto3" json:"size_class_queue_name,omitempty"`
	WorkerIdPattern    map[string]string   `` /* 196-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*AddOrRemoveDrainRequest) Descriptor deprecated 

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

Deprecated: Use AddOrRemoveDrainRequest.ProtoReflect.Descriptor instead.

func (*AddOrRemoveDrainRequest) GetSizeClassQueueName 

func (x *AddOrRemoveDrainRequest) GetSizeClassQueueName() *SizeClassQueueName

func (*AddOrRemoveDrainRequest) GetWorkerIdPattern 

func (x *AddOrRemoveDrainRequest) GetWorkerIdPattern() map[string]string

func (*AddOrRemoveDrainRequest) ProtoMessage 

func (*AddOrRemoveDrainRequest) ProtoMessage()

func (*AddOrRemoveDrainRequest) ProtoReflect 

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

func (*AddOrRemoveDrainRequest) Reset 

func (x *AddOrRemoveDrainRequest) Reset()

func (*AddOrRemoveDrainRequest) String 

func (x *AddOrRemoveDrainRequest) String() string

type BackgroundLearning 

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

func (*BackgroundLearning) Descriptor deprecated 

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

Deprecated: Use BackgroundLearning.ProtoReflect.Descriptor instead.

func (*BackgroundLearning) ProtoMessage 

func (*BackgroundLearning) ProtoMessage()

func (*BackgroundLearning) ProtoReflect 

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

func (*BackgroundLearning) Reset 

func (x *BackgroundLearning) Reset()

func (*BackgroundLearning) String 

func (x *BackgroundLearning) String() string

type BuildQueueStateClient 

type BuildQueueStateClient interface {
	GetOperation(ctx context.Context, in *GetOperationRequest, opts ...grpc.CallOption) (*GetOperationResponse, error)
	ListOperations(ctx context.Context, in *ListOperationsRequest, opts ...grpc.CallOption) (*ListOperationsResponse, error)
	KillOperations(ctx context.Context, in *KillOperationsRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	ListPlatformQueues(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ListPlatformQueuesResponse, error)
	ListInvocationChildren(ctx context.Context, in *ListInvocationChildrenRequest, opts ...grpc.CallOption) (*ListInvocationChildrenResponse, error)
	ListQueuedOperations(ctx context.Context, in *ListQueuedOperationsRequest, opts ...grpc.CallOption) (*ListQueuedOperationsResponse, error)
	ListWorkers(ctx context.Context, in *ListWorkersRequest, opts ...grpc.CallOption) (*ListWorkersResponse, error)
	TerminateWorkers(ctx context.Context, in *TerminateWorkersRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	ListDrains(ctx context.Context, in *ListDrainsRequest, opts ...grpc.CallOption) (*ListDrainsResponse, error)
	AddDrain(ctx context.Context, in *AddOrRemoveDrainRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	RemoveDrain(ctx context.Context, in *AddOrRemoveDrainRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

BuildQueueStateClient is the client API for BuildQueueState service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewBuildQueueStateClient 

func NewBuildQueueStateClient(cc grpc.ClientConnInterface) BuildQueueStateClient

type BuildQueueStateServer 

type BuildQueueStateServer interface {
	GetOperation(context.Context, *GetOperationRequest) (*GetOperationResponse, error)
	ListOperations(context.Context, *ListOperationsRequest) (*ListOperationsResponse, error)
	KillOperations(context.Context, *KillOperationsRequest) (*emptypb.Empty, error)
	ListPlatformQueues(context.Context, *emptypb.Empty) (*ListPlatformQueuesResponse, error)
	ListInvocationChildren(context.Context, *ListInvocationChildrenRequest) (*ListInvocationChildrenResponse, error)
	ListQueuedOperations(context.Context, *ListQueuedOperationsRequest) (*ListQueuedOperationsResponse, error)
	ListWorkers(context.Context, *ListWorkersRequest) (*ListWorkersResponse, error)
	TerminateWorkers(context.Context, *TerminateWorkersRequest) (*emptypb.Empty, error)
	ListDrains(context.Context, *ListDrainsRequest) (*ListDrainsResponse, error)
	AddDrain(context.Context, *AddOrRemoveDrainRequest) (*emptypb.Empty, error)
	RemoveDrain(context.Context, *AddOrRemoveDrainRequest) (*emptypb.Empty, error)
}

BuildQueueStateServer is the server API for BuildQueueState service. All implementations should embed UnimplementedBuildQueueStateServer for forward compatibility

type DrainState 

type DrainState struct {
	WorkerIdPattern  map[string]string      `` /* 196-byte string literal not displayed */
	CreatedTimestamp *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=created_timestamp,json=createdTimestamp,proto3" json:"created_timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*DrainState) Descriptor deprecated 

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

Deprecated: Use DrainState.ProtoReflect.Descriptor instead.

func (*DrainState) GetCreatedTimestamp 

func (x *DrainState) GetCreatedTimestamp() *timestamppb.Timestamp

func (*DrainState) GetWorkerIdPattern 

func (x *DrainState) GetWorkerIdPattern() map[string]string

func (*DrainState) ProtoMessage 

func (*DrainState) ProtoMessage()

func (*DrainState) ProtoReflect 

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

func (*DrainState) Reset 

func (x *DrainState) Reset()

func (*DrainState) String 

func (x *DrainState) String() string

type GetOperationRequest 

type GetOperationRequest struct {
	OperationName string `protobuf:"bytes,1,opt,name=operation_name,json=operationName,proto3" json:"operation_name,omitempty"`
	// contains filtered or unexported fields
}

func (*GetOperationRequest) Descriptor deprecated 

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

Deprecated: Use GetOperationRequest.ProtoReflect.Descriptor instead.

func (*GetOperationRequest) GetOperationName 

func (x *GetOperationRequest) GetOperationName() string

func (*GetOperationRequest) ProtoMessage 

func (*GetOperationRequest) ProtoMessage()

func (*GetOperationRequest) ProtoReflect 

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

func (*GetOperationRequest) Reset 

func (x *GetOperationRequest) Reset()

func (*GetOperationRequest) String 

func (x *GetOperationRequest) String() string

type GetOperationResponse 

type GetOperationResponse struct {
	Operation *OperationState `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"`
	// contains filtered or unexported fields
}

func (*GetOperationResponse) Descriptor deprecated 

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

Deprecated: Use GetOperationResponse.ProtoReflect.Descriptor instead.

func (*GetOperationResponse) GetOperation 

func (x *GetOperationResponse) GetOperation() *OperationState

func (*GetOperationResponse) ProtoMessage 

func (*GetOperationResponse) ProtoMessage()

func (*GetOperationResponse) ProtoReflect 

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

func (*GetOperationResponse) Reset 

func (x *GetOperationResponse) Reset()

func (*GetOperationResponse) String 

func (x *GetOperationResponse) String() string

type InvocationChildState 

type InvocationChildState struct {
	Id    *anypb.Any       `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	State *InvocationState `protobuf:"bytes,2,opt,name=state,proto3" json:"state,omitempty"`
	// contains filtered or unexported fields
}

func (*InvocationChildState) Descriptor deprecated 

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

Deprecated: Use InvocationChildState.ProtoReflect.Descriptor instead.

func (*InvocationChildState) GetId 

func (x *InvocationChildState) GetId() *anypb.Any

func (*InvocationChildState) GetState 

func (x *InvocationChildState) GetState() *InvocationState

func (*InvocationChildState) ProtoMessage 

func (*InvocationChildState) ProtoMessage()

func (*InvocationChildState) ProtoReflect 

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

func (*InvocationChildState) Reset 

func (x *InvocationChildState) Reset()

func (*InvocationChildState) String 

func (x *InvocationChildState) String() string

type InvocationName 

type InvocationName struct {
	SizeClassQueueName *SizeClassQueueName `protobuf:"bytes,1,opt,name=size_class_queue_name,json=sizeClassQueueName,proto3" json:"size_class_queue_name,omitempty"`
	Ids                []*anypb.Any        `protobuf:"bytes,2,rep,name=ids,proto3" json:"ids,omitempty"`
	// contains filtered or unexported fields
}

func (*InvocationName) Descriptor deprecated 

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

Deprecated: Use InvocationName.ProtoReflect.Descriptor instead.

func (*InvocationName) GetIds 

func (x *InvocationName) GetIds() []*anypb.Any

func (*InvocationName) GetSizeClassQueueName 

func (x *InvocationName) GetSizeClassQueueName() *SizeClassQueueName

func (*InvocationName) ProtoMessage 

func (*InvocationName) ProtoMessage()

func (*InvocationName) ProtoReflect 

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

func (*InvocationName) Reset 

func (x *InvocationName) Reset()

func (*InvocationName) String 

func (x *InvocationName) String() string

type InvocationState 

type InvocationState struct {
	QueuedOperationsCount         uint32 `` /* 127-byte string literal not displayed */
	ExecutingWorkersCount         uint32 `` /* 127-byte string literal not displayed */
	IdleWorkersCount              uint32 `protobuf:"varint,5,opt,name=idle_workers_count,json=idleWorkersCount,proto3" json:"idle_workers_count,omitempty"`
	IdleSynchronizingWorkersCount uint32 `` /* 153-byte string literal not displayed */
	ChildrenCount                 uint32 `protobuf:"varint,7,opt,name=children_count,json=childrenCount,proto3" json:"children_count,omitempty"`
	ActiveChildrenCount           uint32 `protobuf:"varint,8,opt,name=active_children_count,json=activeChildrenCount,proto3" json:"active_children_count,omitempty"`
	QueuedChildrenCount           uint32 `protobuf:"varint,9,opt,name=queued_children_count,json=queuedChildrenCount,proto3" json:"queued_children_count,omitempty"`
	// contains filtered or unexported fields
}

func (*InvocationState) Descriptor deprecated 

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

Deprecated: Use InvocationState.ProtoReflect.Descriptor instead.

func (*InvocationState) GetActiveChildrenCount 

func (x *InvocationState) GetActiveChildrenCount() uint32

func (*InvocationState) GetChildrenCount 

func (x *InvocationState) GetChildrenCount() uint32

func (*InvocationState) GetExecutingWorkersCount 

func (x *InvocationState) GetExecutingWorkersCount() uint32

func (*InvocationState) GetIdleSynchronizingWorkersCount 

func (x *InvocationState) GetIdleSynchronizingWorkersCount() uint32

func (*InvocationState) GetIdleWorkersCount 

func (x *InvocationState) GetIdleWorkersCount() uint32

func (*InvocationState) GetQueuedChildrenCount 

func (x *InvocationState) GetQueuedChildrenCount() uint32

func (*InvocationState) GetQueuedOperationsCount 

func (x *InvocationState) GetQueuedOperationsCount() uint32

func (*InvocationState) ProtoMessage 

func (*InvocationState) ProtoMessage()

func (*InvocationState) ProtoReflect 

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

func (*InvocationState) Reset 

func (x *InvocationState) Reset()

func (*InvocationState) String 

func (x *InvocationState) String() string

type KillOperationsRequest 

type KillOperationsRequest struct {
	Filter *KillOperationsRequest_Filter `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"`
	Status *status.Status                `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*KillOperationsRequest) Descriptor deprecated 

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

Deprecated: Use KillOperationsRequest.ProtoReflect.Descriptor instead.

func (*KillOperationsRequest) GetFilter 

func (x *KillOperationsRequest) GetFilter() *KillOperationsRequest_Filter

func (*KillOperationsRequest) GetStatus 

func (x *KillOperationsRequest) GetStatus() *status.Status

func (*KillOperationsRequest) ProtoMessage 

func (*KillOperationsRequest) ProtoMessage()

func (*KillOperationsRequest) ProtoReflect 

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

func (*KillOperationsRequest) Reset 

func (x *KillOperationsRequest) Reset()

func (*KillOperationsRequest) String 

func (x *KillOperationsRequest) String() string

type KillOperationsRequest_Filter 

type KillOperationsRequest_Filter struct {

	// Types that are assignable to Type:
	//
	//	*KillOperationsRequest_Filter_OperationName
	//	*KillOperationsRequest_Filter_SizeClassQueueWithoutWorkers
	Type isKillOperationsRequest_Filter_Type `protobuf_oneof:"type"`
	// contains filtered or unexported fields
}

func (*KillOperationsRequest_Filter) Descriptor deprecated 

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

Deprecated: Use KillOperationsRequest_Filter.ProtoReflect.Descriptor instead.

func (*KillOperationsRequest_Filter) GetOperationName 

func (x *KillOperationsRequest_Filter) GetOperationName() string

func (*KillOperationsRequest_Filter) GetSizeClassQueueWithoutWorkers 

func (x *KillOperationsRequest_Filter) GetSizeClassQueueWithoutWorkers() *SizeClassQueueName

func (*KillOperationsRequest_Filter) GetType 

func (m *KillOperationsRequest_Filter) GetType() isKillOperationsRequest_Filter_Type

func (*KillOperationsRequest_Filter) ProtoMessage 

func (*KillOperationsRequest_Filter) ProtoMessage()

func (*KillOperationsRequest_Filter) ProtoReflect 

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

func (*KillOperationsRequest_Filter) Reset 

func (x *KillOperationsRequest_Filter) Reset()

func (*KillOperationsRequest_Filter) String 

func (x *KillOperationsRequest_Filter) String() string

type KillOperationsRequest_Filter_OperationName 

type KillOperationsRequest_Filter_OperationName struct {
	OperationName string `protobuf:"bytes,1,opt,name=operation_name,json=operationName,proto3,oneof"`
}

type KillOperationsRequest_Filter_SizeClassQueueWithoutWorkers 

type KillOperationsRequest_Filter_SizeClassQueueWithoutWorkers struct {
	SizeClassQueueWithoutWorkers *SizeClassQueueName `protobuf:"bytes,2,opt,name=size_class_queue_without_workers,json=sizeClassQueueWithoutWorkers,proto3,oneof"`
}

type ListDrainsRequest 

type ListDrainsRequest struct {
	SizeClassQueueName *SizeClassQueueName `protobuf:"bytes,1,opt,name=size_class_queue_name,json=sizeClassQueueName,proto3" json:"size_class_queue_name,omitempty"`
	// contains filtered or unexported fields
}

func (*ListDrainsRequest) Descriptor deprecated 

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

Deprecated: Use ListDrainsRequest.ProtoReflect.Descriptor instead.

func (*ListDrainsRequest) GetSizeClassQueueName 

func (x *ListDrainsRequest) GetSizeClassQueueName() *SizeClassQueueName

func (*ListDrainsRequest) ProtoMessage 

func (*ListDrainsRequest) ProtoMessage()

func (*ListDrainsRequest) ProtoReflect 

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

func (*ListDrainsRequest) Reset 

func (x *ListDrainsRequest) Reset()

func (*ListDrainsRequest) String 

func (x *ListDrainsRequest) String() string

type ListDrainsResponse 

type ListDrainsResponse struct {
	Drains []*DrainState `protobuf:"bytes,1,rep,name=drains,proto3" json:"drains,omitempty"`
	// contains filtered or unexported fields
}

func (*ListDrainsResponse) Descriptor deprecated 

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

Deprecated: Use ListDrainsResponse.ProtoReflect.Descriptor instead.

func (*ListDrainsResponse) GetDrains 

func (x *ListDrainsResponse) GetDrains() []*DrainState

func (*ListDrainsResponse) ProtoMessage 

func (*ListDrainsResponse) ProtoMessage()

func (*ListDrainsResponse) ProtoReflect 

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

func (*ListDrainsResponse) Reset 

func (x *ListDrainsResponse) Reset()

func (*ListDrainsResponse) String 

func (x *ListDrainsResponse) String() string

type ListInvocationChildrenRequest 

type ListInvocationChildrenRequest struct {
	InvocationName *InvocationName                      `protobuf:"bytes,1,opt,name=invocation_name,json=invocationName,proto3" json:"invocation_name,omitempty"`
	Filter         ListInvocationChildrenRequest_Filter `` /* 134-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ListInvocationChildrenRequest) Descriptor deprecated 

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

Deprecated: Use ListInvocationChildrenRequest.ProtoReflect.Descriptor instead.

func (*ListInvocationChildrenRequest) GetFilter 

func (x *ListInvocationChildrenRequest) GetFilter() ListInvocationChildrenRequest_Filter

func (*ListInvocationChildrenRequest) GetInvocationName 

func (x *ListInvocationChildrenRequest) GetInvocationName() *InvocationName

func (*ListInvocationChildrenRequest) ProtoMessage 

func (*ListInvocationChildrenRequest) ProtoMessage()

func (*ListInvocationChildrenRequest) ProtoReflect 

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

func (*ListInvocationChildrenRequest) Reset 

func (x *ListInvocationChildrenRequest) Reset()

func (*ListInvocationChildrenRequest) String 

func (x *ListInvocationChildrenRequest) String() string

type ListInvocationChildrenRequest_Filter 

type ListInvocationChildrenRequest_Filter int32
const (
	ListInvocationChildrenRequest_ALL    ListInvocationChildrenRequest_Filter = 0
	ListInvocationChildrenRequest_ACTIVE ListInvocationChildrenRequest_Filter = 1
	ListInvocationChildrenRequest_QUEUED ListInvocationChildrenRequest_Filter = 2
)

func (ListInvocationChildrenRequest_Filter) Descriptor 

func (ListInvocationChildrenRequest_Filter) Descriptor() protoreflect.EnumDescriptor

func (ListInvocationChildrenRequest_Filter) Enum 

func (x ListInvocationChildrenRequest_Filter) Enum() *ListInvocationChildrenRequest_Filter

func (ListInvocationChildrenRequest_Filter) EnumDescriptor deprecated 

func (ListInvocationChildrenRequest_Filter) EnumDescriptor() ([]byte, []int)

Deprecated: Use ListInvocationChildrenRequest_Filter.Descriptor instead.

func (ListInvocationChildrenRequest_Filter) Number 

func (x ListInvocationChildrenRequest_Filter) Number() protoreflect.EnumNumber

func (ListInvocationChildrenRequest_Filter) String 

func (x ListInvocationChildrenRequest_Filter) String() string

func (ListInvocationChildrenRequest_Filter) Type 

func (ListInvocationChildrenRequest_Filter) Type() protoreflect.EnumType

type ListInvocationChildrenResponse 

type ListInvocationChildrenResponse struct {
	Children []*InvocationChildState `protobuf:"bytes,1,rep,name=children,proto3" json:"children,omitempty"`
	// contains filtered or unexported fields
}

func (*ListInvocationChildrenResponse) Descriptor deprecated 

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

Deprecated: Use ListInvocationChildrenResponse.ProtoReflect.Descriptor instead.

func (*ListInvocationChildrenResponse) GetChildren 

func (x *ListInvocationChildrenResponse) GetChildren() []*InvocationChildState

func (*ListInvocationChildrenResponse) ProtoMessage 

func (*ListInvocationChildrenResponse) ProtoMessage()

func (*ListInvocationChildrenResponse) ProtoReflect 

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

func (*ListInvocationChildrenResponse) Reset 

func (x *ListInvocationChildrenResponse) Reset()

func (*ListInvocationChildrenResponse) String 

func (x *ListInvocationChildrenResponse) String() string

type ListOperationsRequest 

type ListOperationsRequest struct {
	PageSize           uint32                            `protobuf:"varint,1,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	StartAfter         *ListOperationsRequest_StartAfter `protobuf:"bytes,2,opt,name=start_after,json=startAfter,proto3" json:"start_after,omitempty"`
	FilterInvocationId *anypb.Any                        `protobuf:"bytes,3,opt,name=filter_invocation_id,json=filterInvocationId,proto3" json:"filter_invocation_id,omitempty"`
	FilterStage        v2.ExecutionStage_Value           `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ListOperationsRequest) Descriptor deprecated 

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

Deprecated: Use ListOperationsRequest.ProtoReflect.Descriptor instead.

func (*ListOperationsRequest) GetFilterInvocationId 

func (x *ListOperationsRequest) GetFilterInvocationId() *anypb.Any

func (*ListOperationsRequest) GetFilterStage 

func (x *ListOperationsRequest) GetFilterStage() v2.ExecutionStage_Value

func (*ListOperationsRequest) GetPageSize 

func (x *ListOperationsRequest) GetPageSize() uint32

func (*ListOperationsRequest) GetStartAfter 

func (x *ListOperationsRequest) GetStartAfter() *ListOperationsRequest_StartAfter

func (*ListOperationsRequest) ProtoMessage 

func (*ListOperationsRequest) ProtoMessage()

func (*ListOperationsRequest) ProtoReflect 

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

func (*ListOperationsRequest) Reset 

func (x *ListOperationsRequest) Reset()

func (*ListOperationsRequest) String 

func (x *ListOperationsRequest) String() string

type ListOperationsRequest_StartAfter 

type ListOperationsRequest_StartAfter struct {
	OperationName string `protobuf:"bytes,1,opt,name=operation_name,json=operationName,proto3" json:"operation_name,omitempty"`
	// contains filtered or unexported fields
}

func (*ListOperationsRequest_StartAfter) Descriptor deprecated 

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

Deprecated: Use ListOperationsRequest_StartAfter.ProtoReflect.Descriptor instead.

func (*ListOperationsRequest_StartAfter) GetOperationName 

func (x *ListOperationsRequest_StartAfter) GetOperationName() string

func (*ListOperationsRequest_StartAfter) ProtoMessage 

func (*ListOperationsRequest_StartAfter) ProtoMessage()

func (*ListOperationsRequest_StartAfter) ProtoReflect 

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

func (*ListOperationsRequest_StartAfter) Reset 

func (x *ListOperationsRequest_StartAfter) Reset()

func (*ListOperationsRequest_StartAfter) String 

func (x *ListOperationsRequest_StartAfter) String() string

type ListOperationsResponse 

type ListOperationsResponse struct {
	Operations     []*OperationState `protobuf:"bytes,1,rep,name=operations,proto3" json:"operations,omitempty"`
	PaginationInfo *PaginationInfo   `protobuf:"bytes,2,opt,name=pagination_info,json=paginationInfo,proto3" json:"pagination_info,omitempty"`
	// contains filtered or unexported fields
}

func (*ListOperationsResponse) Descriptor deprecated 

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

Deprecated: Use ListOperationsResponse.ProtoReflect.Descriptor instead.

func (*ListOperationsResponse) GetOperations 

func (x *ListOperationsResponse) GetOperations() []*OperationState

func (*ListOperationsResponse) GetPaginationInfo 

func (x *ListOperationsResponse) GetPaginationInfo() *PaginationInfo

func (*ListOperationsResponse) ProtoMessage 

func (*ListOperationsResponse) ProtoMessage()

func (*ListOperationsResponse) ProtoReflect 

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

func (*ListOperationsResponse) Reset 

func (x *ListOperationsResponse) Reset()

func (*ListOperationsResponse) String 

func (x *ListOperationsResponse) String() string

type ListPlatformQueuesResponse 

type ListPlatformQueuesResponse struct {
	PlatformQueues []*PlatformQueueState `protobuf:"bytes,1,rep,name=platform_queues,json=platformQueues,proto3" json:"platform_queues,omitempty"`
	// contains filtered or unexported fields
}

func (*ListPlatformQueuesResponse) Descriptor deprecated 

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

Deprecated: Use ListPlatformQueuesResponse.ProtoReflect.Descriptor instead.

func (*ListPlatformQueuesResponse) GetPlatformQueues 

func (x *ListPlatformQueuesResponse) GetPlatformQueues() []*PlatformQueueState

func (*ListPlatformQueuesResponse) ProtoMessage 

func (*ListPlatformQueuesResponse) ProtoMessage()

func (*ListPlatformQueuesResponse) ProtoReflect 

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

func (*ListPlatformQueuesResponse) Reset 

func (x *ListPlatformQueuesResponse) Reset()

func (*ListPlatformQueuesResponse) String 

func (x *ListPlatformQueuesResponse) String() string

type ListQueuedOperationsRequest 

type ListQueuedOperationsRequest struct {
	InvocationName *InvocationName                         `protobuf:"bytes,1,opt,name=invocation_name,json=invocationName,proto3" json:"invocation_name,omitempty"`
	PageSize       uint32                                  `protobuf:"varint,3,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	StartAfter     *ListQueuedOperationsRequest_StartAfter `protobuf:"bytes,4,opt,name=start_after,json=startAfter,proto3" json:"start_after,omitempty"`
	// contains filtered or unexported fields
}

func (*ListQueuedOperationsRequest) Descriptor deprecated 

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

Deprecated: Use ListQueuedOperationsRequest.ProtoReflect.Descriptor instead.

func (*ListQueuedOperationsRequest) GetInvocationName 

func (x *ListQueuedOperationsRequest) GetInvocationName() *InvocationName

func (*ListQueuedOperationsRequest) GetPageSize 

func (x *ListQueuedOperationsRequest) GetPageSize() uint32

func (*ListQueuedOperationsRequest) GetStartAfter 

func (x *ListQueuedOperationsRequest) GetStartAfter() *ListQueuedOperationsRequest_StartAfter

func (*ListQueuedOperationsRequest) ProtoMessage 

func (*ListQueuedOperationsRequest) ProtoMessage()

func (*ListQueuedOperationsRequest) ProtoReflect 

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

func (*ListQueuedOperationsRequest) Reset 

func (x *ListQueuedOperationsRequest) Reset()

func (*ListQueuedOperationsRequest) String 

func (x *ListQueuedOperationsRequest) String() string

type ListQueuedOperationsRequest_StartAfter 

type ListQueuedOperationsRequest_StartAfter struct {
	Priority         int32                  `protobuf:"varint,1,opt,name=priority,proto3" json:"priority,omitempty"`
	ExpectedDuration *durationpb.Duration   `protobuf:"bytes,3,opt,name=expected_duration,json=expectedDuration,proto3" json:"expected_duration,omitempty"`
	QueuedTimestamp  *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=queued_timestamp,json=queuedTimestamp,proto3" json:"queued_timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*ListQueuedOperationsRequest_StartAfter) Descriptor deprecated 

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

Deprecated: Use ListQueuedOperationsRequest_StartAfter.ProtoReflect.Descriptor instead.

func (*ListQueuedOperationsRequest_StartAfter) GetExpectedDuration 

func (x *ListQueuedOperationsRequest_StartAfter) GetExpectedDuration() *durationpb.Duration

func (*ListQueuedOperationsRequest_StartAfter) GetPriority 

func (x *ListQueuedOperationsRequest_StartAfter) GetPriority() int32

func (*ListQueuedOperationsRequest_StartAfter) GetQueuedTimestamp 

func (x *ListQueuedOperationsRequest_StartAfter) GetQueuedTimestamp() *timestamppb.Timestamp

func (*ListQueuedOperationsRequest_StartAfter) ProtoMessage 

func (*ListQueuedOperationsRequest_StartAfter) ProtoMessage()

func (*ListQueuedOperationsRequest_StartAfter) ProtoReflect 

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

func (*ListQueuedOperationsRequest_StartAfter) Reset 

func (x *ListQueuedOperationsRequest_StartAfter) Reset()

func (*ListQueuedOperationsRequest_StartAfter) String 

func (x *ListQueuedOperationsRequest_StartAfter) String() string

type ListQueuedOperationsResponse 

type ListQueuedOperationsResponse struct {
	QueuedOperations []*OperationState `protobuf:"bytes,1,rep,name=queued_operations,json=queuedOperations,proto3" json:"queued_operations,omitempty"`
	PaginationInfo   *PaginationInfo   `protobuf:"bytes,2,opt,name=pagination_info,json=paginationInfo,proto3" json:"pagination_info,omitempty"`
	// contains filtered or unexported fields
}

func (*ListQueuedOperationsResponse) Descriptor deprecated 

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

Deprecated: Use ListQueuedOperationsResponse.ProtoReflect.Descriptor instead.

func (*ListQueuedOperationsResponse) GetPaginationInfo 

func (x *ListQueuedOperationsResponse) GetPaginationInfo() *PaginationInfo

func (*ListQueuedOperationsResponse) GetQueuedOperations 

func (x *ListQueuedOperationsResponse) GetQueuedOperations() []*OperationState

func (*ListQueuedOperationsResponse) ProtoMessage 

func (*ListQueuedOperationsResponse) ProtoMessage()

func (*ListQueuedOperationsResponse) ProtoReflect 

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

func (*ListQueuedOperationsResponse) Reset 

func (x *ListQueuedOperationsResponse) Reset()

func (*ListQueuedOperationsResponse) String 

func (x *ListQueuedOperationsResponse) String() string

type ListWorkersRequest 

type ListWorkersRequest struct {
	Filter     *ListWorkersRequest_Filter     `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"`
	PageSize   uint32                         `protobuf:"varint,3,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	StartAfter *ListWorkersRequest_StartAfter `protobuf:"bytes,4,opt,name=start_after,json=startAfter,proto3" json:"start_after,omitempty"`
	// contains filtered or unexported fields
}

func (*ListWorkersRequest) Descriptor deprecated 

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

Deprecated: Use ListWorkersRequest.ProtoReflect.Descriptor instead.

func (*ListWorkersRequest) GetFilter 

func (x *ListWorkersRequest) GetFilter() *ListWorkersRequest_Filter

func (*ListWorkersRequest) GetPageSize 

func (x *ListWorkersRequest) GetPageSize() uint32

func (*ListWorkersRequest) GetStartAfter 

func (x *ListWorkersRequest) GetStartAfter() *ListWorkersRequest_StartAfter

func (*ListWorkersRequest) ProtoMessage 

func (*ListWorkersRequest) ProtoMessage()

func (*ListWorkersRequest) ProtoReflect 

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

func (*ListWorkersRequest) Reset 

func (x *ListWorkersRequest) Reset()

func (*ListWorkersRequest) String 

func (x *ListWorkersRequest) String() string

type ListWorkersRequest_Filter 

type ListWorkersRequest_Filter struct {

	// Types that are assignable to Type:
	//
	//	*ListWorkersRequest_Filter_All
	//	*ListWorkersRequest_Filter_Executing
	//	*ListWorkersRequest_Filter_IdleSynchronizing
	Type isListWorkersRequest_Filter_Type `protobuf_oneof:"type"`
	// contains filtered or unexported fields
}

func (*ListWorkersRequest_Filter) Descriptor deprecated 

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

Deprecated: Use ListWorkersRequest_Filter.ProtoReflect.Descriptor instead.

func (*ListWorkersRequest_Filter) GetAll 

func (x *ListWorkersRequest_Filter) GetAll() *SizeClassQueueName

func (*ListWorkersRequest_Filter) GetExecuting 

func (x *ListWorkersRequest_Filter) GetExecuting() *InvocationName

func (*ListWorkersRequest_Filter) GetIdleSynchronizing 

func (x *ListWorkersRequest_Filter) GetIdleSynchronizing() *InvocationName

func (*ListWorkersRequest_Filter) GetType 

func (m *ListWorkersRequest_Filter) GetType() isListWorkersRequest_Filter_Type

func (*ListWorkersRequest_Filter) ProtoMessage 

func (*ListWorkersRequest_Filter) ProtoMessage()

func (*ListWorkersRequest_Filter) ProtoReflect 

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

func (*ListWorkersRequest_Filter) Reset 

func (x *ListWorkersRequest_Filter) Reset()

func (*ListWorkersRequest_Filter) String 

func (x *ListWorkersRequest_Filter) String() string

type ListWorkersRequest_Filter_All 

type ListWorkersRequest_Filter_All struct {
	All *SizeClassQueueName `protobuf:"bytes,1,opt,name=all,proto3,oneof"`
}

type ListWorkersRequest_Filter_Executing 

type ListWorkersRequest_Filter_Executing struct {
	Executing *InvocationName `protobuf:"bytes,2,opt,name=executing,proto3,oneof"`
}

type ListWorkersRequest_Filter_IdleSynchronizing 

type ListWorkersRequest_Filter_IdleSynchronizing struct {
	IdleSynchronizing *InvocationName `protobuf:"bytes,3,opt,name=idle_synchronizing,json=idleSynchronizing,proto3,oneof"`
}

type ListWorkersRequest_StartAfter 

type ListWorkersRequest_StartAfter struct {
	WorkerId map[string]string `` /* 173-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ListWorkersRequest_StartAfter) Descriptor deprecated 

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

Deprecated: Use ListWorkersRequest_StartAfter.ProtoReflect.Descriptor instead.

func (*ListWorkersRequest_StartAfter) GetWorkerId 

func (x *ListWorkersRequest_StartAfter) GetWorkerId() map[string]string

func (*ListWorkersRequest_StartAfter) ProtoMessage 

func (*ListWorkersRequest_StartAfter) ProtoMessage()

func (*ListWorkersRequest_StartAfter) ProtoReflect 

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

func (*ListWorkersRequest_StartAfter) Reset 

func (x *ListWorkersRequest_StartAfter) Reset()

func (*ListWorkersRequest_StartAfter) String 

func (x *ListWorkersRequest_StartAfter) String() string

type ListWorkersResponse 

type ListWorkersResponse struct {
	Workers        []*WorkerState  `protobuf:"bytes,1,rep,name=workers,proto3" json:"workers,omitempty"`
	PaginationInfo *PaginationInfo `protobuf:"bytes,2,opt,name=pagination_info,json=paginationInfo,proto3" json:"pagination_info,omitempty"`
	// contains filtered or unexported fields
}

func (*ListWorkersResponse) Descriptor deprecated 

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

Deprecated: Use ListWorkersResponse.ProtoReflect.Descriptor instead.

func (*ListWorkersResponse) GetPaginationInfo 

func (x *ListWorkersResponse) GetPaginationInfo() *PaginationInfo

func (*ListWorkersResponse) GetWorkers 

func (x *ListWorkersResponse) GetWorkers() []*WorkerState

func (*ListWorkersResponse) ProtoMessage 

func (*ListWorkersResponse) ProtoMessage()

func (*ListWorkersResponse) ProtoReflect 

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

func (*ListWorkersResponse) Reset 

func (x *ListWorkersResponse) Reset()

func (*ListWorkersResponse) String 

func (x *ListWorkersResponse) String() string

type OperationState 

type OperationState struct {
	Name             string                 `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	InvocationName   *InvocationName        `protobuf:"bytes,2,opt,name=invocation_name,json=invocationName,proto3" json:"invocation_name,omitempty"`
	ExpectedDuration *durationpb.Duration   `protobuf:"bytes,14,opt,name=expected_duration,json=expectedDuration,proto3" json:"expected_duration,omitempty"`
	QueuedTimestamp  *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=queued_timestamp,json=queuedTimestamp,proto3" json:"queued_timestamp,omitempty"`
	ActionDigest     *v2.Digest             `protobuf:"bytes,5,opt,name=action_digest,json=actionDigest,proto3" json:"action_digest,omitempty"`
	Timeout          *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=timeout,proto3" json:"timeout,omitempty"`
	// Types that are assignable to Stage:
	//
	//	*OperationState_Queued
	//	*OperationState_Executing
	//	*OperationState_Completed
	Stage              isOperationState_Stage  `protobuf_oneof:"stage"`
	TargetId           string                  `protobuf:"bytes,11,opt,name=target_id,json=targetId,proto3" json:"target_id,omitempty"`
	Priority           int32                   `protobuf:"varint,12,opt,name=priority,proto3" json:"priority,omitempty"`
	InstanceNameSuffix string                  `protobuf:"bytes,13,opt,name=instance_name_suffix,json=instanceNameSuffix,proto3" json:"instance_name_suffix,omitempty"`
	DigestFunction     v2.DigestFunction_Value `` /* 163-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*OperationState) Descriptor deprecated 

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

Deprecated: Use OperationState.ProtoReflect.Descriptor instead.

func (*OperationState) GetActionDigest 

func (x *OperationState) GetActionDigest() *v2.Digest

func (*OperationState) GetCompleted 

func (x *OperationState) GetCompleted() *v2.ExecuteResponse

func (*OperationState) GetDigestFunction 

func (x *OperationState) GetDigestFunction() v2.DigestFunction_Value

func (*OperationState) GetExecuting 

func (x *OperationState) GetExecuting() *emptypb.Empty

func (*OperationState) GetExpectedDuration 

func (x *OperationState) GetExpectedDuration() *durationpb.Duration

func (*OperationState) GetInstanceNameSuffix 

func (x *OperationState) GetInstanceNameSuffix() string

func (*OperationState) GetInvocationName 

func (x *OperationState) GetInvocationName() *InvocationName

func (*OperationState) GetName 

func (x *OperationState) GetName() string

func (*OperationState) GetPriority 

func (x *OperationState) GetPriority() int32

func (*OperationState) GetQueued 

func (x *OperationState) GetQueued() *emptypb.Empty

func (*OperationState) GetQueuedTimestamp 

func (x *OperationState) GetQueuedTimestamp() *timestamppb.Timestamp

func (*OperationState) GetStage 

func (m *OperationState) GetStage() isOperationState_Stage

func (*OperationState) GetTargetId 

func (x *OperationState) GetTargetId() string

func (*OperationState) GetTimeout 

func (x *OperationState) GetTimeout() *timestamppb.Timestamp

func (*OperationState) ProtoMessage 

func (*OperationState) ProtoMessage()

func (*OperationState) ProtoReflect 

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

func (*OperationState) Reset 

func (x *OperationState) Reset()

func (*OperationState) String 

func (x *OperationState) String() string

type OperationState_Completed 

type OperationState_Completed struct {
	Completed *v2.ExecuteResponse `protobuf:"bytes,10,opt,name=completed,proto3,oneof"`
}

type OperationState_Executing 

type OperationState_Executing struct {
	Executing *emptypb.Empty `protobuf:"bytes,9,opt,name=executing,proto3,oneof"`
}

type OperationState_Queued 

type OperationState_Queued struct {
	Queued *emptypb.Empty `protobuf:"bytes,8,opt,name=queued,proto3,oneof"`
}

type PaginationInfo 

type PaginationInfo struct {
	StartIndex   uint32 `protobuf:"varint,1,opt,name=start_index,json=startIndex,proto3" json:"start_index,omitempty"`
	TotalEntries uint32 `protobuf:"varint,2,opt,name=total_entries,json=totalEntries,proto3" json:"total_entries,omitempty"`
	// contains filtered or unexported fields
}

func (*PaginationInfo) Descriptor deprecated 

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

Deprecated: Use PaginationInfo.ProtoReflect.Descriptor instead.

func (*PaginationInfo) GetStartIndex 

func (x *PaginationInfo) GetStartIndex() uint32

func (*PaginationInfo) GetTotalEntries 

func (x *PaginationInfo) GetTotalEntries() uint32

func (*PaginationInfo) ProtoMessage 

func (*PaginationInfo) ProtoMessage()

func (*PaginationInfo) ProtoReflect 

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

func (*PaginationInfo) Reset 

func (x *PaginationInfo) Reset()

func (*PaginationInfo) String 

func (x *PaginationInfo) String() string

type PlatformQueueName 

type PlatformQueueName struct {
	InstanceNamePrefix string       `protobuf:"bytes,1,opt,name=instance_name_prefix,json=instanceNamePrefix,proto3" json:"instance_name_prefix,omitempty"`
	Platform           *v2.Platform `protobuf:"bytes,2,opt,name=platform,proto3" json:"platform,omitempty"`
	// contains filtered or unexported fields
}

func (*PlatformQueueName) Descriptor deprecated 

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

Deprecated: Use PlatformQueueName.ProtoReflect.Descriptor instead.

func (*PlatformQueueName) GetInstanceNamePrefix 

func (x *PlatformQueueName) GetInstanceNamePrefix() string

func (*PlatformQueueName) GetPlatform 

func (x *PlatformQueueName) GetPlatform() *v2.Platform

func (*PlatformQueueName) ProtoMessage 

func (*PlatformQueueName) ProtoMessage()

func (*PlatformQueueName) ProtoReflect 

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

func (*PlatformQueueName) Reset 

func (x *PlatformQueueName) Reset()

func (*PlatformQueueName) String 

func (x *PlatformQueueName) String() string

type PlatformQueueState 

type PlatformQueueState struct {
	Name            *PlatformQueueName     `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	SizeClassQueues []*SizeClassQueueState `protobuf:"bytes,2,rep,name=size_class_queues,json=sizeClassQueues,proto3" json:"size_class_queues,omitempty"`
	// contains filtered or unexported fields
}

func (*PlatformQueueState) Descriptor deprecated 

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

Deprecated: Use PlatformQueueState.ProtoReflect.Descriptor instead.

func (*PlatformQueueState) GetName 

func (x *PlatformQueueState) GetName() *PlatformQueueName

func (*PlatformQueueState) GetSizeClassQueues 

func (x *PlatformQueueState) GetSizeClassQueues() []*SizeClassQueueState

func (*PlatformQueueState) ProtoMessage 

func (*PlatformQueueState) ProtoMessage()

func (*PlatformQueueState) ProtoReflect 

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

func (*PlatformQueueState) Reset 

func (x *PlatformQueueState) Reset()

func (*PlatformQueueState) String 

func (x *PlatformQueueState) String() string

type SizeClassQueueName 

type SizeClassQueueName struct {
	PlatformQueueName *PlatformQueueName `protobuf:"bytes,1,opt,name=platform_queue_name,json=platformQueueName,proto3" json:"platform_queue_name,omitempty"`
	SizeClass         uint32             `protobuf:"varint,2,opt,name=size_class,json=sizeClass,proto3" json:"size_class,omitempty"`
	// contains filtered or unexported fields
}

func (*SizeClassQueueName) Descriptor deprecated 

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

Deprecated: Use SizeClassQueueName.ProtoReflect.Descriptor instead.

func (*SizeClassQueueName) GetPlatformQueueName 

func (x *SizeClassQueueName) GetPlatformQueueName() *PlatformQueueName

func (*SizeClassQueueName) GetSizeClass 

func (x *SizeClassQueueName) GetSizeClass() uint32

func (*SizeClassQueueName) ProtoMessage 

func (*SizeClassQueueName) ProtoMessage()

func (*SizeClassQueueName) ProtoReflect 

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

func (*SizeClassQueueName) Reset 

func (x *SizeClassQueueName) Reset()

func (*SizeClassQueueName) String 

func (x *SizeClassQueueName) String() string

type SizeClassQueueState 

type SizeClassQueueState struct {
	SizeClass      uint32                 `protobuf:"varint,1,opt,name=size_class,json=sizeClass,proto3" json:"size_class,omitempty"`
	Timeout        *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=timeout,proto3" json:"timeout,omitempty"`
	WorkersCount   uint32                 `protobuf:"varint,5,opt,name=workers_count,json=workersCount,proto3" json:"workers_count,omitempty"`
	DrainsCount    uint32                 `protobuf:"varint,7,opt,name=drains_count,json=drainsCount,proto3" json:"drains_count,omitempty"`
	RootInvocation *InvocationState       `protobuf:"bytes,9,opt,name=root_invocation,json=rootInvocation,proto3" json:"root_invocation,omitempty"`
	// contains filtered or unexported fields
}

func (*SizeClassQueueState) Descriptor deprecated 

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

Deprecated: Use SizeClassQueueState.ProtoReflect.Descriptor instead.

func (*SizeClassQueueState) GetDrainsCount 

func (x *SizeClassQueueState) GetDrainsCount() uint32

func (*SizeClassQueueState) GetRootInvocation 

func (x *SizeClassQueueState) GetRootInvocation() *InvocationState

func (*SizeClassQueueState) GetSizeClass 

func (x *SizeClassQueueState) GetSizeClass() uint32

func (*SizeClassQueueState) GetTimeout 

func (x *SizeClassQueueState) GetTimeout() *timestamppb.Timestamp

func (*SizeClassQueueState) GetWorkersCount 

func (x *SizeClassQueueState) GetWorkersCount() uint32

func (*SizeClassQueueState) ProtoMessage 

func (*SizeClassQueueState) ProtoMessage()

func (*SizeClassQueueState) ProtoReflect 

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

func (*SizeClassQueueState) Reset 

func (x *SizeClassQueueState) Reset()

func (*SizeClassQueueState) String 

func (x *SizeClassQueueState) String() string

type TerminateWorkersRequest 

type TerminateWorkersRequest struct {
	WorkerIdPattern map[string]string `` /* 196-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*TerminateWorkersRequest) Descriptor deprecated 

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

Deprecated: Use TerminateWorkersRequest.ProtoReflect.Descriptor instead.

func (*TerminateWorkersRequest) GetWorkerIdPattern 

func (x *TerminateWorkersRequest) GetWorkerIdPattern() map[string]string

func (*TerminateWorkersRequest) ProtoMessage 

func (*TerminateWorkersRequest) ProtoMessage()

func (*TerminateWorkersRequest) ProtoReflect 

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

func (*TerminateWorkersRequest) Reset 

func (x *TerminateWorkersRequest) Reset()

func (*TerminateWorkersRequest) String 

func (x *TerminateWorkersRequest) String() string

type UnimplementedBuildQueueStateServer 

type UnimplementedBuildQueueStateServer struct {
}

UnimplementedBuildQueueStateServer should be embedded to have forward compatible implementations.

func (UnimplementedBuildQueueStateServer) AddDrain 

func (UnimplementedBuildQueueStateServer) AddDrain(context.Context, *AddOrRemoveDrainRequest) (*emptypb.Empty, error)

func (UnimplementedBuildQueueStateServer) GetOperation 

func (UnimplementedBuildQueueStateServer) GetOperation(context.Context, *GetOperationRequest) (*GetOperationResponse, error)

func (UnimplementedBuildQueueStateServer) KillOperations 

func (UnimplementedBuildQueueStateServer) KillOperations(context.Context, *KillOperationsRequest) (*emptypb.Empty, error)

func (UnimplementedBuildQueueStateServer) ListDrains 

func (UnimplementedBuildQueueStateServer) ListDrains(context.Context, *ListDrainsRequest) (*ListDrainsResponse, error)

func (UnimplementedBuildQueueStateServer) ListInvocationChildren 

func (UnimplementedBuildQueueStateServer) ListInvocationChildren(context.Context, *ListInvocationChildrenRequest) (*ListInvocationChildrenResponse, error)

func (UnimplementedBuildQueueStateServer) ListOperations 

func (UnimplementedBuildQueueStateServer) ListOperations(context.Context, *ListOperationsRequest) (*ListOperationsResponse, error)

func (UnimplementedBuildQueueStateServer) ListPlatformQueues 

func (UnimplementedBuildQueueStateServer) ListPlatformQueues(context.Context, *emptypb.Empty) (*ListPlatformQueuesResponse, error)

func (UnimplementedBuildQueueStateServer) ListQueuedOperations 

func (UnimplementedBuildQueueStateServer) ListQueuedOperations(context.Context, *ListQueuedOperationsRequest) (*ListQueuedOperationsResponse, error)

func (UnimplementedBuildQueueStateServer) ListWorkers 

func (UnimplementedBuildQueueStateServer) ListWorkers(context.Context, *ListWorkersRequest) (*ListWorkersResponse, error)

func (UnimplementedBuildQueueStateServer) RemoveDrain 

func (UnimplementedBuildQueueStateServer) RemoveDrain(context.Context, *AddOrRemoveDrainRequest) (*emptypb.Empty, error)

func (UnimplementedBuildQueueStateServer) TerminateWorkers 

func (UnimplementedBuildQueueStateServer) TerminateWorkers(context.Context, *TerminateWorkersRequest) (*emptypb.Empty, error)

type UnsafeBuildQueueStateServer 

type UnsafeBuildQueueStateServer interface {
	// contains filtered or unexported methods
}

UnsafeBuildQueueStateServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to BuildQueueStateServer will result in compilation errors.

type WorkerState 

type WorkerState struct {
	Id               map[string]string      `` /* 145-byte string literal not displayed */
	Timeout          *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=timeout,proto3" json:"timeout,omitempty"`
	CurrentOperation *OperationState        `protobuf:"bytes,3,opt,name=current_operation,json=currentOperation,proto3" json:"current_operation,omitempty"`
	Drained          bool                   `protobuf:"varint,4,opt,name=drained,proto3" json:"drained,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkerState) Descriptor deprecated 

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

Deprecated: Use WorkerState.ProtoReflect.Descriptor instead.

func (*WorkerState) GetCurrentOperation 

func (x *WorkerState) GetCurrentOperation() *OperationState

func (*WorkerState) GetDrained 

func (x *WorkerState) GetDrained() bool

func (*WorkerState) GetId 

func (x *WorkerState) GetId() map[string]string

func (*WorkerState) GetTimeout 

func (x *WorkerState) GetTimeout() *timestamppb.Timestamp

func (*WorkerState) ProtoMessage 

func (*WorkerState) ProtoMessage()

func (*WorkerState) ProtoReflect 

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

func (*WorkerState) Reset 

func (x *WorkerState) Reset()

func (*WorkerState) String 

func (x *WorkerState) 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.