events

Documentation

Index

• type ProcessorConfig
• type V1IdentifyNewFileProcessor
  • func NewV1IdentifyNewFileProcessor(c *ProcessorConfig) *V1IdentifyNewFileProcessor
  • func (p *V1IdentifyNewFileProcessor) Process(msg *rabbitmq.Delivery) error
• type V1IdentifyProcessor
  • func NewV1IdentifyProcessor(conf *ProcessorConfig) *V1IdentifyProcessor
  • func (p *V1IdentifyProcessor) Process(msg *rabbitmq.Delivery) error

Types

type ProcessorConfig

type ProcessorConfig struct {
	Providers       map[api.Media_MetadataType]providerapi.Fetcher
	DB              storageapi.Provider
	ImageDownloader *image.Downloader
	ImageUploader   *image.Uploader
	OSDB            *osdb.Client
	S3Client        *minio.Client
}

ProcessorConfig is an event processor config

type V1IdentifyNewFileProcessor

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

V1IdentifyNewFileProcessor is a v1.identify.newfile processor

func NewV1IdentifyNewFileProcessor

func NewV1IdentifyNewFileProcessor(c *ProcessorConfig) *V1IdentifyNewFileProcessor

NewV1IdentifyNewFileProcessor creates a v1.identify.newfile processor

func (*V1IdentifyNewFileProcessor) Process

func (p *V1IdentifyNewFileProcessor) Process(msg *rabbitmq.Delivery) error

Process processes a AMQP message

type V1IdentifyProcessor

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

V1IdentifyProcessor process v1.identifiy messages

func NewV1IdentifyProcessor

func NewV1IdentifyProcessor(conf *ProcessorConfig) *V1IdentifyProcessor

NewV1IdentifyProcessor returns and identifier processor

func (*V1IdentifyProcessor) Process

func (p *V1IdentifyProcessor) Process(msg *rabbitmq.Delivery) error

Process processes an AMQP message