remoteworker

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
}

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
}

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

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

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

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

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

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

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

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
}

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
}

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

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

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

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

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
}

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
}

type UnimplementedOperationQueueServer struct {
}

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