durable

Documentation

Index

• func OpenSpannerClient(ctx context.Context, name string) (*spanner.Client, error)
• type Database
  • func WrapDatabase(client *spanner.Client) *Database
  • func (db *Database) Apply(ctx context.Context, ms []*spanner.Mutation, ...) error
  • func (db *Database) Close()
  • func (db *Database) Query(ctx context.Context, statement spanner.Statement, collection, query string) *spanner.RowIterator
  • func (db *Database) Read(ctx context.Context, table string, keys spanner.KeySet, columns []string, ...) *spanner.RowIterator
  • func (db *Database) ReadOnlyTransaction() *spanner.ReadOnlyTransaction
  • func (db *Database) ReadRow(ctx context.Context, table string, key spanner.Key, columns []string, ...) (*spanner.Row, error)
  • func (db *Database) ReadUsingIndex(ctx context.Context, table, index string, keys spanner.KeySet, ...) *spanner.RowIterator
  • func (db *Database) ReadWriteTransaction(ctx context.Context, ...) (time.Time, error)
• type Limiter
  • func NewLimiter(addr string, db int) (*Limiter, error)
  • func (limiter *Limiter) Available(key string, window time.Duration, max int, shouldIncr bool) (int, error)
  • func (limiter *Limiter) Clear(key string, window time.Duration) error
• type Logger
  • func BuildLogger(client *LoggerClient, name string, r *http.Request) *Logger
  • func (logger *Logger) Debug(v ...interface{})
  • func (logger *Logger) Debugf(format string, v ...interface{})
  • func (logger *Logger) Error(v ...interface{})
  • func (logger *Logger) Errorf(format string, v ...interface{})
  • func (logger *Logger) FillResponse(status int, responseSize int64, latency time.Duration)
  • func (logger *Logger) Info(v ...interface{})
  • func (logger *Logger) Infof(format string, v ...interface{})
  • func (logger *Logger) Panicln(v ...interface{})
• type LoggerClient
  • func NewLoggerClient(project string, syslog bool) (*LoggerClient, error)
  • func (client *LoggerClient) Close() error
• type Transaction

Functions

func OpenSpannerClient

func OpenSpannerClient(ctx context.Context, name string) (*spanner.Client, error)

Types

type Database

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

func WrapDatabase

func WrapDatabase(client *spanner.Client) *Database

func (*Database) Apply

func (db *Database) Apply(ctx context.Context, ms []*spanner.Mutation, collection, operation, query string) error

func (*Database) Close

func (db *Database) Close()

func (*Database) Query

func (db *Database) Query(ctx context.Context, statement spanner.Statement, collection, query string) *spanner.RowIterator

func (*Database) Read

func (db *Database) Read(ctx context.Context, table string, keys spanner.KeySet, columns []string, query string) *spanner.RowIterator

func (*Database) ReadOnlyTransaction

func (db *Database) ReadOnlyTransaction() *spanner.ReadOnlyTransaction

func (*Database) ReadRow

func (db *Database) ReadRow(ctx context.Context, table string, key spanner.Key, columns []string, query string) (*spanner.Row, error)

func (*Database) ReadUsingIndex

func (db *Database) ReadUsingIndex(ctx context.Context, table, index string, keys spanner.KeySet, columns []string, query string) *spanner.RowIterator

func (*Database) ReadWriteTransaction

func (db *Database) ReadWriteTransaction(ctx context.Context, impl func(context.Context, *spanner.ReadWriteTransaction) error, collection, operation, query string) (time.Time, error)

type Limiter

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

func NewLimiter

func NewLimiter(addr string, db int) (*Limiter, error)

func (*Limiter) Available

func (limiter *Limiter) Available(key string, window time.Duration, max int, shouldIncr bool) (int, error)

func (*Limiter) Clear

func (limiter *Limiter) Clear(key string, window time.Duration) error

type Logger

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

func BuildLogger

func BuildLogger(client *LoggerClient, name string, r *http.Request) *Logger

func (*Logger) Debug

func (logger *Logger) Debug(v ...interface{})

func (*Logger) Debugf

func (logger *Logger) Debugf(format string, v ...interface{})

func (*Logger) Error

func (logger *Logger) Error(v ...interface{})

func (*Logger) Errorf

func (logger *Logger) Errorf(format string, v ...interface{})

func (*Logger) FillResponse

func (logger *Logger) FillResponse(status int, responseSize int64, latency time.Duration)

func (*Logger) Info

func (logger *Logger) Info(v ...interface{})

func (*Logger) Infof

func (logger *Logger) Infof(format string, v ...interface{})

func (*Logger) Panicln

func (logger *Logger) Panicln(v ...interface{})

type LoggerClient

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

func NewLoggerClient

func NewLoggerClient(project string, syslog bool) (*LoggerClient, error)

func (*LoggerClient) Close

func (client *LoggerClient) Close() error

type Transaction

type Transaction interface {
	ReadUsingIndex(context.Context, string, string, spanner.KeySet, []string) *spanner.RowIterator
	Read(context.Context, string, spanner.KeySet, []string) *spanner.RowIterator
	ReadRow(context.Context, string, spanner.Key, []string) (*spanner.Row, error)
	Query(context.Context, spanner.Statement) *spanner.RowIterator
}