collect

Documentation

Index

• func Run(ctx context.Context, args []string) error
• type Broker
  • func NewBroker[T any]() *Broker[T]
  • func (b *Broker[T]) Broadcast(msg T)
  • func (b *Broker[T]) Start()
  • func (b *Broker[T]) Stop()
  • func (b *Broker[T]) Subscribe() chan T
  • func (b *Broker[T]) Unsubscribe(oldC chan T)
• type ImageServer
  • func NewImageServer(opt Options) (*ImageServer, error)
  • func (s *ImageServer) LiveStream(req *schema.LiveStreamRequest, stream schema.ImageService_LiveStreamServer) error
  • func (s *ImageServer) Start(ctx context.Context) error
  • func (s *ImageServer) Stop()
  • func (s *ImageServer) StoreRawImage(ctx context.Context, req *schema.StoreRawImageRequest) (*schema.StoreRawImageResponse, error)
• type Options
• type ProcessedImage
• type ProxyServer
  • func NewProxyServer(opt Options) *ProxyServer
  • func (s *ProxyServer) Start() error
  • func (s *ProxyServer) Stop()

Functions

func Run

func Run(ctx context.Context, args []string) error

Types

type Broker

type Broker[T any] struct {
	// contains filtered or unexported fields
}

func NewBroker

func NewBroker[T any]() *Broker[T]

func (*Broker[T]) Broadcast

func (b *Broker[T]) Broadcast(msg T)

func (*Broker[T]) Start

func (b *Broker[T]) Start()

func (*Broker[T]) Stop

func (b *Broker[T]) Stop()

func (*Broker[T]) Subscribe

func (b *Broker[T]) Subscribe() chan T

func (*Broker[T]) Unsubscribe

func (b *Broker[T]) Unsubscribe(oldC chan T)

type ImageServer

type ImageServer struct {
	schema.UnimplementedImageServiceServer
	// contains filtered or unexported fields
}

func NewImageServer

func NewImageServer(opt Options) (*ImageServer, error)

func (*ImageServer) LiveStream

func (s *ImageServer) LiveStream(req *schema.LiveStreamRequest, stream schema.ImageService_LiveStreamServer) error

func (*ImageServer) Start

func (s *ImageServer) Start(ctx context.Context) error

func (*ImageServer) Stop

func (s *ImageServer) Stop()

func (*ImageServer) StoreRawImage

func (s *ImageServer) StoreRawImage(ctx context.Context, req *schema.StoreRawImageRequest) (*schema.StoreRawImageResponse, error)

type Options

type Options struct {
	Addr      string
	ImgDir    string
	ProxyAddr string
}

type ProcessedImage

type ProcessedImage struct {
	URL       string
	Timestamp time.Time
	ID        string
}

type ProxyServer

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

func NewProxyServer

func NewProxyServer(opt Options) *ProxyServer

func (*ProxyServer) Start

func (s *ProxyServer) Start() error

func (*ProxyServer) Stop

func (s *ProxyServer) Stop()