streamplayers

Documentation

Index

• type SetupOption
• type SetupOptionDefaultStreamPlayerOptions
• type SetupOptions
  • func (s SetupOptions) Config() setupConfig
• type StreamPlayers
  • func NewStreamPlayers(sp *streamplayer.StreamPlayers, streamServer StreamServer) *StreamPlayers
  • func (s *StreamPlayers) AddStreamPlayer(ctx context.Context, streamID types.StreamID, playerType player.Backend, ...) error
  • func (s *StreamPlayers) GetActiveStreamPlayer(ctx context.Context, streamID types.StreamID) (player.Player, error)
  • func (s *StreamPlayers) GetStreamPlayer(ctx context.Context, streamID types.StreamID) (*types.StreamPlayer, error)
  • func (s *StreamPlayers) Init(ctx context.Context, opts ...types.InitOption) error
  • func (s *StreamPlayers) ListStreamPlayers(ctx context.Context) ([]types.StreamPlayer, error)
  • func (s *StreamPlayers) RemoveStreamPlayer(ctx context.Context, streamID types.StreamID) error
  • func (s *StreamPlayers) SetupStreamPlayers(ctx context.Context, opts ...SetupOption) (_err error)
  • func (s *StreamPlayers) UpdateStreamPlayer(ctx context.Context, streamID types.StreamID, playerType player.Backend, ...) error
• type StreamServer

Types

type SetupOption

type SetupOption interface {
	// contains filtered or unexported methods
}

type SetupOptionDefaultStreamPlayerOptions

type SetupOptionDefaultStreamPlayerOptions streamplayer.Options

type SetupOptions

type SetupOptions []SetupOption

func (SetupOptions) Config

func (s SetupOptions) Config() setupConfig

type StreamPlayers

type StreamPlayers struct {
	xsync.Mutex
	StreamServer
	*streamplayer.StreamPlayers
}

func NewStreamPlayers

func NewStreamPlayers(
	sp *streamplayer.StreamPlayers,
	streamServer StreamServer,
) *StreamPlayers

func (*StreamPlayers) AddStreamPlayer

func (s *StreamPlayers) AddStreamPlayer(
	ctx context.Context,
	streamID types.StreamID,
	playerType player.Backend,
	disabled bool,
	streamPlaybackConfig sptypes.Config,
	opts ...types.StreamPlayerOption,
) error

func (*StreamPlayers) GetActiveStreamPlayer

func (s *StreamPlayers) GetActiveStreamPlayer(
	ctx context.Context,
	streamID types.StreamID,
) (player.Player, error)

func (*StreamPlayers) GetStreamPlayer

func (s *StreamPlayers) GetStreamPlayer(
	ctx context.Context,
	streamID types.StreamID,
) (*types.StreamPlayer, error)

func (*StreamPlayers) Init

func (s *StreamPlayers) Init(
	ctx context.Context,
	opts ...types.InitOption,
) error

func (*StreamPlayers) ListStreamPlayers

func (s *StreamPlayers) ListStreamPlayers(
	ctx context.Context,
) ([]types.StreamPlayer, error)

func (*StreamPlayers) RemoveStreamPlayer

func (s *StreamPlayers) RemoveStreamPlayer(
	ctx context.Context,
	streamID types.StreamID,
) error

func (*StreamPlayers) SetupStreamPlayers

func (s *StreamPlayers) SetupStreamPlayers(
	ctx context.Context,
	opts ...SetupOption,
) (_err error)

func (*StreamPlayers) UpdateStreamPlayer

func (s *StreamPlayers) UpdateStreamPlayer(
	ctx context.Context,
	streamID types.StreamID,
	playerType player.Backend,
	disabled bool,
	streamPlaybackConfig sptypes.Config,
	opts ...types.StreamPlayerOption,
) error

type StreamServer

type StreamServer interface {
	types.WithConfiger
	types.WaitPublisherChaner
}