videostreams

Nov 29, 2022

Changes in this version

+ const ChannelName

+ func NewChannelFactory(b *Broker, sessionID string, logger pubsub.Logger, ...) actioncable.ChannelFactory

type Broker

+ func (b *Broker) Hub() *Hub

+ type Channel struct

+ func NewChannel(identifier string, h *pubsub.Hub[[]Frame], subscriber subscriber, ...) (*Channel, error)

+ func (c *Channel) Perform(data string) error

+ func (c *Channel) Subscribe(ctx context.Context, sub *actioncable.Subscription) error

type Frame

+ AsJPEGFrame func() (*JPEGFrame, error)

type ImageFrame

+ func (f *ImageFrame) AsJPEGFrame() (*JPEGFrame, error)

+ type JPEGFrame struct

+ Err error

+ Im []byte

+ Meta *Metadata

+ func (f *JPEGFrame) AsImageFrame() (*ImageFrame, error)

+ func (f *JPEGFrame) AsJPEGFrame() (*JPEGFrame, error)

+ func (f *JPEGFrame) Error() error

Oct 27, 2022

Changes in this version

+ const Nop

+ var LineHeight = fontFace.Metrics().Height.Round()

+ func AddAnnotationPadding(source image.Image, topLines, bottomLines int) (output draw.Image)

+ func AnnotateTop(im draw.Image, annotations string, lines int)

+ func CopyRGBA(im image.Image) draw.Image

+ func ResizeToHeight(im image.Image, height int) draw.Image

+ type AnnotationMetadata struct

+ FPSCount int64

+ FPSPeriod float32

+ Height int

+ JPEGQuality int

+ Timestamp time.Time

+ Width int

+ func (m AnnotationMetadata) String() string

+ func (m AnnotationMetadata) WithFrameData(f *ImageFrame) AnnotationMetadata

type Frame

+ AsImageFrame func() (*ImageFrame, error)

+ AsJPEG func() ([]byte, Operation, error)

+ Error func() error

type ImageFrame

+ Im image.Image

+ Meta *Metadata

+ func (f *ImageFrame) AsImageFrame() (*ImageFrame, error)

+ func (f *ImageFrame) AsJPEG() ([]byte, Operation, error)

+ func (f *ImageFrame) WithAnnotation(annotations string, lines int) *ImageFrame

+ func (f *ImageFrame) WithResizeToHeight(height int) *ImageFrame

type Metadata

+ FromSource map[string][]string

+ Operations *OpChain

+ ReceiveTime time.Time

+ Settings Settings

+ func (m *Metadata) WithOp(op Operation) *Metadata

+ func (m *Metadata) WithSettings(settings Settings) *Metadata

+ type OpChain struct

+ Op Operation

+ func (o *OpChain) Linearization() []Operation

+ func (o *OpChain) With(op Operation) *OpChain

+ type Operation string

+ func Operationf(formatString string, params ...interface{}) Operation

+ type Settings struct

+ JPEGEncodeQuality int

Oct 26, 2022

Changes in this version

+ const MethodPub

+ const MethodSub

+ const MethodUnsub

+ func AddLabel(im draw.Image, label string, co color.Color, x, y int)

+ func Annotate(im draw.Image, timestamp time.Time, metadata fmt.Stringer)

+ func CopyForAnnotation(source image.Image) (output draw.Image)

+ func EmptyHandler(c *Context) error

+ type BroadcastReceiver func(ctx context.Context, frames []Frame) (ok bool)

+ type Broker struct

+ func NewBroker(logger pubsub.Logger) *Broker

+ func (b *Broker) PUB(topic string, h HandlerFunc, m ...MiddlewareFunc) *Route

+ func (b *Broker) SUB(topic string, h HandlerFunc, m ...MiddlewareFunc) *Route

+ func (b *Broker) Serve(ctx context.Context) error

+ func (b *Broker) Subscribe(ctx context.Context, topic string) <-chan Frame

+ func (b *Broker) UNSUB(topic string, h HandlerFunc, m ...MiddlewareFunc) *Route

+ func (b *Broker) Use(middleware ...MiddlewareFunc)

+ type Context struct

+ type Frame interface

+ Err func() error

+ Image func() (image.Image, error)

+ JPEG func() ([]byte, error)

+ Time func() time.Time

+ func NewErrorFrame(err error) Frame

+ type HandlerFunc = pubsub.HandlerFunc[*Context]

+ type Hub = pubsub.Hub[[]Frame]

+ type ImageFrame struct

+ Data image.Image

+ Error error

+ JPEGQuality int

+ Timestamp time.Time

+ func (f ImageFrame) CopyRGBA() ImageFrame

+ func (f ImageFrame) Err() error

+ func (f ImageFrame) Image() (image.Image, error)

+ func (f ImageFrame) JPEG() ([]byte, error)

+ func (f ImageFrame) Time() time.Time

+ type Metadata struct

+ FPSCount int64

+ FPSPeriod float32

+ Height int

+ Quality int

+ Timestamp time.Time

+ Width int

+ func (m Metadata) String() string

+ type MiddlewareFunc = pubsub.MiddlewareFunc[*Context]

+ type Route = pubsub.Route

+ type Router = pubsub.Router[*Context]