minichord

package module
v0.0.0-...-5f11ed6 Latest Latest
Warning

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

Go to latest
Published: Mar 15, 2024 License: BSD-2-Clause Imports: 9 Imported by: 0

README

minichord

Message specification for the Chord assignment at Reykjavik University

Documentation

Index

Constants

View Source
const I64SIZE = 8

Variables

View Source
var File_minichord_proto protoreflect.FileDescriptor

Functions

func SendMiniChordMessage

func SendMiniChordMessage(conn net.Conn, message *MiniChord) (err error)

SendMiniChordMessage marshals and sends a protobuf message on a connection conn.

Types

type Deregistration

type Deregistration struct {
	Id      int32  `protobuf:"fixed32,2,opt,name=Id,proto3" json:"Id,omitempty"`
	Address string `protobuf:"bytes,1,opt,name=Address,proto3" json:"Address,omitempty"`
	// contains filtered or unexported fields
}

func (*Deregistration) Descriptor deprecated

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

Deprecated: Use Deregistration.ProtoReflect.Descriptor instead.

func (*Deregistration) GetAddress

func (x *Deregistration) GetAddress() string

func (*Deregistration) GetId

func (x *Deregistration) GetId() int32

func (*Deregistration) ProtoMessage

func (*Deregistration) ProtoMessage()

func (*Deregistration) ProtoReflect

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

func (*Deregistration) Reset

func (x *Deregistration) Reset()

func (*Deregistration) String

func (x *Deregistration) String() string

type DeregistrationResponse

type DeregistrationResponse struct {
	Result int32  `protobuf:"fixed32,2,opt,name=Result,proto3" json:"Result,omitempty"`
	Info   string `protobuf:"bytes,3,opt,name=Info,proto3" json:"Info,omitempty"`
	// contains filtered or unexported fields
}

func (*DeregistrationResponse) Descriptor deprecated

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

Deprecated: Use DeregistrationResponse.ProtoReflect.Descriptor instead.

func (*DeregistrationResponse) GetInfo

func (x *DeregistrationResponse) GetInfo() string

func (*DeregistrationResponse) GetResult

func (x *DeregistrationResponse) GetResult() int32

func (*DeregistrationResponse) ProtoMessage

func (*DeregistrationResponse) ProtoMessage()

func (*DeregistrationResponse) ProtoReflect

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

func (*DeregistrationResponse) Reset

func (x *DeregistrationResponse) Reset()

func (*DeregistrationResponse) String

func (x *DeregistrationResponse) String() string

type InitiateTask

type InitiateTask struct {
	Packets uint32 `protobuf:"fixed32,13,opt,name=Packets,proto3" json:"Packets,omitempty"`
	// contains filtered or unexported fields
}

func (*InitiateTask) Descriptor deprecated

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

Deprecated: Use InitiateTask.ProtoReflect.Descriptor instead.

func (*InitiateTask) GetPackets

func (x *InitiateTask) GetPackets() uint32

func (*InitiateTask) ProtoMessage

func (*InitiateTask) ProtoMessage()

func (*InitiateTask) ProtoReflect

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

func (*InitiateTask) Reset

func (x *InitiateTask) Reset()

func (*InitiateTask) String

func (x *InitiateTask) String() string

type MiniChord

type MiniChord struct {

	// Types that are assignable to Message:
	//
	//	*MiniChord_Registration
	//	*MiniChord_RegistrationResponse
	//	*MiniChord_Deregistration
	//	*MiniChord_DeregistrationResponse
	//	*MiniChord_NodeRegistry
	//	*MiniChord_NodeRegistryResponse
	//	*MiniChord_InitiateTask
	//	*MiniChord_NodeData
	//	*MiniChord_TaskFinished
	//	*MiniChord_RequestTrafficSummary
	//	*MiniChord_ReportTrafficSummary
	Message isMiniChord_Message `protobuf_oneof:"Message"`
	// contains filtered or unexported fields
}

func ReceiveMiniChordMessage

func ReceiveMiniChordMessage(conn net.Conn) (message *MiniChord, err error)

ReceiveMiniChordMessage receives a protobuf marshaled message on a connection conn and unmarshals it. Make sure to call this function from only one go routine at a time.

func (*MiniChord) Descriptor deprecated

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

Deprecated: Use MiniChord.ProtoReflect.Descriptor instead.

func (*MiniChord) GetDeregistration

func (x *MiniChord) GetDeregistration() *Deregistration

func (*MiniChord) GetDeregistrationResponse

func (x *MiniChord) GetDeregistrationResponse() *DeregistrationResponse

func (*MiniChord) GetInitiateTask

func (x *MiniChord) GetInitiateTask() *InitiateTask

func (*MiniChord) GetMessage

func (m *MiniChord) GetMessage() isMiniChord_Message

func (*MiniChord) GetNodeData

func (x *MiniChord) GetNodeData() *NodeData

func (*MiniChord) GetNodeRegistry

func (x *MiniChord) GetNodeRegistry() *NodeRegistry

func (*MiniChord) GetNodeRegistryResponse

func (x *MiniChord) GetNodeRegistryResponse() *NodeRegistryResponse

func (*MiniChord) GetRegistration

func (x *MiniChord) GetRegistration() *Registration

func (*MiniChord) GetRegistrationResponse

func (x *MiniChord) GetRegistrationResponse() *RegistrationResponse

func (*MiniChord) GetReportTrafficSummary

func (x *MiniChord) GetReportTrafficSummary() *TrafficSummary

func (*MiniChord) GetRequestTrafficSummary

func (x *MiniChord) GetRequestTrafficSummary() *RequestTrafficSummary

func (*MiniChord) GetTaskFinished

func (x *MiniChord) GetTaskFinished() *TaskFinished

func (*MiniChord) ProtoMessage

func (*MiniChord) ProtoMessage()

func (*MiniChord) ProtoReflect

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

func (*MiniChord) Reset

func (x *MiniChord) Reset()

func (*MiniChord) String

func (x *MiniChord) String() string

type MiniChord_Deregistration

type MiniChord_Deregistration struct {
	Deregistration *Deregistration `protobuf:"bytes,19,opt,name=deregistration,proto3,oneof"`
}

type MiniChord_DeregistrationResponse

type MiniChord_DeregistrationResponse struct {
	DeregistrationResponse *DeregistrationResponse `protobuf:"bytes,20,opt,name=deregistrationResponse,proto3,oneof"`
}

type MiniChord_InitiateTask

type MiniChord_InitiateTask struct {
	InitiateTask *InitiateTask `protobuf:"bytes,23,opt,name=initiateTask,proto3,oneof"`
}

type MiniChord_NodeData

type MiniChord_NodeData struct {
	NodeData *NodeData `protobuf:"bytes,15,opt,name=nodeData,proto3,oneof"`
}

type MiniChord_NodeRegistry

type MiniChord_NodeRegistry struct {
	NodeRegistry *NodeRegistry `protobuf:"bytes,21,opt,name=nodeRegistry,proto3,oneof"`
}

type MiniChord_NodeRegistryResponse

type MiniChord_NodeRegistryResponse struct {
	NodeRegistryResponse *NodeRegistryResponse `protobuf:"bytes,22,opt,name=nodeRegistryResponse,proto3,oneof"`
}

type MiniChord_Registration

type MiniChord_Registration struct {
	Registration *Registration `protobuf:"bytes,17,opt,name=registration,proto3,oneof"`
}

type MiniChord_RegistrationResponse

type MiniChord_RegistrationResponse struct {
	RegistrationResponse *RegistrationResponse `protobuf:"bytes,18,opt,name=registrationResponse,proto3,oneof"`
}

type MiniChord_ReportTrafficSummary

type MiniChord_ReportTrafficSummary struct {
	ReportTrafficSummary *TrafficSummary `protobuf:"bytes,26,opt,name=reportTrafficSummary,proto3,oneof"`
}

type MiniChord_RequestTrafficSummary

type MiniChord_RequestTrafficSummary struct {
	RequestTrafficSummary *RequestTrafficSummary `protobuf:"bytes,25,opt,name=requestTrafficSummary,proto3,oneof"`
}

type MiniChord_TaskFinished

type MiniChord_TaskFinished struct {
	TaskFinished *TaskFinished `protobuf:"bytes,24,opt,name=taskFinished,proto3,oneof"`
}

type NodeData

type NodeData struct {
	Destination int32   `protobuf:"fixed32,1,opt,name=Destination,proto3" json:"Destination,omitempty"`
	Source      int32   `protobuf:"fixed32,2,opt,name=Source,proto3" json:"Source,omitempty"`
	Payload     int32   `protobuf:"fixed32,3,opt,name=Payload,proto3" json:"Payload,omitempty"`
	Hops        uint32  `protobuf:"fixed32,4,opt,name=Hops,proto3" json:"Hops,omitempty"`
	Trace       []int32 `protobuf:"fixed32,5,rep,packed,name=Trace,proto3" json:"Trace,omitempty"`
	// contains filtered or unexported fields
}

func (*NodeData) Descriptor deprecated

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

Deprecated: Use NodeData.ProtoReflect.Descriptor instead.

func (*NodeData) GetDestination

func (x *NodeData) GetDestination() int32

func (*NodeData) GetHops

func (x *NodeData) GetHops() uint32

func (*NodeData) GetPayload

func (x *NodeData) GetPayload() int32

func (*NodeData) GetSource

func (x *NodeData) GetSource() int32

func (*NodeData) GetTrace

func (x *NodeData) GetTrace() []int32

func (*NodeData) ProtoMessage

func (*NodeData) ProtoMessage()

func (*NodeData) ProtoReflect

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

func (*NodeData) Reset

func (x *NodeData) Reset()

func (*NodeData) String

func (x *NodeData) String() string

type NodeRegistry

type NodeRegistry struct {
	NR    uint32            `protobuf:"fixed32,4,opt,name=NR,proto3" json:"NR,omitempty"`
	Peers []*Deregistration `protobuf:"bytes,5,rep,name=Peers,proto3" json:"Peers,omitempty"` // Pair of Id and Address
	NoIds uint32            `protobuf:"fixed32,7,opt,name=NoIds,proto3" json:"NoIds,omitempty"`
	Ids   []int32           `protobuf:"fixed32,6,rep,packed,name=Ids,proto3" json:"Ids,omitempty"`
	// contains filtered or unexported fields
}

func (*NodeRegistry) Descriptor deprecated

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

Deprecated: Use NodeRegistry.ProtoReflect.Descriptor instead.

func (*NodeRegistry) GetIds

func (x *NodeRegistry) GetIds() []int32

func (*NodeRegistry) GetNR

func (x *NodeRegistry) GetNR() uint32

func (*NodeRegistry) GetNoIds

func (x *NodeRegistry) GetNoIds() uint32

func (*NodeRegistry) GetPeers

func (x *NodeRegistry) GetPeers() []*Deregistration

func (*NodeRegistry) ProtoMessage

func (*NodeRegistry) ProtoMessage()

func (*NodeRegistry) ProtoReflect

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

func (*NodeRegistry) Reset

func (x *NodeRegistry) Reset()

func (*NodeRegistry) String

func (x *NodeRegistry) String() string

type NodeRegistryResponse

type NodeRegistryResponse struct {
	Result uint32 `protobuf:"fixed32,2,opt,name=Result,proto3" json:"Result,omitempty"`
	Info   string `protobuf:"bytes,3,opt,name=Info,proto3" json:"Info,omitempty"`
	// contains filtered or unexported fields
}

func (*NodeRegistryResponse) Descriptor deprecated

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

Deprecated: Use NodeRegistryResponse.ProtoReflect.Descriptor instead.

func (*NodeRegistryResponse) GetInfo

func (x *NodeRegistryResponse) GetInfo() string

func (*NodeRegistryResponse) GetResult

func (x *NodeRegistryResponse) GetResult() uint32

func (*NodeRegistryResponse) ProtoMessage

func (*NodeRegistryResponse) ProtoMessage()

func (*NodeRegistryResponse) ProtoReflect

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

func (*NodeRegistryResponse) Reset

func (x *NodeRegistryResponse) Reset()

func (*NodeRegistryResponse) String

func (x *NodeRegistryResponse) String() string

type Registration

type Registration struct {
	Address string `protobuf:"bytes,1,opt,name=Address,proto3" json:"Address,omitempty"` // Address of the peer that registers, must be acceptable by func Dial
	// contains filtered or unexported fields
}

func (*Registration) Descriptor deprecated

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

Deprecated: Use Registration.ProtoReflect.Descriptor instead.

func (*Registration) GetAddress

func (x *Registration) GetAddress() string

func (*Registration) ProtoMessage

func (*Registration) ProtoMessage()

func (*Registration) ProtoReflect

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

func (*Registration) Reset

func (x *Registration) Reset()

func (*Registration) String

func (x *Registration) String() string

type RegistrationResponse

type RegistrationResponse struct {
	Result int32  `protobuf:"fixed32,2,opt,name=Result,proto3" json:"Result,omitempty"`
	Info   string `protobuf:"bytes,3,opt,name=Info,proto3" json:"Info,omitempty"`
	// contains filtered or unexported fields
}

func (*RegistrationResponse) Descriptor deprecated

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

Deprecated: Use RegistrationResponse.ProtoReflect.Descriptor instead.

func (*RegistrationResponse) GetInfo

func (x *RegistrationResponse) GetInfo() string

func (*RegistrationResponse) GetResult

func (x *RegistrationResponse) GetResult() int32

func (*RegistrationResponse) ProtoMessage

func (*RegistrationResponse) ProtoMessage()

func (*RegistrationResponse) ProtoReflect

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

func (*RegistrationResponse) Reset

func (x *RegistrationResponse) Reset()

func (*RegistrationResponse) String

func (x *RegistrationResponse) String() string

type RequestTrafficSummary

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

func (*RequestTrafficSummary) Descriptor deprecated

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

Deprecated: Use RequestTrafficSummary.ProtoReflect.Descriptor instead.

func (*RequestTrafficSummary) ProtoMessage

func (*RequestTrafficSummary) ProtoMessage()

func (*RequestTrafficSummary) ProtoReflect

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

func (*RequestTrafficSummary) Reset

func (x *RequestTrafficSummary) Reset()

func (*RequestTrafficSummary) String

func (x *RequestTrafficSummary) String() string

type TaskFinished

type TaskFinished struct {
	Id      int32  `protobuf:"fixed32,2,opt,name=Id,proto3" json:"Id,omitempty"`
	Address string `protobuf:"bytes,1,opt,name=Address,proto3" json:"Address,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskFinished) Descriptor deprecated

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

Deprecated: Use TaskFinished.ProtoReflect.Descriptor instead.

func (*TaskFinished) GetAddress

func (x *TaskFinished) GetAddress() string

func (*TaskFinished) GetId

func (x *TaskFinished) GetId() int32

func (*TaskFinished) ProtoMessage

func (*TaskFinished) ProtoMessage()

func (*TaskFinished) ProtoReflect

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

func (*TaskFinished) Reset

func (x *TaskFinished) Reset()

func (*TaskFinished) String

func (x *TaskFinished) String() string

type TrafficSummary

type TrafficSummary struct {
	Id            int32  `protobuf:"fixed32,2,opt,name=Id,proto3" json:"Id,omitempty"`
	Sent          uint32 `protobuf:"fixed32,11,opt,name=Sent,proto3" json:"Sent,omitempty"`
	Relayed       uint32 `protobuf:"fixed32,12,opt,name=Relayed,proto3" json:"Relayed,omitempty"`
	Received      uint32 `protobuf:"fixed32,13,opt,name=Received,proto3" json:"Received,omitempty"`
	TotalSent     int64  `protobuf:"fixed64,14,opt,name=TotalSent,proto3" json:"TotalSent,omitempty"`
	TotalReceived int64  `protobuf:"fixed64,15,opt,name=TotalReceived,proto3" json:"TotalReceived,omitempty"`
	// contains filtered or unexported fields
}

func (*TrafficSummary) Descriptor deprecated

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

Deprecated: Use TrafficSummary.ProtoReflect.Descriptor instead.

func (*TrafficSummary) GetId

func (x *TrafficSummary) GetId() int32

func (*TrafficSummary) GetReceived

func (x *TrafficSummary) GetReceived() uint32

func (*TrafficSummary) GetRelayed

func (x *TrafficSummary) GetRelayed() uint32

func (*TrafficSummary) GetSent

func (x *TrafficSummary) GetSent() uint32

func (*TrafficSummary) GetTotalReceived

func (x *TrafficSummary) GetTotalReceived() int64

func (*TrafficSummary) GetTotalSent

func (x *TrafficSummary) GetTotalSent() int64

func (*TrafficSummary) ProtoMessage

func (*TrafficSummary) ProtoMessage()

func (*TrafficSummary) ProtoReflect

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

func (*TrafficSummary) Reset

func (x *TrafficSummary) Reset()

func (*TrafficSummary) String

func (x *TrafficSummary) String() string

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL