thumbnail

Documentation

Index

• Constants
• type Config
  • func Flags(fs *flag.FlagSet, prefix string) *Config
• type Service
  • func New(ctx context.Context, config *Config, storage absto.Storage, ...) (Service, error)
  • func (s Service) AMQPHandler(ctx context.Context, message amqp.Delivery) (err error)
  • func (s Service) CanHaveThumbnail(item absto.Item) bool
  • func (s Service) EventConsumer(ctx context.Context, e provider.Event)
  • func (s Service) GetChunk(ctx context.Context, pathname string) (absto.Item, error)
  • func (s Service) HasLargeThumbnail(ctx context.Context, item absto.Item) bool
  • func (s Service) HasStream(ctx context.Context, item absto.Item) bool
  • func (s Service) HasThumbnail(ctx context.Context, item absto.Item, scale uint64) bool
  • func (s Service) Info(ctx context.Context, pathname string) (item absto.Item, err error)
  • func (s Service) LargeThumbnailSize() uint64
  • func (s Service) List(w http.ResponseWriter, r *http.Request, item absto.Item, items []absto.Item)
  • func (s Service) ListDir(ctx context.Context, item absto.Item) (map[string]absto.Item, error)
  • func (s Service) ListDirLarge(ctx context.Context, item absto.Item) (map[string]absto.Item, error)
  • func (s Service) Path(item absto.Item) string
  • func (s Service) PathForLarge(item absto.Item) string
  • func (s Service) PathForScale(item absto.Item, scale uint64) string
  • func (s Service) Rename(ctx context.Context, old, new absto.Item) error
  • func (s Service) Serve(w http.ResponseWriter, r *http.Request, item absto.Item)
  • func (s Service) Stream(w http.ResponseWriter, r *http.Request, item absto.Item)

Constants

const SmallSize uint64 = 150

Types

type Config

type Config struct {
	VithURL  string
	VithUser string
	VithPass string

	AmqpExchange            string
	AmqpStreamRoutingKey    string
	AmqpThumbnailRoutingKey string

	MaxSize      int64
	MinBitrate   uint64
	DirectAccess bool

	LargeSize uint64
}

func Flags

func Flags(fs *flag.FlagSet, prefix string) *Config

type Service

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

func New

func New(ctx context.Context, config *Config, storage absto.Storage, redisClient redis.Client, meterProvider metric.MeterProvider, traceProvider trace.TracerProvider, amqpClient *amqp.Client) (Service, error)

func (Service) AMQPHandler

func (s Service) AMQPHandler(ctx context.Context, message amqp.Delivery) (err error)

func (Service) CanHaveThumbnail

func (s Service) CanHaveThumbnail(item absto.Item) bool

func (Service) EventConsumer

func (s Service) EventConsumer(ctx context.Context, e provider.Event)

func (Service) GetChunk

func (s Service) GetChunk(ctx context.Context, pathname string) (absto.Item, error)

func (Service) HasLargeThumbnail

func (s Service) HasLargeThumbnail(ctx context.Context, item absto.Item) bool

func (Service) HasStream

func (s Service) HasStream(ctx context.Context, item absto.Item) bool

func (Service) HasThumbnail

func (s Service) HasThumbnail(ctx context.Context, item absto.Item, scale uint64) bool

func (Service) Info

func (s Service) Info(ctx context.Context, pathname string) (item absto.Item, err error)

func (Service) LargeThumbnailSize

func (s Service) LargeThumbnailSize() uint64

func (Service) List

func (s Service) List(w http.ResponseWriter, r *http.Request, item absto.Item, items []absto.Item)

func (Service) ListDir

func (s Service) ListDir(ctx context.Context, item absto.Item) (map[string]absto.Item, error)

func (Service) ListDirLarge

func (s Service) ListDirLarge(ctx context.Context, item absto.Item) (map[string]absto.Item, error)

func (Service) Path

func (s Service) Path(item absto.Item) string

func (Service) PathForLarge

func (s Service) PathForLarge(item absto.Item) string

func (Service) PathForScale

func (s Service) PathForScale(item absto.Item, scale uint64) string

func (Service) Rename

func (s Service) Rename(ctx context.Context, old, new absto.Item) error

func (Service) Serve

func (s Service) Serve(w http.ResponseWriter, r *http.Request, item absto.Item)

func (Service) Stream

func (s Service) Stream(w http.ResponseWriter, r *http.Request, item absto.Item)