consumer

Documentation

Index

• func NewStorageDynamoDB(client dynamodbiface.DynamoDBAPI, table string) *storageDynamoDBImpl
• func NewStorageInMemory() *storageInMemoryImpl
• type Consumer
• type ConsumerImpl
  • func MakeConsumer(ctx context.Context, logger log.FieldLogger, broker *broker.Broker, ...) *ConsumerImpl
  • func (c *ConsumerImpl) Start()
• type Storage

Functions

func NewStorageDynamoDB

func NewStorageDynamoDB(client dynamodbiface.DynamoDBAPI, table string) *storageDynamoDBImpl

func NewStorageInMemory

func NewStorageInMemory() *storageInMemoryImpl

Types

type Consumer

type Consumer interface {
	Start()
}

Consumer is the component that subscribes to the broker and interacts with Archivematica.

type ConsumerImpl

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

ConsumerImpl is an implementation of Consumer.

func MakeConsumer

func MakeConsumer(
	ctx context.Context,
	logger log.FieldLogger,
	broker *broker.Broker,
	amc *amclient.Client,
	s3 s3.ObjectStorage,
	storage Storage) *ConsumerImpl

MakeConsumer returns a new ConsumerImpl which implements Consumer

func (*ConsumerImpl) Start

func (c *ConsumerImpl) Start()

Start implements Consumer

type Storage

type Storage interface {
	AssociateResearchObject(ctx context.Context, objectUUID string, transferID string) error
	GetResearchObject(ctx context.Context, objectUUID string) (string, error)
}