relayHandler

Documentation

Index

• Variables
• type MessageChan
• type RelaySession
  • func NewSession(ctx context.Context, ip string) RelaySession
  • func (s *RelaySession) Broadcast(data []json.RawMessage)
  • func (s *RelaySession) Init(r []string)
  • func (s *RelaySession) Wait()
• type SessionRelays

Variables

var UserAgent string = "bostr2 (https://codeberg.org/Yonle/bostr2) - nostr relay proxy aggregator"

Types

type MessageChan

type MessageChan chan []json.RawMessage

type RelaySession

type RelaySession struct {
	UpEVENT     MessageChan
	UpEOSE      MessageChan
	UpConnected chan *websocket.Conn

	HowManyRelaysAreConnected int
	// contains filtered or unexported fields
}

func NewSession

func NewSession(ctx context.Context, ip string) RelaySession

func (*RelaySession) Broadcast

func (s *RelaySession) Broadcast(data []json.RawMessage)

func (*RelaySession) Init

func (s *RelaySession) Init(r []string)

func (*RelaySession) Wait

func (s *RelaySession) Wait()

type SessionRelays

type SessionRelays map[*websocket.Conn]struct{}