pkg

type Agent struct {
}

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

type Log interface {
	Debug(v ...interface{})
	Debugf(format string, v ...interface{})
	Info(v ...interface{})
	Infof(format string, v ...interface{})
	Warn(v ...interface{})
	Warnf(format string, v ...interface{})
	Error(v ...interface{})
	Errorf(format string, v ...interface{})
}

type Message struct {
	// Sender digital twin ID
	Sender uint64 `json:"sender"`
	// Receiver digital twin ID
	Receiver uint64 `json:"receiver"`
	// Topic of the message
	Topic string `json:"topic"`
	// TTL of the message, after this time, the message should be flushed from
	// receiving and sending buffers.
	TTL time.Time `json:"ttl"`
	// Payload of the message
	Payload []byte `json:"payload"`
}

type NOOPLogger struct{}

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

type PeerStore interface {
	// PeerID currently associated with this digital twin
	PeerID(dtid uint64) (string, error)
	// PublicKey of this digital twin
	PublicKey(dtid uint64) ([PublicKeySize]byte, error)
	// SetPeerId of this digital twin. This should override a cached peer ID of
	// a digital twin. NOTE: because the transport does not validate keys of remote
	// digital twins, a malicous entity could emulate a peer ID and poison the peer
	// cache. As such, this should only be used in development.
	SetPeerID(dtid uint64, pid string)
}

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