campfire

Aug 14, 2023

Changes in this version

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

+ func MustGeneratePSK() []byte

+ type CampfireChannel interface

+ Accept func() (io.ReadWriteCloser, error)

+ Close func() error

+ Errors func() <-chan error

+ Expired func() <-chan struct{}

+ Opened func() bool

+ type CampfireURI struct

+ Fingerprint string

+ PSK []byte

+ RemoteHosts []string

+ RemotePorts []string

+ StunHosts []string

+ StunPorts []string

+ TURNPassword string

+ TURNServers []string

+ TURNUsername string

+ func ParseCampfireURI(rawURL string) (*CampfireURI, error)

+ func (c *CampfireURI) EncodeURI() string

Aug 12, 2023

Changes in this version

type CampFire

+ Expired func() <-chan struct{}

Aug 11, 2023

Changes in this version

+ var ErrClosed = net.ErrClosed

+ func JoinTURN(ctx context.Context, opts Options) (io.ReadWriteCloser, error)

type CampFire

+ func JoinViaRoom(ctx context.Context, room WaitingRoom) CampFire

+ func Wait(ctx context.Context, opts Options) (CampFire, error)

+ func WaitICE(ctx context.Context, opts Options) (CampFire, error)

+ func WaitTURN(ctx context.Context, opts Options) (CampFire, error)

type Location

+ LocalSecret string

+ PSK []byte

+ RemoteSecret string

+ func (l *Location) LocalPwd() string

+ func (l *Location) LocalUfrag() string

+ func (l *Location) RemotePwd() string

+ func (l *Location) RemoteUfrag() string

+ func (l *Location) SessionID() int

+ func (l *Location) TURNSessionID() string

Aug 8, 2023

Changes in this version

+ const PSKSize

+ const Protocol

+ var Now = time.Now

+ func GetDefaultTURNServers() []string

+ type CampFire struct

+ func Join(ctx context.Context, room WaitingRoom) *CampFire

+ func (cf *CampFire) Accept() (datachannel.ReadWriteCloser, error)

+ func (cf *CampFire) Close() error

+ func (cf *CampFire) Errors() <-chan error

+ func (cf *CampFire) Ready() <-chan struct{}

+ type ICEFire struct

+ func JoinICE(ctx context.Context, opts Options) (*ICEFire, error)

+ func (cf *ICEFire) Accept(ctx context.Context) (*ice.Conn, error)

+ func (cf *ICEFire) Close() error

+ func (cf *ICEFire) Dial(ctx context.Context) (*ice.Conn, error)

+ func (cf *ICEFire) Ready() <-chan struct{}

+ type Location struct

+ ExpiresAt time.Time

+ Secret string

+ TURNServer string

+ func Find(psk []byte, turnServers []string) (*Location, error)

+ func (l *Location) Expired() <-chan struct{}

+ type Message struct

+ Candidate string

+ SDP string

+ Type MessageType

+ func NewCandidateMessage(candidate string) Message

+ func NewSDPMessage(sdp webrtc.SessionDescription) (Message, error)

+ func (m Message) UnmarshalSDP() (webrtc.SessionDescription, error)

+ type MessageType int

+ const CandidateMessageType

+ const SDPMessageType

+ type Options struct

+ PSK []byte

+ TURNServers []string

+ type Stream interface

+ Close func() error

+ PeerID func() string

+ Receive func() (Message, error)

+ SendCandidate func(candidate string) error

+ SendOffer func(offer webrtc.SessionDescription) error

+ type WaitingRoom interface

+ Close func() error

+ Connections func() <-chan Stream

+ Errors func() <-chan error

+ Location func() *Location

+ Peers func() <-chan Stream

+ func NewWebmeshWaitingRoom(ctx context.Context, campfireServer string, opts Options) (WaitingRoom, error)