packet

package
v0.6.1 Latest Latest
Warning

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

 Go to latest Published: Oct 23, 2018 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Overview

Package packet provides network messaging protocol and serialization layer.

Packet can be created with shortcut: 

senderAddr, _ := host.NewAddress("127.0.0.1:1337")
receiverAddr, _ := host.NewAddress("127.0.0.1:1338")

sender := host.NewHost(senderAddr)
receiver := host.NewHost(receiverAddr)

msg := packet.NewPingPacket(sender, receiver)

// do something with packet

Or with builder: 

builder := packet.NewBuilder()

senderAddr, _ := host.NewAddress("127.0.0.1:1337")
receiverAddr, _ := host.NewAddress("127.0.0.1:1338")

sender := host.NewHost(senderAddr)
receiver := host.NewHost(receiverAddr)

msg := builder.
	Sender(sender).
	Receiver(receiver).
	Type(packet.TypeFindHost).
	Request(&packet.RequestDataFindHost{}).
	Build()

// do something with packet

Packet may be serialized: 

msg := &packet.Packet{}
serialized, err := packet.SerializePacket(msg)

if err != nil {
	panic(err.Error())
}

fmt.Println(serialized)

And deserialized therefore: 

var buffer bytes.Buffer

// Fill buffer somewhere

msg, err := packet.DeserializePacket(buffer)

if err != nil {
	panic(err.Error())
}

// do something with packet

Index

Constants

View Source 
const (
	// TypePing is packet type for ping method.
	TypePing packetType = iota + 1
	// TypeStore is packet type for store method.
	TypeStore
	// TypeFindHost is packet type for FindHost method.
	TypeFindHost
	// TypeFindValue is packet type for FindValue method.
	TypeFindValue
	// TypeRPC is packet type for RPC method.
	TypeRPC
	// TypeRelay is packet type for request target to be a relay.
	TypeRelay
	// TypeAuthentication is packet type for authentication between hosts.
	TypeAuthentication
	// TypeCheckOrigin is packet to check originality of some host.
	TypeCheckOrigin
	// TypeObtainIP is packet to get itself IP from another host.
	TypeObtainIP
	// TypeRelayOwnership is packet to say all other hosts that current host have a static IP.
	TypeRelayOwnership
	// TypeKnownOuterHosts is packet to say how much outer hosts current host know.
	TypeKnownOuterHosts
	// TypeCheckNodePriv is packet to check preset node privileges.
	TypeCheckNodePriv
	// TypeCascadeSend is the packet type for the cascade send message feature.
	TypeCascadeSend
	// TypePulse is packet type for the messages received from pulsars.
	TypePulse
	// TypeGetRandomHosts is packet type for the call to get random hosts of the DHT network.
	TypeGetRandomHosts
	// TypeGetNonce is packet to request a nonce to sign it.
	TypeGetNonce
	// TypeCheckSignedNonce is packet to check a signed nonce.
	TypeCheckSignedNonce
	// TypeExchangeUnsyncLists is packet type to exchange unsync lists during consensus
	TypeExchangeUnsyncLists
	// TypeExchangeUnsyncHash is packet type to exchange hash of merged unsync lists during consensus
	TypeExchangeUnsyncHash
	// TypeDisconnect is packet to disconnect from active list.
	TypeDisconnect
)
View Source 
const (
	// Unknown - unknown command.
	Unknown = CommandType(iota + 1)
	// StartRelay - command start relay.
	StartRelay
	// StopRelay - command stop relay.
	StopRelay
	// BeginAuthentication - begin authentication.
	BeginAuthentication
	// RevokeAuthentication - revoke authentication.
	RevokeAuthentication
)
View Source 
const (
	// Error - some error, see error string.
	Error = CheckNodePrivState(iota + 1)
	// Confirmed - state confirmed.
	Confirmed
	// Declined - state declined.
	Declined
)

Variables

This section is empty.

Functions

func SerializePacket 

func SerializePacket(q *Packet) ([]byte, error)

SerializePacket converts packet to byte slice.

Types

type Builder 

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

Builder allows lazy building of packets. Each operation returns new copy of a builder.

func NewBuilder 

func NewBuilder() Builder

NewBuilder returns empty packet builder.

func (Builder) Build 

func (cb Builder) Build() (packet *Packet)

Build returns configured packet.

func (Builder) Error 

func (cb Builder) Error(err error) Builder

Error adds error description to packet.

func (Builder) Receiver 

func (cb Builder) Receiver(host *host.Host) Builder

Receiver sets packet receiver.

func (Builder) Request 

func (cb Builder) Request(request interface{}) Builder

Request adds request data to packet.

func (Builder) Response 

func (cb Builder) Response(response interface{}) Builder

Response adds response data to packet

func (Builder) Sender 

func (cb Builder) Sender(host *host.Host) Builder

Sender sets packet sender.

func (Builder) Type 

func (cb Builder) Type(packetType packetType) Builder

Type sets packet type.

type CheckNodePrivState added in v0.0.5 

type CheckNodePrivState int

CheckNodePrivState - state of check node privileges request.

type CommandType 

type CommandType int

CommandType - type for commands.

type Packet 

type Packet struct {
	Sender        *host.Host
	Receiver      *host.Host
	Type          packetType
	RequestID     RequestID
	RemoteAddress string

	Data       interface{}
	Error      error
	IsResponse bool
}

Packet is DHT packet object.

func DeserializePacket 

func DeserializePacket(conn io.Reader) (*Packet, error)

DeserializePacket reads packet from io.Reader.

func NewPingPacket 

func NewPingPacket(sender, receiver *host.Host) *Packet

NewPingPacket can be used as a shortcut for creating ping packets instead of packet Builder.

func (*Packet) IsForMe 

func (m *Packet) IsForMe(origin host.Origin) bool

IsForMe checks if packet is addressed to our host.

func (*Packet) IsValid 

func (m *Packet) IsValid() (valid bool)

IsValid checks if packet data is a valid structure for current packet type.

type RequestAuthentication added in v0.5.0 

type RequestAuthentication struct {
	Command CommandType
}

RequestAuthentication is data for authentication.

type RequestCascadeSend added in v0.2.0 

type RequestCascadeSend struct {
	RPC  RequestDataRPC
	Data core.Cascade
}

RequestCascadeSend is data for cascade sending feature

type RequestCheckNodePriv added in v0.0.5 

type RequestCheckNodePriv struct {
	RoleKey string
}

RequestCheckNodePriv is data for check node privileges.

type RequestCheckOrigin 

type RequestCheckOrigin struct {
}

RequestCheckOrigin is data to check originality.

type RequestCheckSignedNonce added in v0.5.0 

type RequestCheckSignedNonce struct {
	Signed    []byte
	NodeID    core.RecordRef
	NodeRoles []core.NodeRole
	Version   string
}

RequestCheckSignedNonce is data to check a signed nonce.

type RequestDataFindHost 

type RequestDataFindHost struct {
	Target []byte
}

RequestDataFindHost is data for FindHost request.

type RequestDataFindValue 

type RequestDataFindValue struct {
	Target []byte
}

RequestDataFindValue is data for FindValue request.

type RequestDataRPC 

type RequestDataRPC struct {
	NodeID core.RecordRef
	Method string
	Args   [][]byte
}

RequestDataRPC is data for RPC request.

type RequestDataStore 

type RequestDataStore struct {
	Data       []byte
	Publishing bool // Whether or not we are the original publisher.
}

RequestDataStore is data for Store request.

type RequestDisconnect added in v0.6.0 

type RequestDisconnect struct {
}

RequestDisconnect is request to disconnect from active list.

type RequestExchangeUnsyncHash added in v0.6.0 

type RequestExchangeUnsyncHash struct {
	SenderID   core.RecordRef
	Pulse      core.PulseNumber
	UnsyncHash []*consensus.NodeUnsyncHash
}

RequestExchangeUnsyncHash is request to exchange hash of merged unsync lists during consensus

type RequestExchangeUnsyncLists added in v0.6.0 

type RequestExchangeUnsyncLists struct {
	SenderID   core.RecordRef
	Pulse      core.PulseNumber
	UnsyncList []*core.ActiveNode
}

RequestExchangeUnsyncLists is request to exchange unsync lists during consensus

type RequestGetNonce added in v0.6.0 

type RequestGetNonce struct {
	NodeID core.RecordRef
}

RequestGetNonce is data to check a public key.

type RequestGetRandomHosts added in v0.3.0 

type RequestGetRandomHosts struct {
	HostsNumber int
}

RequestGetRandomHosts is data for the call that returns random hosts of the DHT network

type RequestID 

type RequestID uint64

RequestID is 64 bit unsigned int request id.

type RequestKnownOuterHosts 

type RequestKnownOuterHosts struct {
	ID         string // origin ID
	OuterHosts int    // number of known outer hosts
}

RequestKnownOuterHosts is data to notify home subnet about known outer hosts.

type RequestObtainIP 

type RequestObtainIP struct {
}

RequestObtainIP is data to obtain a self IP.

type RequestPulse added in v0.2.0 

type RequestPulse struct {
	Pulse core.Pulse
}

RequestPulse is data received from a pulsar

type RequestRelay 

type RequestRelay struct {
	Command CommandType
}

RequestRelay is data for relay request (commands: start/stop relay).

type RequestRelayOwnership 

type RequestRelayOwnership struct {
	Ready bool
}

RequestRelayOwnership is data to notify that current host can be a relay.

type ResponseAuthentication added in v0.5.0 

type ResponseAuthentication struct {
	Success       bool
	AuthUniqueKey []byte
}

ResponseAuthentication is data for authentication request response.

type ResponseCascadeSend added in v0.2.0 

type ResponseCascadeSend struct {
	Success bool
	Error   string
}

ResponseCascadeSend is the response data of a cascade sending call

type ResponseCheckNodePriv added in v0.0.5 

type ResponseCheckNodePriv struct {
	State CheckNodePrivState
	Error string
}

ResponseCheckNodePriv is data for check node privileges response.

type ResponseCheckOrigin 

type ResponseCheckOrigin struct {
	AuthUniqueKey []byte
}

ResponseCheckOrigin is data for check originality request response.

type ResponseCheckSignedNonce added in v0.5.0 

type ResponseCheckSignedNonce struct {
	Error       string
	ActiveNodes []*core.ActiveNode
}

type ResponseDataFindHost 

type ResponseDataFindHost struct {
	Closest []*host.Host
}

ResponseDataFindHost is data for FindHost response.

type ResponseDataFindValue 

type ResponseDataFindValue struct {
	Closest []*host.Host
	Value   []byte
}

ResponseDataFindValue is data for FindValue response.

type ResponseDataRPC 

type ResponseDataRPC struct {
	Success bool
	Result  []byte
	Error   string
}

ResponseDataRPC is data for RPC response.

type ResponseDataStore 

type ResponseDataStore struct {
	Success bool
}

ResponseDataStore is data for Store response.

type ResponseDisconnect added in v0.6.0 

type ResponseDisconnect struct {
	Disconnected bool
	Error        error
}

ResponseDisconnect id data to answer to disconnected node.

type ResponseExchangeUnsyncHash added in v0.6.0 

type ResponseExchangeUnsyncHash struct {
	UnsyncHash []*consensus.NodeUnsyncHash
	Error      string
}

RequestExchangeUnsyncHash is request to exchange hash of merged unsync lists during consensus

type ResponseExchangeUnsyncLists added in v0.6.0 

type ResponseExchangeUnsyncLists struct {
	UnsyncList []*core.ActiveNode
	Error      string
}

RequestExchangeUnsyncLists is request to exchange unsync lists during consensus

type ResponseGetNonce added in v0.6.0 

type ResponseGetNonce struct {
	Nonce []byte
	Error string
}

ResponseGetNonce is data to answer to authorization request.

type ResponseGetRandomHosts added in v0.3.0 

type ResponseGetRandomHosts struct {
	Hosts []host.Host
	Error string
}

ResponseGetRandomHosts is the response containing random hosts of the DHT network

type ResponseKnownOuterHosts 

type ResponseKnownOuterHosts struct {
	ID         string // 	id of host in which more known outer hosts
	OuterHosts int    // number of known outer hosts
}

ResponseKnownOuterHosts is data to answer if origin host know more outer hosts.

type ResponseObtainIP 

type ResponseObtainIP struct {
	IP string
}

ResponseObtainIP is data for get a IP of requesting host.

type ResponsePulse added in v0.2.0 

type ResponsePulse struct {
	Success bool
	Error   string
}

ResponsePulse is the response for a new pulse from a pulsar

type ResponseRelay 

type ResponseRelay struct {
	State relay.State
}

ResponseRelay is data for relay request response.

type ResponseRelayOwnership 

type ResponseRelayOwnership struct {
	Accepted bool
}

ResponseRelayOwnership is data to response to relay ownership request.

Source Files

View all Source files

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.