remoteworker

package
v0.0.0-...-d03d5e3 Latest Latest
Warning

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

 Go to latest Published: Dec 15, 2024 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	OperationQueue_Synchronize_FullMethodName = "/buildbarn.remoteworker.OperationQueue/Synchronize"
)

Variables

View Source 
var File_pkg_proto_remoteworker_remoteworker_proto protoreflect.FileDescriptor
View Source 
var OperationQueue_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "buildbarn.remoteworker.OperationQueue",
	HandlerType: (*OperationQueueServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Synchronize",
			Handler:    _OperationQueue_Synchronize_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "pkg/proto/remoteworker/remoteworker.proto",
}

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

Functions

func RegisterOperationQueueServer 

func RegisterOperationQueueServer(s grpc.ServiceRegistrar, srv OperationQueueServer)

Types

type CurrentState 

type CurrentState struct {

	// Types that are assignable to WorkerState:
	//
	//	*CurrentState_Idle
	//	*CurrentState_Executing_
	WorkerState isCurrentState_WorkerState `protobuf_oneof:"worker_state"`
	// contains filtered or unexported fields
}

func (*CurrentState) Descriptor deprecated 

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

Deprecated: Use CurrentState.ProtoReflect.Descriptor instead.

func (*CurrentState) GetExecuting 

func (x *CurrentState) GetExecuting() *CurrentState_Executing

func (*CurrentState) GetIdle 

func (x *CurrentState) GetIdle() *emptypb.Empty

func (*CurrentState) GetWorkerState 

func (m *CurrentState) GetWorkerState() isCurrentState_WorkerState

func (*CurrentState) ProtoMessage 

func (*CurrentState) ProtoMessage()

func (*CurrentState) ProtoReflect 

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

func (*CurrentState) Reset 

func (x *CurrentState) Reset()

func (*CurrentState) String 

func (x *CurrentState) String() string

type CurrentState_Executing 

type CurrentState_Executing struct {
	ActionDigest *v2.Digest `protobuf:"bytes,1,opt,name=action_digest,json=actionDigest,proto3" json:"action_digest,omitempty"`
	// Types that are assignable to ExecutionState:
	//
	//	*CurrentState_Executing_Started
	//	*CurrentState_Executing_FetchingInputs
	//	*CurrentState_Executing_Running
	//	*CurrentState_Executing_UploadingOutputs
	//	*CurrentState_Executing_Completed
	ExecutionState isCurrentState_Executing_ExecutionState `protobuf_oneof:"execution_state"`
	// contains filtered or unexported fields
}

func (*CurrentState_Executing) Descriptor deprecated 

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

Deprecated: Use CurrentState_Executing.ProtoReflect.Descriptor instead.

func (*CurrentState_Executing) GetActionDigest 

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

func (*CurrentState_Executing) GetCompleted 

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

func (*CurrentState_Executing) GetExecutionState 

func (m *CurrentState_Executing) GetExecutionState() isCurrentState_Executing_ExecutionState

func (*CurrentState_Executing) GetFetchingInputs 

func (x *CurrentState_Executing) GetFetchingInputs() *emptypb.Empty

func (*CurrentState_Executing) GetRunning 

func (x *CurrentState_Executing) GetRunning() *emptypb.Empty

func (*CurrentState_Executing) GetStarted 

func (x *CurrentState_Executing) GetStarted() *emptypb.Empty

func (*CurrentState_Executing) GetUploadingOutputs 

func (x *CurrentState_Executing) GetUploadingOutputs() *emptypb.Empty

func (*CurrentState_Executing) ProtoMessage 

func (*CurrentState_Executing) ProtoMessage()

func (*CurrentState_Executing) ProtoReflect 

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

func (*CurrentState_Executing) Reset 

func (x *CurrentState_Executing) Reset()

func (*CurrentState_Executing) String 

func (x *CurrentState_Executing) String() string

type CurrentState_Executing_ 

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

type CurrentState_Executing_Completed 

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

type CurrentState_Executing_FetchingInputs 

type CurrentState_Executing_FetchingInputs struct {
	FetchingInputs *emptypb.Empty `protobuf:"bytes,3,opt,name=fetching_inputs,json=fetchingInputs,proto3,oneof"`
}

type CurrentState_Executing_Running 

type CurrentState_Executing_Running struct {
	Running *emptypb.Empty `protobuf:"bytes,4,opt,name=running,proto3,oneof"`
}

type CurrentState_Executing_Started 

type CurrentState_Executing_Started struct {
	Started *emptypb.Empty `protobuf:"bytes,2,opt,name=started,proto3,oneof"`
}

type CurrentState_Executing_UploadingOutputs 

type CurrentState_Executing_UploadingOutputs struct {
	UploadingOutputs *emptypb.Empty `protobuf:"bytes,5,opt,name=uploading_outputs,json=uploadingOutputs,proto3,oneof"`
}

type CurrentState_Idle 

type CurrentState_Idle struct {
	Idle *emptypb.Empty `protobuf:"bytes,1,opt,name=idle,proto3,oneof"`
}

type DesiredState 

type DesiredState struct {

	// Types that are assignable to WorkerState:
	//
	//	*DesiredState_Idle
	//	*DesiredState_Executing_
	WorkerState isDesiredState_WorkerState `protobuf_oneof:"worker_state"`
	// contains filtered or unexported fields
}

func (*DesiredState) Descriptor deprecated 

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

Deprecated: Use DesiredState.ProtoReflect.Descriptor instead.

func (*DesiredState) GetExecuting 

func (x *DesiredState) GetExecuting() *DesiredState_Executing

func (*DesiredState) GetIdle 

func (x *DesiredState) GetIdle() *emptypb.Empty

func (*DesiredState) GetWorkerState 

func (m *DesiredState) GetWorkerState() isDesiredState_WorkerState

func (*DesiredState) ProtoMessage 

func (*DesiredState) ProtoMessage()

func (*DesiredState) ProtoReflect 

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

func (*DesiredState) Reset 

func (x *DesiredState) Reset()

func (*DesiredState) String 

func (x *DesiredState) String() string

type DesiredState_Executing 

type DesiredState_Executing struct {
	ActionDigest       *v2.Digest              `protobuf:"bytes,1,opt,name=action_digest,json=actionDigest,proto3" json:"action_digest,omitempty"`
	Action             *v2.Action              `protobuf:"bytes,2,opt,name=action,proto3" json:"action,omitempty"`
	QueuedTimestamp    *timestamppb.Timestamp  `protobuf:"bytes,4,opt,name=queued_timestamp,json=queuedTimestamp,proto3" json:"queued_timestamp,omitempty"`
	AuxiliaryMetadata  []*anypb.Any            `protobuf:"bytes,6,rep,name=auxiliary_metadata,json=auxiliaryMetadata,proto3" json:"auxiliary_metadata,omitempty"`
	InstanceNameSuffix string                  `protobuf:"bytes,7,opt,name=instance_name_suffix,json=instanceNameSuffix,proto3" json:"instance_name_suffix,omitempty"`
	W3CTraceContext    map[string]string       `` /* 196-byte string literal not displayed */
	DigestFunction     v2.DigestFunction_Value `` /* 162-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*DesiredState_Executing) Descriptor deprecated 

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

Deprecated: Use DesiredState_Executing.ProtoReflect.Descriptor instead.

func (*DesiredState_Executing) GetAction 

func (x *DesiredState_Executing) GetAction() *v2.Action

func (*DesiredState_Executing) GetActionDigest 

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

func (*DesiredState_Executing) GetAuxiliaryMetadata 

func (x *DesiredState_Executing) GetAuxiliaryMetadata() []*anypb.Any

func (*DesiredState_Executing) GetDigestFunction 

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

func (*DesiredState_Executing) GetInstanceNameSuffix 

func (x *DesiredState_Executing) GetInstanceNameSuffix() string

func (*DesiredState_Executing) GetQueuedTimestamp 

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

func (*DesiredState_Executing) GetW3CTraceContext 

func (x *DesiredState_Executing) GetW3CTraceContext() map[string]string

func (*DesiredState_Executing) ProtoMessage 

func (*DesiredState_Executing) ProtoMessage()

func (*DesiredState_Executing) ProtoReflect 

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

func (*DesiredState_Executing) Reset 

func (x *DesiredState_Executing) Reset()

func (*DesiredState_Executing) String 

func (x *DesiredState_Executing) String() string

type DesiredState_Executing_ 

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

type DesiredState_Idle 

type DesiredState_Idle struct {
	Idle *emptypb.Empty `protobuf:"bytes,1,opt,name=idle,proto3,oneof"`
}

type OperationQueueClient 

type OperationQueueClient interface {
	Synchronize(ctx context.Context, in *SynchronizeRequest, opts ...grpc.CallOption) (*SynchronizeResponse, error)
}

OperationQueueClient is the client API for OperationQueue 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 NewOperationQueueClient 

func NewOperationQueueClient(cc grpc.ClientConnInterface) OperationQueueClient

type OperationQueueServer 

type OperationQueueServer interface {
	Synchronize(context.Context, *SynchronizeRequest) (*SynchronizeResponse, error)
}

OperationQueueServer is the server API for OperationQueue service. All implementations should embed UnimplementedOperationQueueServer for forward compatibility

type SynchronizeRequest 

type SynchronizeRequest struct {
	WorkerId           map[string]string `` /* 173-byte string literal not displayed */
	InstanceNamePrefix string            `protobuf:"bytes,2,opt,name=instance_name_prefix,json=instanceNamePrefix,proto3" json:"instance_name_prefix,omitempty"`
	Platform           *v2.Platform      `protobuf:"bytes,3,opt,name=platform,proto3" json:"platform,omitempty"`
	SizeClass          uint32            `protobuf:"varint,5,opt,name=size_class,json=sizeClass,proto3" json:"size_class,omitempty"`
	CurrentState       *CurrentState     `protobuf:"bytes,4,opt,name=current_state,json=currentState,proto3" json:"current_state,omitempty"`
	PreferBeingIdle    bool              `protobuf:"varint,6,opt,name=prefer_being_idle,json=preferBeingIdle,proto3" json:"prefer_being_idle,omitempty"`
	// contains filtered or unexported fields
}

func (*SynchronizeRequest) Descriptor deprecated 

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

Deprecated: Use SynchronizeRequest.ProtoReflect.Descriptor instead.

func (*SynchronizeRequest) GetCurrentState 

func (x *SynchronizeRequest) GetCurrentState() *CurrentState

func (*SynchronizeRequest) GetInstanceNamePrefix 

func (x *SynchronizeRequest) GetInstanceNamePrefix() string

func (*SynchronizeRequest) GetPlatform 

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

func (*SynchronizeRequest) GetPreferBeingIdle 

func (x *SynchronizeRequest) GetPreferBeingIdle() bool

func (*SynchronizeRequest) GetSizeClass 

func (x *SynchronizeRequest) GetSizeClass() uint32

func (*SynchronizeRequest) GetWorkerId 

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

func (*SynchronizeRequest) ProtoMessage 

func (*SynchronizeRequest) ProtoMessage()

func (*SynchronizeRequest) ProtoReflect 

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

func (*SynchronizeRequest) Reset 

func (x *SynchronizeRequest) Reset()

func (*SynchronizeRequest) String 

func (x *SynchronizeRequest) String() string

type SynchronizeResponse 

type SynchronizeResponse struct {
	NextSynchronizationAt *timestamppb.Timestamp `` /* 126-byte string literal not displayed */
	DesiredState          *DesiredState          `protobuf:"bytes,2,opt,name=desired_state,json=desiredState,proto3" json:"desired_state,omitempty"`
	// contains filtered or unexported fields
}

func (*SynchronizeResponse) Descriptor deprecated 

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

Deprecated: Use SynchronizeResponse.ProtoReflect.Descriptor instead.

func (*SynchronizeResponse) GetDesiredState 

func (x *SynchronizeResponse) GetDesiredState() *DesiredState

func (*SynchronizeResponse) GetNextSynchronizationAt 

func (x *SynchronizeResponse) GetNextSynchronizationAt() *timestamppb.Timestamp

func (*SynchronizeResponse) ProtoMessage 

func (*SynchronizeResponse) ProtoMessage()

func (*SynchronizeResponse) ProtoReflect 

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

func (*SynchronizeResponse) Reset 

func (x *SynchronizeResponse) Reset()

func (*SynchronizeResponse) String 

func (x *SynchronizeResponse) String() string

type UnimplementedOperationQueueServer 

type UnimplementedOperationQueueServer struct {
}

UnimplementedOperationQueueServer should be embedded to have forward compatible implementations.

func (UnimplementedOperationQueueServer) Synchronize 

func (UnimplementedOperationQueueServer) Synchronize(context.Context, *SynchronizeRequest) (*SynchronizeResponse, error)

type UnsafeOperationQueueServer 

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

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

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.