mocks

package

v1.8.8-0...-edaca3c Latest Latest Go to latest Published: Jul 22, 2026 License: MIT Imports: 6 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/sharedcode/sop

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func NewMockBlobStore() sop.BlobStore
func NewMockClient() sop.L2Cache
func NewMockRegistry(inducedErrorOnUpdateAllOrNothing bool) sop.Registry
func NewMockStoreRepository() sop.StoreRepository
func NewMockTransactionLog() sop.TransactionLog
type MockTransactionLog
type Mock_vid_registry

Constants ¶

View Source

const DateHourLayout = "2006-01-02T15"

Variables ¶

This section is empty.

Functions ¶

func NewMockBlobStore ¶

func NewMockBlobStore() sop.BlobStore

NewBlobStore instantiates a new (mocked) blobstore.

func NewMockClient ¶

func NewMockClient() sop.L2Cache

Returns a new Redis mock client.

func NewMockRegistry ¶

func NewMockRegistry(inducedErrorOnUpdateAllOrNothing bool) sop.Registry

NewMockRegistry manages the Handle in memory for mocking.

func NewMockStoreRepository ¶

func NewMockStoreRepository() sop.StoreRepository

NewMockStoreRepository manages the StoreInfo in Cassandra table.

func NewMockTransactionLog ¶

func NewMockTransactionLog() sop.TransactionLog

Types ¶

type MockTransactionLog ¶

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

func (*MockTransactionLog) Add ¶

func (tl *MockTransactionLog) Add(ctx context.Context, tid sop.UUID, commitFunction int, payload []byte) error

Add blob(s) to the Blob store.

func (*MockTransactionLog) Get ¶

func (tl *MockTransactionLog) Get(ctx context.Context, tid sop.UUID) ([]sop.RegistryPayload[sop.Handle], error)

Fetch the transaction logs details given a tranasction ID.

func (*MockTransactionLog) GetLog ¶

func (tl *MockTransactionLog) GetLog(ctx context.Context) (sop.UUID, []sop.RegistryPayload[sop.Handle], error)

GetLog will fetch the oldest transaction (older than 2 min) priority logs details if there are from the File System active home folder.

func (*MockTransactionLog) GetOne ¶

func (tl *MockTransactionLog) GetOne(ctx context.Context) (sop.UUID, string, []sop.KeyValuePair[int, []byte], error)

GetOne returns the oldest transaction ID.

func (*MockTransactionLog) GetOneOfHour ¶

func (tl *MockTransactionLog) GetOneOfHour(ctx context.Context, hour string) (sop.UUID, []sop.KeyValuePair[int, []byte], error)

func (*MockTransactionLog) GetTIDLogs ¶

func (tl *MockTransactionLog) GetTIDLogs(tid sop.UUID) []sop.KeyValuePair[int, []byte]

func (*MockTransactionLog) NewUUID ¶

func (tl *MockTransactionLog) NewUUID() sop.UUID

Generates a new UUID based on time.

func (*MockTransactionLog) PriorityLog ¶

func (tl *MockTransactionLog) PriorityLog() sop.TransactionPriorityLog

func (*MockTransactionLog) Remove ¶

func (tl *MockTransactionLog) Remove(ctx context.Context, tid sop.UUID) error

Remove will delete(non-logged) node records from different Blob stores(node tables).

type Mock_vid_registry ¶

type Mock_vid_registry struct {
	Lookup                           map[sop.UUID]sop.Handle
	InducedErrorOnUpdateAllOrNothing bool
}

func (*Mock_vid_registry) Add ¶

func (v *Mock_vid_registry) Add(ctx context.Context, storesHandles []sop.RegistryPayload[sop.Handle]) error

func (*Mock_vid_registry) Get ¶

func (v *Mock_vid_registry) Get(ctx context.Context, storesLids []sop.RegistryPayload[sop.UUID]) ([]sop.RegistryPayload[sop.Handle], error)

func (*Mock_vid_registry) Remove ¶

func (v *Mock_vid_registry) Remove(ctx context.Context, storesLids []sop.RegistryPayload[sop.UUID]) error

func (*Mock_vid_registry) Replicate ¶

func (v *Mock_vid_registry) Replicate(ctx context.Context, newRootNodeHandles, addedNodeHandles, updatedNodeHandles, removedNodeHandles []sop.RegistryPayload[sop.Handle]) error

Mock does NOT replicate.

func (*Mock_vid_registry) Unlock ¶

func (v *Mock_vid_registry) Unlock(ctx context.Context, lockKey *sop.LockKey) error

Unlock is a no-op in the mock; production implementation releases file-region locks.

func (*Mock_vid_registry) Update ¶

func (v *Mock_vid_registry) Update(ctx context.Context, storesHandles []sop.RegistryPayload[sop.Handle]) error

func (*Mock_vid_registry) UpdateNoLocks ¶

func (v *Mock_vid_registry) UpdateNoLocks(ctx context.Context, allOrNothing bool, storesHandles []sop.RegistryPayload[sop.Handle]) error

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL