autonomous_peer

Documentation

Index

• Constants
• func CreateAddress(addr, id string) string
• type Data
  • func (d *Data) GetData(dataType string) []byte
  • func (d *Data) RegisterDataUpdate(dataType string, update func([]byte))
  • func (d *Data) SetData(dataType string, data []byte)
• type IdRec
• type P2pHost
  • func NewHost(myAddr string, psk []byte) *P2pHost
  • func (h *P2pHost) AddPeers(peerHosts map[string]*IdRec)
  • func (h *P2pHost) Close()
  • func (h *P2pHost) GetAddress() string
  • func (h *P2pHost) GetHostAddress() string
  • func (h *P2pHost) GetID() string
  • func (h *P2pHost) PurgePeer(hostAddr string)
  • func (h *P2pHost) SetDataVersion(dataType string, version *time.Time)

Constants

const (
	API           = "/exchange"
	MAX_MESSAGE   = 1000000 //1M
	MESSAGE_PEERS = "Peers"
	MESSAGE_END   = "End"
)

Functions

func CreateAddress

func CreateAddress(addr, id string) string

Types

type Data

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

func (*Data) GetData

func (d *Data) GetData(dataType string) []byte

GetData for a given dataType Protected by data Mutex

func (*Data) RegisterDataUpdate

func (d *Data) RegisterDataUpdate(dataType string, update func([]byte))

RegisterDataUpdate for a given dataType Protected by data Mutex

func (*Data) SetData

func (d *Data) SetData(dataType string, data []byte)

SetData for a given dataType Protected by data Mutex

type IdRec

type IdRec struct {
	Id      string    `json:"id"`
	Version time.Time `json:"ver"`
}

type P2pHost

type P2pHost struct {
	Data Data
	// contains filtered or unexported fields
}

func NewHost

func NewHost(myAddr string, psk []byte) *P2pHost

func (*P2pHost) AddPeers

func (h *P2pHost) AddPeers(peerHosts map[string]*IdRec)

AddPeers using a map of peers. Protected with host mutex.

func (*P2pHost) Close

func (h *P2pHost) Close()

func (*P2pHost) GetAddress

func (h *P2pHost) GetAddress() string

func (*P2pHost) GetHostAddress

func (h *P2pHost) GetHostAddress() string

func (*P2pHost) GetID

func (h *P2pHost) GetID() string

func (*P2pHost) PurgePeer

func (h *P2pHost) PurgePeer(hostAddr string)

PurgePeer of a given hostAddr. Protected with host mutex.

func (*P2pHost) SetDataVersion

func (h *P2pHost) SetDataVersion(dataType string, version *time.Time)

SetDataVersion for a given dataType. Protected with host mutex.