tests

Documentation

Index

• func RunCommitterTests(t *testing.T, c ingestion.Committer, teardown func())
• func RunLockTests(t *testing.T, lockCtor LockCtor, teardown func())
• type LockCtor

Functions

func RunCommitterTests

func RunCommitterTests(t *testing.T, c ingestion.Committer, teardown func())

func RunLockTests

func RunLockTests(t *testing.T, lockCtor LockCtor, teardown func())

Types

type LockCtor

type LockCtor func(key string) (ingestion.DistributedLock, error)