messaging

Documentation

Index

• type Conn
  • func (j *Conn) Close() (err error)
  • func (c *Conn) Context() context.Context
  • func (j *Conn) Credentials(ctx context.Context) (*nethernet.Credentials, error)
  • func (j *Conn) MessagingID() uuid.UUID
  • func (j *Conn) NetworkID() string
  • func (c *Conn) Notify(signals chan<- *nethernet.Signal) (stop func())
  • func (j *Conn) PongData([]byte)
  • func (c *Conn) ReadSignal() (*nethernet.Signal, error)
  • func (j *Conn) Signal(ctx context.Context, signal *nethernet.Signal) error
• type Dialer
  • func (d Dialer) DialContext(ctx context.Context, mct *service.Token) (*Conn, error)
• type Environment
  • func (e *Environment) ServiceName() string

Types

type Conn

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

func (*Conn) Close

func (j *Conn) Close() (err error)

func (*Conn) Context

func (c *Conn) Context() context.Context

func (*Conn) Credentials

func (j *Conn) Credentials(ctx context.Context) (*nethernet.Credentials, error)

func (*Conn) MessagingID

func (j *Conn) MessagingID() uuid.UUID

func (*Conn) NetworkID

func (j *Conn) NetworkID() string

func (*Conn) Notify

func (c *Conn) Notify(signals chan<- *nethernet.Signal) (stop func())

func (*Conn) PongData

func (j *Conn) PongData([]byte)

func (*Conn) ReadSignal

func (c *Conn) ReadSignal() (*nethernet.Signal, error)

func (*Conn) Signal

func (j *Conn) Signal(ctx context.Context, signal *nethernet.Signal) error

type Dialer

type Dialer struct {
	Options *websocket.DialOptions
	Log     *slog.Logger
}

func (Dialer) DialContext

func (d Dialer) DialContext(ctx context.Context, mct *service.Token) (*Conn, error)

type Environment

type Environment struct {
	ServiceURI string `json:"serviceUri"`
	StunURI    string `json:"stunUri"`
	TurnURI    string `json:"turnUri"`
}

func (*Environment) ServiceName

func (e *Environment) ServiceName() string