dca

Documentation

Index

• Variables
• type EncodeSession
  • func EncodeData(path string, isOpus, isLocal bool) *EncodeSession
  • func (e *EncodeSession) Cleanup()
  • func (e *EncodeSession) FrameDuration() time.Duration
  • func (e *EncodeSession) OpusFrame() ([]byte, error)
  • func (e *EncodeSession) Read(p []byte) (n int, err error)
  • func (e *EncodeSession) ReadFrame() ([]byte, error)
  • func (e *EncodeSession) Stop() error
• type OpusReader
• type StreamingSession
  • func NewStream(source *EncodeSession, vc model.VoiceConnection, callback chan error) *StreamingSession
  • func (s *StreamingSession) Finished() (bool, error)
  • func (s *StreamingSession) Pause()
  • func (s *StreamingSession) Paused() bool
  • func (s *StreamingSession) PlaybackPosition() int
  • func (s *StreamingSession) Resume()
  • func (s *StreamingSession) Source() *EncodeSession
  • func (s *StreamingSession) TogglePause()

Variables

var (
	ErrVoiceConnectionClosed = errors.New("voice connection was closed")
)

Types

type EncodeSession

type EncodeSession struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func EncodeData

func EncodeData(path string, isOpus, isLocal bool) *EncodeSession

func (*EncodeSession) Cleanup

func (e *EncodeSession) Cleanup()

func (*EncodeSession) FrameDuration

func (e *EncodeSession) FrameDuration() time.Duration

func (*EncodeSession) OpusFrame

func (e *EncodeSession) OpusFrame() ([]byte, error)

func (*EncodeSession) Read

func (e *EncodeSession) Read(p []byte) (n int, err error)

func (*EncodeSession) ReadFrame

func (e *EncodeSession) ReadFrame() ([]byte, error)

func (*EncodeSession) Stop

func (e *EncodeSession) Stop() error

type OpusReader

type OpusReader interface {
	OpusFrame() (frame []byte, err error)
	FrameDuration() time.Duration
}

type StreamingSession

type StreamingSession struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewStream

func NewStream(source *EncodeSession, vc model.VoiceConnection, callback chan error) *StreamingSession

func (*StreamingSession) Finished

func (s *StreamingSession) Finished() (bool, error)

func (*StreamingSession) Pause

func (s *StreamingSession) Pause()

func (*StreamingSession) Paused

func (s *StreamingSession) Paused() bool

func (*StreamingSession) PlaybackPosition

func (s *StreamingSession) PlaybackPosition() int

func (*StreamingSession) Resume

func (s *StreamingSession) Resume()

func (*StreamingSession) Source

func (s *StreamingSession) Source() *EncodeSession

func (*StreamingSession) TogglePause

func (s *StreamingSession) TogglePause()