connections

Apr 20, 2023

Changes in this version

+ type DefaultEngineHooks struct

+ func (deh DefaultEngineHooks) SendPeerMessage(connection tapir.Connection, message []byte) error

+ type EngineHooks interface

+ SendPeerMessage func(connection tapir.Connection, message []byte) error

type PeerApp

+ OnSendMessage func(connection tapir.Connection, message []byte) error

Dec 4, 2022

Changes in this version

+ const TorMaxPendingConns

Nov 30, 2022

Changes in this version

+ func MakePayment(tokenServiceOnion string, tokenService *privacypass.TokenServer, ...) error

type TokenBoardHandler

+ PostingFailed func(server string, sig []byte)

type TokenManager

+ func NewTokenManager() *TokenManager

+ func (tm *TokenManager) StoreNewTokens(tokens []*privacypass.Token)

Sep 7, 2022

Changes in this version

+ type TokenBoardHandler interface

+ FetchToken func(tokenService string) (*privacypass.Token, int, error)

+ GroupMessageHandler func(server string, gm *groups.EncryptedGroupMessage)

+ NewTokenHandler func(tokenService string, tokens []*privacypass.Token)

+ ServerAuthedHandler func(server string)

+ ServerClosedHandler func(server string)

+ ServerSyncedHandler func(server string)

+ type TokenManager struct

+ func (tm *TokenManager) FetchToken() (*privacypass.Token, int, error)

+ func (tm *TokenManager) NewTokens(tokens []*privacypass.Token)

+ func (tm *TokenManager) NumTokens() int

Jan 26, 2022

Changes in this version

+ const Version1

+ const Version2

Nov 12, 2020

Changes in this version

type PeerApp

+ IsAllowed func(string) bool

Sep 28, 2020

Changes in this version

+ func NewTokenBoardClient(acn connectivity.ACN, Y *ristretto255.Element, tokenServiceOnion string, ...) tapir.Application

+ type TokenBoardClient struct

+ func (ta *TokenBoardClient) Init(connection tapir.Connection)

+ func (ta *TokenBoardClient) Listen()

+ func (ta *TokenBoardClient) MakePayment()

+ func (ta *TokenBoardClient) NewInstance() tapir.Application

+ func (ta *TokenBoardClient) NextToken(data []byte, hostname string) (privacypass.SpentToken, error)

+ func (ta *TokenBoardClient) Post(ct []byte, sig []byte) bool

+ func (ta *TokenBoardClient) PurchaseTokens()

+ func (ta *TokenBoardClient) Replay()

Jun 16, 2020

Changes in this version

type PeerApp

+ IsApproved func(string) bool

Mar 27, 2020

Changes in this version

type PeerApp

+ RetValHandler func(string, []byte, []byte)

Aug 14, 2019

Changes in this version

+ var ConnectionStateName = []string

+ var ConnectionStateToType = map[string]ConnectionState

+ type ConnectionState int

+ const AUTHENTICATED

+ const CONNECTED

+ const CONNECTING

+ const DISCONNECTED

+ const FAILED

+ const KILLED

+ const SYNCED

+ type Engine interface

+ ACN func() connectivity.ACN

+ EventManager func() event.Manager

+ Shutdown func()

+ func NewProtocolEngine(identity primitives.Identity, privateKey ed25519.PrivateKey, ...) Engine

+ type Manager struct

+ func NewConnectionsManager(acn connectivity.ACN) *Manager

+ func (m *Manager) AttemptReconnections()

+ func (m *Manager) GetPeerServerConnectionForOnion(host string) (psc *PeerServerConnection)

+ func (m *Manager) ManageServerConnection(host string, engine Engine, ...)

+ func (m *Manager) SetServerSynced(onion string)

+ func (m *Manager) Shutdown()

+ type PeerApp struct

+ IsBlocked func(string) bool

+ MessageHandler func(string, string, []byte)

+ OnAcknowledgement func(string, string)

+ OnAuth func(string)

+ OnClose func(string)

+ OnConnecting func(string)

+ func (pa *PeerApp) Init(connection tapir.Connection)

+ func (pa PeerApp) NewInstance() tapir.Application

+ func (pa PeerApp) SendMessage(message PeerMessage)

+ type PeerMessage struct

+ Context string

+ Data []byte

+ ID string

+ type PeerServerConnection struct

+ GroupMessageHandler func(string, *protocol.GroupMessage)

+ Server string

+ func NewPeerServerConnection(engine Engine, serverhostname string) *PeerServerConnection

+ func (psc *PeerServerConnection) Break() error

+ func (psc *PeerServerConnection) Close()

+ func (psc *PeerServerConnection) GetState() ConnectionState

+ func (psc *PeerServerConnection) HandleFetchDone()

+ func (psc *PeerServerConnection) HandleGroupMessage(gm *protocol.GroupMessage)

+ func (psc *PeerServerConnection) Run() error

+ func (psc *PeerServerConnection) SendGroupMessage(gm *protocol.GroupMessage) error

+ func (psc *PeerServerConnection) WaitTilSynced()