coordinator

package
v0.0.1 Latest Latest
Warning

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

 Go to latest Published: Mar 7, 2025 License: AGPL-3.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	Capability_name = map[int32]string{
		0: "CAPABILITY_UNKNOWN_UNSPECIFIED",
		1: "CAPABILITY_BUILTIN",
		2: "CAPABILITY_NMAP",
		3: "CAPABILITY_NMAP_FULL",
	}
	Capability_value = map[string]int32{
		"CAPABILITY_UNKNOWN_UNSPECIFIED": 0,
		"CAPABILITY_BUILTIN":             1,
		"CAPABILITY_NMAP":                2,
		"CAPABILITY_NMAP_FULL":           3,
	}
)

Enum value maps for Capability.

View Source 
var File_coordinator_v1_coordinator_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type Capability 

type Capability int32

Capability enum defines the different scanning or operational capabilities that components in the system can support. 

const (
	// Default value used when capability is unknown or unspecified.
	Capability_CAPABILITY_UNKNOWN_UNSPECIFIED Capability = 0
	// Basic built-in capabilities provided by default.
	Capability_CAPABILITY_BUILTIN Capability = 1
	// Basic network mapping capability using nmap with missing scripts.
	Capability_CAPABILITY_NMAP Capability = 2
	// Full network mapping capability using nmap with all scripts.
	Capability_CAPABILITY_NMAP_FULL Capability = 3
)

func (Capability) Descriptor 

func (Capability) Descriptor() protoreflect.EnumDescriptor

func (Capability) Enum 

func (x Capability) Enum() *Capability

func (Capability) EnumDescriptor deprecated 

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

Deprecated: Use Capability.Descriptor instead.

func (Capability) Number 

func (x Capability) Number() protoreflect.EnumNumber

func (Capability) String 

func (x Capability) String() string

func (Capability) Type 

func (Capability) Type() protoreflect.EnumType

type RegisterRequest 

type RegisterRequest struct {

	// The client's public key for message verification and identity
	PublicKey []byte `protobuf:"bytes,1,opt,name=public_key,json=publicKey,proto3" json:"public_key,omitempty"`
	// Number of parallel computation workers the client can provide
	Workers uint32 `protobuf:"varint,2,opt,name=workers,proto3" json:"workers,omitempty"`
	// The client's capabilities
	Capabilities []Capability `protobuf:"varint,3,rep,packed,name=capabilities,proto3,enum=fn0rd.coordinator.v1.Capability" json:"capabilities,omitempty"`
	// contains filtered or unexported fields
}

RegisterRequest is sent by clients to join the computation network

func (*RegisterRequest) Descriptor deprecated 

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

Deprecated: Use RegisterRequest.ProtoReflect.Descriptor instead.

func (*RegisterRequest) GetCapabilities 

func (x *RegisterRequest) GetCapabilities() []Capability

func (*RegisterRequest) GetPublicKey 

func (x *RegisterRequest) GetPublicKey() []byte

func (*RegisterRequest) GetWorkers 

func (x *RegisterRequest) GetWorkers() uint32

func (*RegisterRequest) ProtoMessage 

func (*RegisterRequest) ProtoMessage()

func (*RegisterRequest) ProtoReflect 

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

func (*RegisterRequest) Reset 

func (x *RegisterRequest) Reset()

func (*RegisterRequest) String 

func (x *RegisterRequest) String() string

type StreamRequest 

type StreamRequest struct {

	// Unique random value to prevent replay attacks
	Nonce []byte `protobuf:"bytes,1,opt,name=nonce,proto3" json:"nonce,omitempty"`
	// Cryptographic signature proving the sender's identity
	Signature []byte `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"`
	// The actual request payload, which can be one of multiple types
	//
	// Types that are valid to be assigned to Request:
	//
	//	*StreamRequest_Register
	//	*StreamRequest_Submit
	Request isStreamRequest_Request `protobuf_oneof:"request"`
	// contains filtered or unexported fields
}

StreamRequest encapsulates all possible client-to-coordinator messages

func (*StreamRequest) Descriptor deprecated 

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

Deprecated: Use StreamRequest.ProtoReflect.Descriptor instead.

func (*StreamRequest) GetNonce 

func (x *StreamRequest) GetNonce() []byte

func (*StreamRequest) GetRegister 

func (x *StreamRequest) GetRegister() *RegisterRequest

func (*StreamRequest) GetRequest 

func (x *StreamRequest) GetRequest() isStreamRequest_Request

func (*StreamRequest) GetSignature 

func (x *StreamRequest) GetSignature() []byte

func (*StreamRequest) GetSubmit 

func (x *StreamRequest) GetSubmit() *SubmitRequest

func (*StreamRequest) ProtoMessage 

func (*StreamRequest) ProtoMessage()

func (*StreamRequest) ProtoReflect 

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

func (*StreamRequest) Reset 

func (x *StreamRequest) Reset()

func (*StreamRequest) String 

func (x *StreamRequest) String() string

type StreamRequest_Register 

type StreamRequest_Register struct {
	// Client registration information
	Register *RegisterRequest `protobuf:"bytes,3,opt,name=register,proto3,oneof"`
}

type StreamRequest_Submit 

type StreamRequest_Submit struct {
	// Computation result submission
	Submit *SubmitRequest `protobuf:"bytes,4,opt,name=submit,proto3,oneof"`
}

type StreamResponse 

type StreamResponse struct {

	// Unique random value to prevent replay attacks
	Nonce []byte `protobuf:"bytes,1,opt,name=nonce,proto3" json:"nonce,omitempty"`
	// The actual response payload, which can be one of multiple types
	//
	// Types that are valid to be assigned to Response:
	//
	//	*StreamResponse_Target
	Response isStreamResponse_Response `protobuf_oneof:"response"`
	// contains filtered or unexported fields
}

StreamResponse encapsulates all possible coordinator-to-client messages

func (*StreamResponse) Descriptor deprecated 

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

Deprecated: Use StreamResponse.ProtoReflect.Descriptor instead.

func (*StreamResponse) GetNonce 

func (x *StreamResponse) GetNonce() []byte

func (*StreamResponse) GetResponse 

func (x *StreamResponse) GetResponse() isStreamResponse_Response

func (*StreamResponse) GetTarget 

func (x *StreamResponse) GetTarget() *TargetResponse

func (*StreamResponse) ProtoMessage 

func (*StreamResponse) ProtoMessage()

func (*StreamResponse) ProtoReflect 

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

func (*StreamResponse) Reset 

func (x *StreamResponse) Reset()

func (*StreamResponse) String 

func (x *StreamResponse) String() string

type StreamResponse_Target 

type StreamResponse_Target struct {
	// Computational target assignment
	Target *TargetResponse `protobuf:"bytes,2,opt,name=target,proto3,oneof"`
}

type SubmitRequest 

type SubmitRequest struct {

	// The result of the completed computation
	Result []byte `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

SubmitRequest is sent by clients when they complete a computational task

func (*SubmitRequest) Descriptor deprecated 

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

Deprecated: Use SubmitRequest.ProtoReflect.Descriptor instead.

func (*SubmitRequest) GetResult 

func (x *SubmitRequest) GetResult() []byte

func (*SubmitRequest) ProtoMessage 

func (*SubmitRequest) ProtoMessage()

func (*SubmitRequest) ProtoReflect 

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

func (*SubmitRequest) Reset 

func (x *SubmitRequest) Reset()

func (*SubmitRequest) String 

func (x *SubmitRequest) String() string

type TargetResponse 

type TargetResponse struct {

	// The computational targets to process
	Target []byte `protobuf:"bytes,1,opt,name=target,proto3" json:"target,omitempty"`
	// Timestamp by which the computation must be completed
	Deadline *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=deadline,proto3" json:"deadline,omitempty"`
	// contains filtered or unexported fields
}

TargetResponse contains a computational task assigned to a client

func (*TargetResponse) Descriptor deprecated 

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

Deprecated: Use TargetResponse.ProtoReflect.Descriptor instead.

func (*TargetResponse) GetDeadline 

func (x *TargetResponse) GetDeadline() *timestamppb.Timestamp

func (*TargetResponse) GetTarget 

func (x *TargetResponse) GetTarget() []byte

func (*TargetResponse) ProtoMessage 

func (*TargetResponse) ProtoMessage()

func (*TargetResponse) ProtoReflect 

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

func (*TargetResponse) Reset 

func (x *TargetResponse) Reset()

func (*TargetResponse) String 

func (x *TargetResponse) String() string

Source Files

View all Source files

Directories

Path Synopsis
Namespace for the coordinator service The fn0rd.coordinator.v1 package contains definitions for the distributed computation coordination system
 Namespace for the coordinator service The fn0rd.coordinator.v1 package contains definitions for the distributed computation coordination system

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.