parrot

Documentation

Index

• Variables
• type Parrot
  • func NewParrot(redis *redis.Client) *Parrot
  • func (p *Parrot) GetStream(ctx context.Context, streamID uint) []models.Packet
  • func (p *Parrot) IsStarted(ctx context.Context, streamID uint) bool
  • func (p *Parrot) RecordPacket(ctx context.Context, streamID uint, packet models.Packet)
  • func (p *Parrot) StartStream(ctx context.Context, streamID uint, repeaterID uint) bool
  • func (p *Parrot) StopStream(ctx context.Context, streamID uint)

Variables

var (
	ErrRedis        = fmt.Errorf("redis error")
	ErrCast         = fmt.Errorf("cast error")
	ErrMarshal      = fmt.Errorf("marshal error")
	ErrUnmarshal    = fmt.Errorf("unmarshal error")
	ErrNoSuchStream = fmt.Errorf("no such stream")
)

Types

type Parrot

type Parrot struct {
	Redis redisParrotStorage
}

Parrot is a struct that stores packets and repeats them back to the repeater.

func NewParrot

func NewParrot(redis *redis.Client) *Parrot

NewParrot creates a new parrot instance.

func (*Parrot) GetStream

func (p *Parrot) GetStream(ctx context.Context, streamID uint) []models.Packet

GetStream returns the stream.

func (*Parrot) IsStarted

func (p *Parrot) IsStarted(ctx context.Context, streamID uint) bool

IsStarted returns true if the stream is already started.

func (*Parrot) RecordPacket

func (p *Parrot) RecordPacket(ctx context.Context, streamID uint, packet models.Packet)

RecordPacket records a packet from the stream.

func (*Parrot) StartStream

func (p *Parrot) StartStream(ctx context.Context, streamID uint, repeaterID uint) bool

StartStream starts a new stream.

func (*Parrot) StopStream

func (p *Parrot) StopStream(ctx context.Context, streamID uint)

StopStream stops a stream.