spannerclient

Documentation

Index

• type ReadOnlyTransaction
• type Row
• type RowIterator
• type SpannerClient
  • func NewClient(ctx context.Context, projectID string) (SpannerClient, error)
• type SpannerClientProxy
  • func (proxy *SpannerClientProxy) Apply(ctx context.Context, ms []*spanner.Mutation, opts ...spanner.ApplyOption) (commitTimestamp time.Time, err error)
  • func (proxy *SpannerClientProxy) Close()
  • func (proxy *SpannerClientProxy) Single() ReadOnlyTransaction
• type SpannerReadOnlyTransactionProxy
  • func (proxy *SpannerReadOnlyTransactionProxy) Query(ctx context.Context, statement spanner.Statement) RowIterator
• type SpannerRowIteratorProxy
  • func (proxy *SpannerRowIteratorProxy) Next() (Row, error)
  • func (proxy *SpannerRowIteratorProxy) Stop()

Types

type ReadOnlyTransaction

type ReadOnlyTransaction interface {
	Query(ctx context.Context, statement spanner.Statement) RowIterator
}

type Row

type Row interface {
	ToStruct(p interface{}) error
}

type RowIterator

type RowIterator interface {
	Next() (Row, error)
	Stop()
}

type SpannerClient

type SpannerClient interface {
	Close()
	Apply(ctx context.Context, ms []*spanner.Mutation, opts ...spanner.ApplyOption) (commitTimestamp time.Time, err error)
	Single() ReadOnlyTransaction
}

func NewClient

func NewClient(ctx context.Context, projectID string) (SpannerClient, error)

type SpannerClientProxy

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

func (*SpannerClientProxy) Apply

func (proxy *SpannerClientProxy) Apply(ctx context.Context, ms []*spanner.Mutation, opts ...spanner.ApplyOption,
) (commitTimestamp time.Time, err error)

func (*SpannerClientProxy) Close

func (proxy *SpannerClientProxy) Close()

func (*SpannerClientProxy) Single

func (proxy *SpannerClientProxy) Single() ReadOnlyTransaction

type SpannerReadOnlyTransactionProxy

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

func (*SpannerReadOnlyTransactionProxy) Query

func (proxy *SpannerReadOnlyTransactionProxy) Query(ctx context.Context, statement spanner.Statement) RowIterator

type SpannerRowIteratorProxy

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

func (*SpannerRowIteratorProxy) Next

func (proxy *SpannerRowIteratorProxy) Next() (Row, error)

func (*SpannerRowIteratorProxy) Stop

func (proxy *SpannerRowIteratorProxy) Stop()