Function NewKernel

internal/resources/kernel.go:139–170

NewKernel constructs a new raw resource persistence kernel over the supplied database.

(db *sql.DB, opts ...Option)

// NewKernel constructs a new raw resource persistence kernel over the supplied database.
func NewKernel(db *sql.DB, opts ...Option) (*Kernel, error) {
	if db == nil {
		return nil, errors.New("resources: database is required")
	}

	kernel := &Kernel{
		db:                 db,
		now:                func() time.Time { return time.Now().UTC() },
		maxSpecBytes:       defaultMaxSpecBytes,
		maxSnapshotRecords: defaultMaxSnapshotRecords,
		maxSnapshotBytes:   defaultMaxSnapshotBytes,
		sourceLocks:        make(map[string]*sourceLock),
	}
	for _, opt := range opts {
		if opt != nil {
			opt(kernel)
		}
	}
	if kernel.now == nil {
		return nil, errors.New("resources: clock is required")
	}
	if kernel.maxSpecBytes <= 0 {
		return nil, errors.New("resources: max spec bytes must be positive")
	}
	if kernel.maxSnapshotRecords <= 0 {
		return nil, errors.New("resources: max snapshot records must be positive")
	}
	if kernel.maxSnapshotBytes <= 0 {
		return nil, errors.New("resources: max snapshot bytes must be positive")
	}
	return kernel, nil
}

// ActivateSourceSession registers the active nonce and resets the snapshot version counter for one source.
func (k *Kernel) ActivateSourceSession(