cloudspanner

Documentation

Index

• Variables
• func NewAdminStorage(client *spanner.Client) storage.AdminStorage
• func NewLogStorage(client *spanner.Client) storage.LogStorage
• func NewLogStorageWithOpts(client *spanner.Client, opts LogStorageOptions) storage.LogStorage
• type LogStorageOptions
• type QueuedEntry
• type TreeStorageOptions

Variables

var (
	// NumUnseqBuckets is the length of the unsequenced time ring buffer.
	NumUnseqBuckets = int64(4)
	// NumMerkleBuckets is the number of individual buckets below each unsequenced ring buffer.
	NumMerkleBuckets = int64(16)
	// TimeNow is the function used to get the current time. Exposed so it may be mocked by tests.
	TimeNow = time.Now
)

var (
	// ErrNotFound is returned when a read/lookup fails because there was no such
	// item.
	ErrNotFound = status.Errorf(codes.NotFound, "not found")

	// ErrNotImplemented is returned by any interface methods which have not been
	// implemented yet.
	ErrNotImplemented = errors.New("not implemented")

	// ErrTransactionClosed is returned by interface methods when an operation is
	// attempted on a transaction whose Commit or Rollback methods have
	// previously been called.
	ErrTransactionClosed = errors.New("transaction is closed")

	// ErrWrongTXType is returned when, somehow, a write operation is attempted
	// with a read-only transaction.  This should not even be possible.
	ErrWrongTXType = errors.New("mutating method called on read-only transaction")
)

var (
	// MaxUnsequencedCountStaleness configures the read-staleness limit for the
	// spanner query to retrieve the number of unsequenced certs.
	MaxUnsequencedCountStaleness = 5 * time.Minute
)

Functions

func NewAdminStorage

func NewAdminStorage(client *spanner.Client) storage.AdminStorage

NewAdminStorage returns a Spanner-based storage.AdminStorage implementation.

func NewLogStorage

func NewLogStorage(client *spanner.Client) storage.LogStorage

NewLogStorage initialises and returns a new LogStorage.

func NewLogStorageWithOpts

func NewLogStorageWithOpts(client *spanner.Client, opts LogStorageOptions) storage.LogStorage

NewLogStorageWithOpts initialises and returns a new LogStorage. The opts parameter can be used to enable custom workarounds.

Types

type LogStorageOptions

type LogStorageOptions struct {
	TreeStorageOptions

	// DequeueAcrossMerkleBuckets controls whether DequeueLeaves will only dequeue
	// from within the chosen Time+Merkle bucket, or whether it will attempt to
	// continue reading from contiguous Merkle buckets until a sufficient number
	// of leaves have been dequeued, or the entire Time bucket has been read.
	DequeueAcrossMerkleBuckets bool
	// DequeueAcrossMerkleBucketsRangeFraction specifies the fraction of Merkle
	// keyspace to dequeue from when using multi-bucket-dequeue.
	DequeueAcrossMerkleBucketsRangeFraction float64
}

LogStorageOptions are tuning, experiments and workarounds that can be used.

type QueuedEntry

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

QueuedEntry represents a leaf which was dequeued. It's used to store some extra info which is necessary for rebuilding the leaf's primary key when it's passed back in to UpdateSequencedLeaves.

type TreeStorageOptions

type TreeStorageOptions struct {
	// ReadOnlyStaleness controls how far in the past a read-only snapshot
	// transaction will read.
	// This is intended to allow Spanner to use local replicas for read requests
	// to help with performance.
	// See https://cloud.google.com/spanner/docs/timestamp-bounds for more details.
	ReadOnlyStaleness time.Duration
}

TreeStorageOptions holds various levers for configuring the tree storage instance.