adnl

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

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

type CustomMessageHandler func(msg *MessageCustom) error

type DisconnectHandler func(addr string, key ed25519.PublicKey)

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

type MessageAnswer struct {
	ID   []byte `tl:"int256"`
	Data any    `tl:"bytes struct boxed"`
}

type MessageConfirmChannel struct {
	Key     []byte `tl:"int256"`
	PeerKey []byte `tl:"int256"`
	Date    int32  `tl:"int"`
}

type MessageCreateChannel struct {
	Key  []byte `tl:"int256"`
	Date int32  `tl:"int"`
}

type MessageCustom struct {
	Data any `tl:"bytes struct boxed"`
}

type MessageNop struct{}

type MessagePart struct {
	Hash      []byte `tl:"int256"`
	TotalSize int32  `tl:"int"`
	Offset    int32  `tl:"int"`
	Data      []byte `tl:"bytes"`
}

type MessagePing struct {
	Value int64 `tl:"long"`
}

type MessagePong struct {
	Value int64 `tl:"long"`
}

type MessageQuery struct {
	ID   []byte `tl:"int256"`
	Data any    `tl:"bytes struct boxed"`
}

type MessageReinit struct {
	Date int32 `tl:"int"`
}

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

type NetManager interface {
	Free(p *UDPPacket)
	GetReaderChan(gate *Gateway) <-chan *UDPPacket
	InitConnection(gate *Gateway, addr string) error
	CloseConnection(gate *Gateway)
	WritePacket(gate *Gateway, p []byte, addr net.Addr) (n int, err error)
	Close()
}

type Node struct {
	ID        any           `tl:"struct boxed [pub.ed25519,pub.aes]"`
	AddrList  *address.List `tl:"struct"`
	Version   int32         `tl:"int"`
	Signature []byte        `tl:"bytes"`
}

type PacketContent struct {
	Rand1                       []byte
	From                        *keys.PublicKeyED25519
	FromIDShort                 []byte
	Messages                    []any
	Address                     *address.List
	PriorityAddress             *address.List
	Seqno                       *int64
	ConfirmSeqno                *int64
	RecvAddrListVersion         *int32
	RecvPriorityAddrListVersion *int32
	ReinitDate                  *int32
	DstReinitDate               *int32
	Signature                   []byte
	Rand2                       []byte
	// contains filtered or unexported fields
}

type PacketWriter interface {
	Write(b []byte, deadline time.Time) (n int, err error)
	Close() error
}

type Peer interface {
	SetCustomMessageHandler(handler func(msg *MessageCustom) error)
	SetQueryHandler(handler func(msg *MessageQuery) error)
	GetDisconnectHandler() func(addr string, key ed25519.PublicKey)
	SetDisconnectHandler(handler func(addr string, key ed25519.PublicKey))
	SendCustomMessage(ctx context.Context, req tl.Serializable) error
	SendNop(ctx context.Context) error
	Query(ctx context.Context, req, result tl.Serializable) error
	Answer(ctx context.Context, queryID []byte, result tl.Serializable) error
	Ping(ctx context.Context) (time.Duration, error)
	GetQueryHandler() func(msg *MessageQuery) error
	GetCloserCtx() context.Context
	SetAddresses(addresses address.List)
	RemoteAddr() string
	GetID() []byte
	GetPubKey() ed25519.PublicKey
	Stats() PeerStats
	Reinit()
	Close()
}

type PeerChannelState uint8

type PeerChannelStats struct {
	State PeerChannelState
}

type PeerInboundStats struct {
	Packets          uint64
	Bytes            uint64
	ProcessingErrors uint64
	LastPacketAt     time.Time
	LastErrorAt      time.Time
}

type PeerOutboundStats struct {
	Packets      uint64
	Bytes        uint64
	WriteErrors  uint64
	LastPacketAt time.Time
	LastErrorAt  time.Time
}

type PeerReinitializationStats struct {
	LocalEpoch           int32
	PeerEpoch            int32
	PeerEvents           uint64
	RootRecoveryAttempts uint64
	LastPeerEventAt      time.Time
	LastRootRecoveryAt   time.Time
}

type PeerSequenceStats struct {
	// LocalSeqno is the highest locally allocated ADNL sequence number.
	LocalSeqno int64
	// PeerSeqno is the highest ADNL sequence number received from the peer.
	PeerSeqno int64
	// ConfirmedByPeerSeqno is the highest local sequence number reported by the peer.
	ConfirmedByPeerSeqno int64
}

type PeerStats struct {
	CapturedAt       time.Time
	CreatedAt        time.Time
	Closed           bool
	Channel          PeerChannelStats
	Inbound          PeerInboundStats
	Outbound         PeerOutboundStats
	Sequences        PeerSequenceStats
	Reinitialization PeerReinitializationStats
}

type QueryHandler func(msg *MessageQuery) error

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

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

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