metadata

Documentation

Index

• func Path(item absto.Item) string
• type Config
  • func Flags(fs *flag.FlagSet, prefix string) *Config
• type Service
  • func New(ctx context.Context, config *Config, storageService absto.Storage, ...) (Service, error)
  • func (s Service) AMQPHandler(ctx context.Context, message amqp.Delivery) error
  • func (s Service) CanHaveExif(item absto.Item) bool
  • func (s Service) EventConsumer(ctx context.Context, e provider.Event)
  • func (s Service) GetAggregateFor(ctx context.Context, item absto.Item) (aggregate provider.Aggregate, err error)
  • func (s Service) GetAllAggregateFor(ctx context.Context, items ...absto.Item) (map[string]provider.Aggregate, error)
  • func (s Service) GetAllMetadataFor(ctx context.Context, items ...absto.Item) (map[string]provider.Metadata, error)
  • func (s Service) GetMetadataFor(ctx context.Context, item absto.Item) (metadata provider.Metadata, err error)
  • func (s Service) ListDir(ctx context.Context, item absto.Item) ([]absto.Item, error)
  • func (s Service) Rename(ctx context.Context, old, new absto.Item) error
  • func (s Service) SaveAggregateFor(ctx context.Context, item absto.Item, aggregate provider.Aggregate) error
  • func (s Service) Update(ctx context.Context, item absto.Item, opts ...provider.MetadataAction) (provider.Metadata, error)

Functions

func Path

func Path(item absto.Item) string

Types

type Config

type Config struct {
	ExifURL  string
	ExifUser string
	ExifPass string

	AmqpExchange   string
	AmqpRoutingKey string

	MaxSize      int64
	DirectAccess bool
}

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, storageService absto.Storage, meterProvider metric.MeterProvider, traceProvider trace.TracerProvider, amqpClient *amqpclient.Client, redisClient redis.Client, exclusiveService exclusive.Service) (Service, error)

func (Service) AMQPHandler

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

func (Service) CanHaveExif

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

func (Service) EventConsumer

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

func (Service) GetAggregateFor

func (s Service) GetAggregateFor(ctx context.Context, item absto.Item) (aggregate provider.Aggregate, err error)

func (Service) GetAllAggregateFor

func (s Service) GetAllAggregateFor(ctx context.Context, items ...absto.Item) (map[string]provider.Aggregate, error)

func (Service) GetAllMetadataFor

func (s Service) GetAllMetadataFor(ctx context.Context, items ...absto.Item) (map[string]provider.Metadata, error)

func (Service) GetMetadataFor

func (s Service) GetMetadataFor(ctx context.Context, item absto.Item) (metadata provider.Metadata, err error)

func (Service) ListDir

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

func (Service) Rename

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

func (Service) SaveAggregateFor

func (s Service) SaveAggregateFor(ctx context.Context, item absto.Item, aggregate provider.Aggregate) error

func (Service) Update

func (s Service) Update(ctx context.Context, item absto.Item, opts ...provider.MetadataAction) (provider.Metadata, error)