remoteworker

type CurrentState struct {

	// Types that are valid to be assigned to WorkerState:
	//
	//	*CurrentState_Idle
	//	*CurrentState_Rejected_
	//	*CurrentState_Executing_
	//	*CurrentState_Completed_
	WorkerState isCurrentState_WorkerState `protobuf_oneof:"worker_state"`
	// contains filtered or unexported fields
}

type CurrentState_Completed struct {
	TaskUuid                 string                        `protobuf:"bytes,1,opt,name=task_uuid,json=taskUuid,proto3" json:"task_uuid,omitempty"`
	Event                    *encryptedaction.Event        `protobuf:"bytes,2,opt,name=event,proto3" json:"event,omitempty"`
	VirtualExecutionDuration *durationpb.Duration          `` /* 135-byte string literal not displayed */
	Result                   CurrentState_Completed_Result `protobuf:"varint,4,opt,name=result,proto3,enum=bonanza.remoteworker.CurrentState_Completed_Result" json:"result,omitempty"`
	// contains filtered or unexported fields
}

type CurrentState_Completed_ struct {
	Completed *CurrentState_Completed `protobuf:"bytes,4,opt,name=completed,proto3,oneof"`
}

type CurrentState_Completed_Result int32

type CurrentState_Executing struct {
	TaskUuid string                 `protobuf:"bytes,1,opt,name=task_uuid,json=taskUuid,proto3" json:"task_uuid,omitempty"`
	Event    *encryptedaction.Event `protobuf:"bytes,2,opt,name=event,proto3" json:"event,omitempty"`
	// contains filtered or unexported fields
}

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

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

type CurrentState_Rejected struct {
	TaskUuid string         `protobuf:"bytes,1,opt,name=task_uuid,json=taskUuid,proto3" json:"task_uuid,omitempty"`
	Reason   *status.Status `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`
	// contains filtered or unexported fields
}

type CurrentState_Rejected_ struct {
	Rejected *CurrentState_Rejected `protobuf:"bytes,2,opt,name=rejected,proto3,oneof"`
}

type DesiredState struct {

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

type DesiredState_Executing struct {
	TaskUuid                  string                  `protobuf:"bytes,1,opt,name=task_uuid,json=taskUuid,proto3" json:"task_uuid,omitempty"`
	Action                    *encryptedaction.Action `protobuf:"bytes,2,opt,name=action,proto3" json:"action,omitempty"`
	EffectiveExecutionTimeout *durationpb.Duration    `` /* 138-byte string literal not displayed */
	QueuedTimestamp           *timestamppb.Timestamp  `protobuf:"bytes,4,opt,name=queued_timestamp,json=queuedTimestamp,proto3" json:"queued_timestamp,omitempty"`
	AuxiliaryMetadata         []*anypb.Any            `protobuf:"bytes,5,rep,name=auxiliary_metadata,json=auxiliaryMetadata,proto3" json:"auxiliary_metadata,omitempty"`
	W3CTraceContext           map[string]string       `` /* 182-byte string literal not displayed */
	// contains filtered or unexported fields
}

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

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

type DesiredState_VerifyingPublicKeys struct {
	VerificationPkixPublicKeys [][]byte `` /* 143-byte string literal not displayed */
	// contains filtered or unexported fields
}

type DesiredState_VerifyingPublicKeys_ struct {
	VerifyingPublicKeys *DesiredState_VerifyingPublicKeys `protobuf:"bytes,1,opt,name=verifying_public_keys,json=verifyingPublicKeys,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               `` /* 159-byte string literal not displayed */
	PublicKeys      []*SynchronizeRequest_PublicKey `protobuf:"bytes,2,rep,name=public_keys,json=publicKeys,proto3" json:"public_keys,omitempty"`
	SizeClass       uint32                          `protobuf:"varint,3,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,5,opt,name=prefer_being_idle,json=preferBeingIdle,proto3" json:"prefer_being_idle,omitempty"`
	// contains filtered or unexported fields
}

type SynchronizeRequest_PublicKey struct {
	PkixPublicKey     []byte `protobuf:"bytes,1,opt,name=pkix_public_key,json=pkixPublicKey,proto3" json:"pkix_public_key,omitempty"`
	VerificationZeros []byte `protobuf:"bytes,2,opt,name=verification_zeros,json=verificationZeros,proto3" json:"verification_zeros,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
}