tracker

Documentation

Index

• Constants
• func Execute(ctx context.Context, cfg config.Config) error
• func ListenerAdd(ctx context.Context, delayer *Delayer, recorder *Recorder) http.HandlerFunc
• func ListenerRemove(ctx context.Context, delayer *Delayer, recorder *Recorder) http.HandlerFunc
• func NewServer(ctx context.Context, addr string, recorder *Recorder) *http.Server
• type Delayer
  • func NewDelayer(delay time.Duration) *Delayer
  • func (d *Delayer) Delay(ctx context.Context, id string, fn func())
  • func (d *Delayer) Remove(ctx context.Context, id string)
• type Listener
• type Recorder
  • func NewRecorder() *Recorder
  • func (r *Recorder) ListenerAdd(ctx context.Context, id string, req *http.Request)
  • func (r *Recorder) ListenerRemove(ctx context.Context, id string, req *http.Request)

Constants

const ADD_DELAY = time.Second * 1

Functions

func Execute

func Execute(ctx context.Context, cfg config.Config) error

func ListenerAdd

func ListenerAdd(ctx context.Context, delayer *Delayer, recorder *Recorder) http.HandlerFunc

func ListenerRemove

func ListenerRemove(ctx context.Context, delayer *Delayer, recorder *Recorder) http.HandlerFunc

func NewServer

func NewServer(ctx context.Context, addr string, recorder *Recorder) *http.Server

Types

type Delayer

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

func NewDelayer

func NewDelayer(delay time.Duration) *Delayer

func (*Delayer) Delay

func (d *Delayer) Delay(ctx context.Context, id string, fn func())

func (*Delayer) Remove

func (d *Delayer) Remove(ctx context.Context, id string)

type Listener

type Listener struct {

	// ID is the identifier icecast is using for this client
	ID string
	// Start is the time this listener started listening
	Start time.Time
	// Info is the information icecast sends us through the POST form values
	Info url.Values
	// contains filtered or unexported fields
}

type Recorder

type Recorder struct {
	Listeners      map[string]*Listener
	ListenerAmount atomic.Int64
	// contains filtered or unexported fields
}

func NewRecorder

func NewRecorder() *Recorder

func (*Recorder) ListenerAdd

func (r *Recorder) ListenerAdd(ctx context.Context, id string, req *http.Request)

func (*Recorder) ListenerRemove

func (r *Recorder) ListenerRemove(ctx context.Context, id string, req *http.Request)