buildqueuestate

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
}

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

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)
}

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)
}

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
}

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

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

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
}

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
}

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
}

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
}

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
}

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

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

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
}

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

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
}

type ListInvocationChildrenRequest_Filter int32

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

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
}

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
}

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
}

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

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
}

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
}

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
}

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
}

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
}

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

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

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

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

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
}

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
}

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

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

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

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
}

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
}

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
}

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
}

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
}

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

type UnimplementedBuildQueueStateServer struct {
}

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

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
}