Documentation ¶
Index ¶
- Constants
- Variables
- func SendMiniChordMessage(conn net.Conn, message *MiniChord) (err error)
- type Deregistration
- func (*Deregistration) Descriptor() ([]byte, []int)deprecated
- func (x *Deregistration) GetAddress() string
- func (x *Deregistration) GetId() int32
- func (*Deregistration) ProtoMessage()
- func (x *Deregistration) ProtoReflect() protoreflect.Message
- func (x *Deregistration) Reset()
- func (x *Deregistration) String() string
- type DeregistrationResponse
- func (*DeregistrationResponse) Descriptor() ([]byte, []int)deprecated
- func (x *DeregistrationResponse) GetInfo() string
- func (x *DeregistrationResponse) GetResult() int32
- func (*DeregistrationResponse) ProtoMessage()
- func (x *DeregistrationResponse) ProtoReflect() protoreflect.Message
- func (x *DeregistrationResponse) Reset()
- func (x *DeregistrationResponse) String() string
- type InitiateTask
- type MiniChord
- func (*MiniChord) Descriptor() ([]byte, []int)deprecated
- func (x *MiniChord) GetDeregistration() *Deregistration
- func (x *MiniChord) GetDeregistrationResponse() *DeregistrationResponse
- func (x *MiniChord) GetInitiateTask() *InitiateTask
- func (m *MiniChord) GetMessage() isMiniChord_Message
- func (x *MiniChord) GetNodeData() *NodeData
- func (x *MiniChord) GetNodeRegistry() *NodeRegistry
- func (x *MiniChord) GetNodeRegistryResponse() *NodeRegistryResponse
- func (x *MiniChord) GetRegistration() *Registration
- func (x *MiniChord) GetRegistrationResponse() *RegistrationResponse
- func (x *MiniChord) GetReportTrafficSummary() *TrafficSummary
- func (x *MiniChord) GetRequestTrafficSummary() *RequestTrafficSummary
- func (x *MiniChord) GetTaskFinished() *TaskFinished
- func (*MiniChord) ProtoMessage()
- func (x *MiniChord) ProtoReflect() protoreflect.Message
- func (x *MiniChord) Reset()
- func (x *MiniChord) String() string
- type MiniChord_Deregistration
- type MiniChord_DeregistrationResponse
- type MiniChord_InitiateTask
- type MiniChord_NodeData
- type MiniChord_NodeRegistry
- type MiniChord_NodeRegistryResponse
- type MiniChord_Registration
- type MiniChord_RegistrationResponse
- type MiniChord_ReportTrafficSummary
- type MiniChord_RequestTrafficSummary
- type MiniChord_TaskFinished
- type NodeData
- func (*NodeData) Descriptor() ([]byte, []int)deprecated
- func (x *NodeData) GetDestination() int32
- func (x *NodeData) GetHops() uint32
- func (x *NodeData) GetPayload() int32
- func (x *NodeData) GetSource() int32
- func (x *NodeData) GetTrace() []int32
- func (*NodeData) ProtoMessage()
- func (x *NodeData) ProtoReflect() protoreflect.Message
- func (x *NodeData) Reset()
- func (x *NodeData) String() string
- type NodeRegistry
- func (*NodeRegistry) Descriptor() ([]byte, []int)deprecated
- func (x *NodeRegistry) GetIds() []int32
- func (x *NodeRegistry) GetNR() uint32
- func (x *NodeRegistry) GetNoIds() uint32
- func (x *NodeRegistry) GetPeers() []*Deregistration
- func (*NodeRegistry) ProtoMessage()
- func (x *NodeRegistry) ProtoReflect() protoreflect.Message
- func (x *NodeRegistry) Reset()
- func (x *NodeRegistry) String() string
- type NodeRegistryResponse
- func (*NodeRegistryResponse) Descriptor() ([]byte, []int)deprecated
- func (x *NodeRegistryResponse) GetInfo() string
- func (x *NodeRegistryResponse) GetResult() uint32
- func (*NodeRegistryResponse) ProtoMessage()
- func (x *NodeRegistryResponse) ProtoReflect() protoreflect.Message
- func (x *NodeRegistryResponse) Reset()
- func (x *NodeRegistryResponse) String() string
- type Registration
- type RegistrationResponse
- func (*RegistrationResponse) Descriptor() ([]byte, []int)deprecated
- func (x *RegistrationResponse) GetInfo() string
- func (x *RegistrationResponse) GetResult() int32
- func (*RegistrationResponse) ProtoMessage()
- func (x *RegistrationResponse) ProtoReflect() protoreflect.Message
- func (x *RegistrationResponse) Reset()
- func (x *RegistrationResponse) String() string
- type RequestTrafficSummary
- type TaskFinished
- func (*TaskFinished) Descriptor() ([]byte, []int)deprecated
- func (x *TaskFinished) GetAddress() string
- func (x *TaskFinished) GetId() int32
- func (*TaskFinished) ProtoMessage()
- func (x *TaskFinished) ProtoReflect() protoreflect.Message
- func (x *TaskFinished) Reset()
- func (x *TaskFinished) String() string
- type TrafficSummary
- func (*TrafficSummary) Descriptor() ([]byte, []int)deprecated
- func (x *TrafficSummary) GetId() int32
- func (x *TrafficSummary) GetReceived() uint32
- func (x *TrafficSummary) GetRelayed() uint32
- func (x *TrafficSummary) GetSent() uint32
- func (x *TrafficSummary) GetTotalReceived() int64
- func (x *TrafficSummary) GetTotalSent() int64
- func (*TrafficSummary) ProtoMessage()
- func (x *TrafficSummary) ProtoReflect() protoreflect.Message
- func (x *TrafficSummary) Reset()
- func (x *TrafficSummary) String() string
Constants ¶
const I64SIZE = 8
Variables ¶
var File_minichord_proto protoreflect.FileDescriptor
Functions ¶
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 ¶
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) 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 (*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
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) GetDestination ¶
func (*NodeData) GetPayload ¶
func (*NodeData) ProtoMessage ¶
func (*NodeData) ProtoMessage()
func (*NodeData) ProtoReflect ¶
func (x *NodeData) ProtoReflect() protoreflect.Message
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