cloudspanner

Documentation

Overview

Package cloudspanner implements cloud spanner as a hashR storage.

Index

• type Storage
  • func NewStorage(ctx context.Context, spannerClient *spanner.Client) (*Storage, error)
  • func (s *Storage) FetchJobs(ctx context.Context) (map[string]string, error)
  • func (s *Storage) UpdateJobs(ctx context.Context, qHash string, p *hashr.ProcessingSource) error

Types

type Storage

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

Storage allows to interact with cloud spanner.

func NewStorage

func NewStorage(ctx context.Context, spannerClient *spanner.Client) (*Storage, error)

NewStorage creates new Storage struct that allows to interact with cloud spanner.

func (*Storage) FetchJobs

func (s *Storage) FetchJobs(ctx context.Context) (map[string]string, error)

FetchJobs fetches processing jobs from cloud spanner.

func (*Storage) UpdateJobs

func (s *Storage) UpdateJobs(ctx context.Context, qHash string, p *hashr.ProcessingSource) error

UpdateJobs updates cloud spanner table.