stream

Documentation

Index

• func InitWorker() worker.Worker
• type FSM
• type Stream
  • func NewStream(opts ...StreamOption) (*Stream, error)
  • func (s *Stream) GetFSM() *fsm.FSM
  • func (s *Stream) LaunchRoku() error
  • func (s *Stream) NewHttpClient(ctx context.Context) *http.Client
  • func (s *Stream) OneShot() chan<- struct{}
  • func (s *Stream) ProcessSegment(ctx context.Context, request *segment.Request) error
  • func (s *Stream) PushEvent(ctx context.Context, str string)
  • func (s *Stream) RokuCB() (*roku.Remote, error)
  • func (s *Stream) Run(ctx context.Context) error
• type StreamOption
  • func WithBot(b *bot.Bot) StreamOption
  • func WithFlags() StreamOption
  • func WithRokuCB(rokuCB func() (*roku.Remote, error)) StreamOption
  • func WithURL(u *url.URL) StreamOption
  • func WithWorker(w worker.Worker) StreamOption

Functions

func InitWorker

func InitWorker() worker.Worker

Types

type FSM

type FSM struct {
	Clock  func() time.Time
	FSM    *fsm.FSM
	Target chan string
}

type Stream

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

func NewStream

func NewStream(opts ...StreamOption) (*Stream, error)

func (*Stream) GetFSM

func (s *Stream) GetFSM() *fsm.FSM

func (*Stream) LaunchRoku

func (s *Stream) LaunchRoku() error

func (*Stream) NewHttpClient

func (s *Stream) NewHttpClient(ctx context.Context) *http.Client

func (*Stream) OneShot

func (s *Stream) OneShot() chan<- struct{}

func (*Stream) ProcessSegment

func (s *Stream) ProcessSegment(ctx context.Context, request *segment.Request) error

func (*Stream) PushEvent

func (s *Stream) PushEvent(ctx context.Context, str string)

func (*Stream) RokuCB

func (s *Stream) RokuCB() (*roku.Remote, error)

func (*Stream) Run

func (s *Stream) Run(ctx context.Context) error

type StreamOption

type StreamOption func(s *Stream) error

func WithBot

func WithBot(b *bot.Bot) StreamOption

func WithFlags

func WithFlags() StreamOption

func WithRokuCB

func WithRokuCB(rokuCB func() (*roku.Remote, error)) StreamOption

func WithURL

func WithURL(u *url.URL) StreamOption

func WithWorker

func WithWorker(w worker.Worker) StreamOption