node

Nov 8, 2024

Changes in this version

+ type LastMessage struct

+ Update chan *domain.Message

+ func NewLastMessage() *LastMessage

+ func (m *LastMessage) Get() *domain.Message

+ func (m *LastMessage) ListenUpdates()

+ type Option func(*Options)

+ func WithBitSize(size int) Option

+ func WithClipboardScanDelay(delay time.Duration) Option

+ func WithDiscovering(opt DiscoverOptions) Option

+ func WithKeepAlive(duration time.Duration) Option

+ func WithNotifier(notifier notification.Notifier) Option

+ func WithPublicPort(port int) Option

+ func WithWriteTimeout(timeout time.Duration) Option

type Options

+ func NewOptions(opts ...Option) *Options

+ type PeerOption func(*Peer)

+ func WithCipher(cipher *encrypter.Cipher) PeerOption

+ func WithConn(conn net.Conn) PeerOption

+ func WithLocalClipboard(updates Channel) PeerOption

+ func WithMetaData(meta domain.MetaData) PeerOption

Oct 13, 2024

Changes in this version

+ type DiscoverOptions struct

+ Delay time.Duration

+ Enable bool

+ MaxPeers int

type Options

+ Discovering DiscoverOptions

Aug 17, 2024

Changes in this version

type Node

+ func (n *Node) Notify(message string, v ...any)

type Options

+ Notifier notification.Notifier

Jul 29, 2024

Changes in this version

+ type Options struct

+ BitSize uint16

+ ClipboardScanDelay time.Duration

+ KeepAlive time.Duration

+ Metadata *data.MetaData

+ PublicPort uint16

+ WriteTimeout time.Duration

type Peer

+ func (p *Peer) MetaData() *data.MetaData

+ func (p *Peer) Signer() crypto.Signer

Apr 24, 2024

Changes in this version

+ const DataLength

+ var ErrAlreadyConnected = errors.New("already connected")

+ type Channel chan *data.Message

+ type Node struct

+ func New(clipboard clipboard.Manager, peers *Storage, localClipboard Channel, ...) *Node

+ func (n *Node) Broadcast(msg *data.Message, ignore UniqueID)

+ func (n *Node) ConnectTo(addr string) error

+ func (n *Node) Metadata() *types.Device

+ func (n *Node) MonitorBuffer()

+ func (n *Node) Start() error

+ type Peer struct

+ func AcquirePeer(conn net.Conn, addr netip.AddrPort, id *types.Device, updates Channel, ...) *Peer

+ func (p *Peer) Addr() netip.AddrPort

+ func (p *Peer) Close() error

+ func (p *Peer) Conn() net.Conn

+ func (p *Peer) Device() *types.Device

+ func (p *Peer) Receive(last *data.LastMessage)

+ func (p *Peer) Release()

+ func (p *Peer) String() string

+ func (p *Peer) Updates() Channel

+ type Storage = storage.SyncMap[UniqueID, *Peer]

+ type UniqueID = string