process

Documentation

Index

• type Client
  • func (c *Client) CloseInput(ctx context.Context, inputID InputID) error
  • func (c *Client) CloseOutput(ctx context.Context, outputID OutputID) error
  • func (c *Client) GetRecoderStats(ctx context.Context, recoderID RecoderID) (*RecoderStats, error)
  • func (c *Client) NewInputFromURL(ctx context.Context, url string, authKey string, config InputConfig) (InputID, error)
  • func (c *Client) NewOutputFromURL(ctx context.Context, url string, streamKey string, config OutputConfig) (OutputID, error)
  • func (c *Client) NewRecoder(ctx context.Context, config RecoderConfig) (RecoderID, error)
  • func (c *Client) RecodingEndedChan(ctx context.Context, recoderID RecoderID) (<-chan struct{}, error)
  • func (c *Client) StartRecoding(ctx context.Context, recoderID RecoderID, inputID InputID, outputID OutputID) error
• type InputConfig
• type InputID
• type OutputConfig
• type OutputID
• type Recoder
  • func Run(ctx context.Context) (*Recoder, error)
  • func (r *Recoder) Kill() error
• type RecoderConfig
• type RecoderID
• type RecoderStats
• type ReturnedData

Types

type Client

type Client struct{}

func (*Client) CloseInput

func (c *Client) CloseInput(
	ctx context.Context,
	inputID InputID,
) error

func (*Client) CloseOutput

func (c *Client) CloseOutput(
	ctx context.Context,
	outputID OutputID,
) error

func (*Client) GetRecoderStats

func (c *Client) GetRecoderStats(
	ctx context.Context,
	recoderID RecoderID,
) (*RecoderStats, error)

func (*Client) NewInputFromURL

func (c *Client) NewInputFromURL(
	ctx context.Context,
	url string,
	authKey string,
	config InputConfig,
) (InputID, error)

func (*Client) NewOutputFromURL

func (c *Client) NewOutputFromURL(
	ctx context.Context,
	url string,
	streamKey string,
	config OutputConfig,
) (OutputID, error)

func (*Client) NewRecoder

func (c *Client) NewRecoder(
	ctx context.Context,
	config RecoderConfig,
) (RecoderID, error)

func (*Client) RecodingEndedChan

func (c *Client) RecodingEndedChan(
	ctx context.Context,
	recoderID RecoderID,
) (<-chan struct{}, error)

func (*Client) StartRecoding

func (c *Client) StartRecoding(
	ctx context.Context,
	recoderID RecoderID,
	inputID InputID,
	outputID OutputID,
) error

type InputConfig

type InputConfig = recoder.InputConfig

type InputID

type InputID uint64

type OutputConfig

type OutputConfig = recoder.OutputConfig

type OutputID

type OutputID uint64

type Recoder

type Recoder struct {
	*Client
}

func Run

func Run(
	ctx context.Context,
) (*Recoder, error)

func (*Recoder) Kill

func (r *Recoder) Kill() error

type RecoderConfig

type RecoderConfig = recoder.Config

type RecoderID

type RecoderID uint64

type RecoderStats

type RecoderStats = recoder.Stats

type ReturnedData

type ReturnedData struct {
	ListenAddr string
}