commands

Documentation

Index

• type Command
  • func NewCommand(ctx context.Context, user uuid.UUID) *Command
  • func (c *Command) Done() <-chan struct{}
  • func (c *Command) Execute(_ *sessions.Session)
  • func (c *Command) GetUserId() uuid.UUID
  • func (c *Command) SetDone()
  • func (c *Command) SetError(err error)
  • func (c *Command) WaitForDone() error
• type CreateEgress
  • func NewCreateEgress(ctx context.Context, user uuid.UUID, sdp *webrtc.SessionDescription, ...) *CreateEgress
  • func (c *CreateEgress) Execute(session *sessions.Session)
• type CresteIngress
  • func NewCreateIngress(ctx context.Context, user uuid.UUID, sdp *webrtc.SessionDescription, ...) *CresteIngress
  • func (c *CresteIngress) Execute(session *sessions.Session)
• type OfferEgress
  • func NewOfferEgress(ctx context.Context, api ingressRestApi, user uuid.UUID, ...) *OfferEgress
  • func (c *OfferEgress) Execute(session *sessions.Session)
• type OfferIngress
  • func NewOfferIngress(ctx context.Context, api egressRestApi, user uuid.UUID, ...) *OfferIngress
  • func (c *OfferIngress) Execute(session *sessions.Session)

Types

type Command

type Command struct {
	ParentCtx context.Context

	Err error
	// contains filtered or unexported fields
}

func NewCommand

func NewCommand(ctx context.Context, user uuid.UUID) *Command

func (*Command) Done

func (c *Command) Done() <-chan struct{}

func (*Command) Execute

func (c *Command) Execute(_ *sessions.Session)

func (*Command) GetUserId

func (c *Command) GetUserId() uuid.UUID

func (*Command) SetDone

func (c *Command) SetDone()

func (*Command) SetError

func (c *Command) SetError(err error)

func (*Command) WaitForDone

func (c *Command) WaitForDone() error

type CreateEgress

type CreateEgress struct {
	*Command

	Response *resources.WebRTC
	// contains filtered or unexported fields
}

func NewCreateEgress

func NewCreateEgress(ctx context.Context, user uuid.UUID, sdp *webrtc.SessionDescription, signalKind sessions.SignalChannelKind) *CreateEgress

func (*CreateEgress) Execute

func (c *CreateEgress) Execute(session *sessions.Session)

type CresteIngress

type CresteIngress struct {
	*Command

	Response *resources.WebRTC
	// contains filtered or unexported fields
}

func NewCreateIngress

func NewCreateIngress(
	ctx context.Context,
	user uuid.UUID,
	sdp *webrtc.SessionDescription,
	signalKind sessions.SignalChannelKind,
) *CresteIngress

func (*CresteIngress) Execute

func (c *CresteIngress) Execute(session *sessions.Session)

type OfferEgress

type OfferEgress struct {
	*Command

	Response *resources.WebRTC
	// contains filtered or unexported fields
}

func NewOfferEgress

func NewOfferEgress(ctx context.Context, api ingressRestApi, user uuid.UUID, signalKind sessions.SignalChannelKind) *OfferEgress

func (*OfferEgress) Execute

func (c *OfferEgress) Execute(session *sessions.Session)

type OfferIngress

type OfferIngress struct {
	*Command

	Response *resources.WebRTC
	// contains filtered or unexported fields
}

func NewOfferIngress

func NewOfferIngress(ctx context.Context, api egressRestApi, user uuid.UUID, signalKind sessions.SignalChannelKind) *OfferIngress

func (*OfferIngress) Execute

func (c *OfferIngress) Execute(session *sessions.Session)