rt

package
v0.0.0-...-ad8d7c7 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 8, 2023 License: AGPL-3.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Client

type Client struct {

	// RTRouterEndpoint is the URL of a public RTRouter
	Endpoint string
	// Key is the secret key to be used for stateful changes
	Key string
	// Needs to be hardcoded for now...
	WHEPEndpoint string
	// contains filtered or unexported fields
}

func New

func New(hostname, endpoint, key, whepEndpoint string) *Client

func (*Client) Close

func (client *Client) Close() error

Likely this needs to tell the orchestrator all URLs for this endpoint are no longer valid

func (*Client) Connect

func (client *Client) Connect() error

Since RTRouter is HTTP, no permanent connection is necessary.

func (*Client) Heartbeat

func (client *Client) Heartbeat(channelID types.ChannelID) error

func (*Client) Name

func (client *Client) Name() string

func (*Client) SetLogger

func (client *Client) SetLogger(log logrus.FieldLogger)

func (*Client) StartStream

func (client *Client) StartStream(channelID types.ChannelID, streamID types.StreamID) error

func (*Client) StopStream

func (client *Client) StopStream(channelID types.ChannelID, streamID types.StreamID) error

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL