spannerauthmigration

Documentation

Index

• Variables
• type Storage
  • func New(log *zap.Logger, src *badgerauth.Node, dst *spannerauth.CloudDatabase) *Storage
  • func (s *Storage) Close() (err error)
  • func (s *Storage) Get(ctx context.Context, keyHash authdb.KeyHash) (record *authdb.Record, err error)
  • func (s *Storage) HealthCheck(ctx context.Context) (err error)
  • func (s *Storage) MigrateToLatest(ctx context.Context) error
  • func (s *Storage) Put(ctx context.Context, keyHash authdb.KeyHash, record *authdb.Record) (err error)
  • func (s *Storage) Run(ctx context.Context) error

Variables

var (

	// Error is a class of spannerauthmigration errors.
	Error = errs.Class("spannerauthmigration")
)

Types

type Storage

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

Storage is an implementation of the Storage interface for migrating from badgerauth source backend to the spannerauth destination backend. It proxies requests to avoid downtime.

func New

func New(log *zap.Logger, src *badgerauth.Node, dst *spannerauth.CloudDatabase) *Storage

New constructs a new Storage.

func (*Storage) Close

func (s *Storage) Close() (err error)

Close closes the database.

func (*Storage) Get

func (s *Storage) Get(ctx context.Context, keyHash authdb.KeyHash) (record *authdb.Record, err error)

Get gets the record, retrieving it from the source backend if it doesn't exist in the destination backend.

func (*Storage) HealthCheck

func (s *Storage) HealthCheck(ctx context.Context) (err error)

HealthCheck attempts to do a database roundtrip and returns an error if it can't.

func (*Storage) MigrateToLatest

func (s *Storage) MigrateToLatest(ctx context.Context) error

MigrateToLatest migrates existing records from the source to destination backends.

func (*Storage) Put

func (s *Storage) Put(ctx context.Context, keyHash authdb.KeyHash, record *authdb.Record) (err error)

Put stores the record, writing it to both source and destination backends.

func (*Storage) Run

func (s *Storage) Run(ctx context.Context) error

Run runs the server and associated servers.