configuration

type BlobAccessCreator interface {
	BlobReplicatorCreator

	// GetStorageType() returns operations that can be used by
	// BlobAccess to create Buffer objects to return data.
	GetStorageType() blobstore.StorageType
	// GetStorageTypeName() returns a short string that identifies
	// the purpose of this storage (e.g., "ac", "cas").
	GetStorageTypeName() string
	// NewCustomBlobAccess() can be used as a fallback to create
	// BlobAccess instances that only apply to this storage type.
	// For example, CompletenessCheckingBlobAccess is only
	// applicable to the Action Cache.
	NewCustomBlobAccess(configuration *pb.BlobAccessConfiguration) (blobstore.BlobAccess, string, error)
	// WrapTopLevelBlobAccess() is called at the very end of
	// NewBlobAccessFromConfiguration() to apply any top-level
	// decorators.
	WrapTopLevelBlobAccess(blobAccess blobstore.BlobAccess) blobstore.BlobAccess
}

type BlobReplicatorCreator interface {
	// GetDigestKeyFormat() returns the preferred way of creating
	// keys based on digests. For the Content Addressable Storage,
	// it is typically valid to discard the instance name, so that
	// we get a higher cache hit rate in case multiple instance
	// names are used.
	GetDigestKeyFormat() digest.KeyFormat
	// NewCustomBlobReplicator() can be used as a fallback to create
	// BlobReplicator instances that only apply to this storage
	// type. For example, sending replication requests over gRPC is
	// only supported for the Content Addressable Storage.
	NewCustomBlobReplicator(configuration *pb.BlobReplicatorConfiguration, source blobstore.BlobAccess, sink blobstore.BlobAccess) (replication.BlobReplicator, error)
}