adapter

Aug 13, 2020

Changes in this version

+ var UnknownTenantErr = errors.New("unknown tenantJiscID")

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

+ type Adapter struct

+ func New(logger logrus.FieldLogger, broker *broker.Broker, s3 s3.ObjectStorage, ...) *Adapter

+ func (c *Adapter) Run()

+ func (c *Adapter) Stop()

+ type Registry struct

+ func NewRegistry(logger logrus.FieldLogger, dynamodbClient dynamodbiface.DynamoDBAPI, ...) (*Registry, error)

+ func (r *Registry) Get(tenantID uint64) *amclient.Client

+ func (r *Registry) Log()

+ func (r *Registry) Reload()

+ func (r *Registry) Stop()

+ type Storage interface

+ AssociateResearchObject func(ctx context.Context, objectUUID string, transferID string) error

+ GetResearchObject func(ctx context.Context, objectUUID string) (string, error)