Documentation
¶
Overview ¶
Package test provides in-memory intended-for-testing implementations of storage package interfaces.
Index ¶
- type Key
- func (k *Key) BatchSigningKeys() map[LocalityIngestor]key.Key
- func (k *Key) GetBatchSigningKey(ctx context.Context, locality, ingestor string) (key.Key, error)
- func (k *Key) GetPacketEncryptionKey(ctx context.Context, locality string) (key.Key, error)
- func (k *Key) PacketEncryptionKeys() map[string]key.Key
- func (k *Key) PutBatchSigningKey(ctx context.Context, locality, ingestor string, key key.Key) error
- func (k *Key) PutPacketEncryptionKey(ctx context.Context, locality string, key key.Key) error
- type LocalityIngestor
- type Manifest
- func (m *Manifest) GetDataShareProcessorSpecificManifest(_ context.Context, dspName string) (manifest.DataShareProcessorSpecificManifest, error)
- func (m *Manifest) GetDataShareProcessorSpecificManifestPutCount(dspName string) int
- func (m *Manifest) GetDataShareProcessorSpecificManifests() map[string]manifest.DataShareProcessorSpecificManifest
- func (m *Manifest) GetIngestorGlobalManifest(ctx context.Context) (manifest.IngestorGlobalManifest, error)
- func (m *Manifest) GetIngestorGlobalManifestPutCount() int
- func (m *Manifest) PutDataShareProcessorSpecificManifest(_ context.Context, dspName string, ...) error
- func (m *Manifest) PutIngestorGlobalManifest(_ context.Context, manifest manifest.IngestorGlobalManifest) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Key ¶
type Key struct {
// contains filtered or unexported fields
}
func NewKey ¶
func NewKey() *Key
NewKey returns a Key which stores keys in memory only, suitable for testing.
func (*Key) BatchSigningKeys ¶
func (k *Key) BatchSigningKeys() map[LocalityIngestor]key.Key
Test-only functions. Not goroutine-safe.
func (*Key) GetBatchSigningKey ¶
func (*Key) GetPacketEncryptionKey ¶
func (*Key) PutBatchSigningKey ¶
Standard storage.Key functions. Safe for concurrent access from multiple goroutines.
type LocalityIngestor ¶
type LocalityIngestor struct{ Locality, Ingestor string }
LocalityIngestor represents a (locality, ingestor) tuple.
type Manifest ¶
type Manifest struct {
// contains filtered or unexported fields
}
func NewManifest ¶
func NewManifest() *Manifest
NewManifest returns a Manifest which stores manifests in memory only, suitable for testing.
func (*Manifest) GetDataShareProcessorSpecificManifest ¶
func (*Manifest) GetDataShareProcessorSpecificManifestPutCount ¶
func (*Manifest) GetDataShareProcessorSpecificManifests ¶
func (m *Manifest) GetDataShareProcessorSpecificManifests() map[string]manifest.DataShareProcessorSpecificManifest
Test-only functions. NOT goroutine-safe.
func (*Manifest) GetIngestorGlobalManifest ¶
func (*Manifest) GetIngestorGlobalManifestPutCount ¶
func (*Manifest) PutDataShareProcessorSpecificManifest ¶
func (m *Manifest) PutDataShareProcessorSpecificManifest(_ context.Context, dspName string, manifest manifest.DataShareProcessorSpecificManifest) error
Standard storage.Manifest functions. Safe for concurrent access from multiple goroutines.
func (*Manifest) PutIngestorGlobalManifest ¶
Source Files
Click to show internal directories.
Click to hide internal directories.