snowflake_client

Mar 18, 2024

Changes in this version

type ClientConfig

+ SQSCredsStr string

Feb 5, 2024

Changes in this version

type ClientConfig

+ SQSAccessKeyID string

+ SQSQueueURL string

+ SQSSecretKey string

Nov 20, 2023

Changes in this version

type ClientConfig

+ CommunicationProxy *url.URL

type WebRTCDialer

+ func NewWebRTCDialerWithEventsAndProxy(broker *BrokerChannel, iceServers []webrtc.ICEServer, max int, ...) *WebRTCDialer

type WebRTCPeer

+ func NewWebRTCPeerWithEventsAndProxy(config *webrtc.Configuration, broker *BrokerChannel, ...) (*WebRTCPeer, error)

Oct 16, 2023

Changes in this version

type ClientConfig

+ FrontDomains []string

Jun 19, 2023

Changes in this version

+ const DataChannelTimeout

+ const LogTimeInterval

+ const ReconnectTimeout

+ const SnowflakeTimeout

+ const StreamSize

+ const WindowSize

+ type BrokerChannel struct

+ BridgeFingerprint string

+ Rendezvous RendezvousMethod

+ func (bc *BrokerChannel) Negotiate(offer *webrtc.SessionDescription) (*webrtc.SessionDescription, error)

+ func (bc *BrokerChannel) SetNATType(NATType string)

+ type ClientConfig struct

+ AmpCacheURL string

+ BridgeFingerprint string

+ BrokerURL string

+ FrontDomain string

+ ICEAddresses []string

+ KeepLocalAddresses bool

+ Max int

+ UTLSClientID string

+ UTLSRemoveSNI bool

+ type Peers struct

+ func NewPeers(tongue Tongue) (*Peers, error)

+ func (p *Peers) Collect() (*WebRTCPeer, error)

+ func (p *Peers) Count() int

+ func (p *Peers) End()

+ func (p *Peers) Melted() <-chan struct{}

+ func (p *Peers) Pop() *WebRTCPeer

+ type RendezvousMethod interface

+ Exchange func([]byte) ([]byte, error)

+ type SnowflakeCollector interface

+ Collect func() (*WebRTCPeer, error)

+ Melted func() <-chan struct{}

+ Pop func() *WebRTCPeer

+ type SnowflakeConn struct

+ func (conn *SnowflakeConn) Close() error

+ type Tongue interface

+ Catch func() (*WebRTCPeer, error)

+ GetMax func() int

+ type Transport struct

+ func NewSnowflakeClient(config ClientConfig) (*Transport, error)

+ func (t *Transport) AddSnowflakeEventListener(receiver event.SnowflakeEventReceiver)

+ func (t *Transport) Dial() (net.Conn, error)

+ func (t *Transport) RemoveSnowflakeEventListener(receiver event.SnowflakeEventReceiver)

+ func (t *Transport) SetRendezvousMethod(r RendezvousMethod)

+ type WebRTCDialer struct

+ func NewWebRTCDialer(broker *BrokerChannel, iceServers []webrtc.ICEServer, max int) *WebRTCDialer

+ func NewWebRTCDialerWithEvents(broker *BrokerChannel, iceServers []webrtc.ICEServer, max int, ...) *WebRTCDialer

+ func (w WebRTCDialer) Catch() (*WebRTCPeer, error)

+ func (w WebRTCDialer) GetMax() int

+ type WebRTCPeer struct

+ func NewWebRTCPeer(config *webrtc.Configuration, broker *BrokerChannel) (*WebRTCPeer, error)

+ func NewWebRTCPeerWithEvents(config *webrtc.Configuration, broker *BrokerChannel, ...) (*WebRTCPeer, error)

+ func (c *WebRTCPeer) Close() error

+ func (c *WebRTCPeer) Closed() bool

+ func (c *WebRTCPeer) Read(b []byte) (int, error)

+ func (c *WebRTCPeer) Write(b []byte) (int, error)