Skip to content

primaryreplica

import "github.com/go-rel/primaryreplica"

Overview

func New

func New(primary rel.Adapter, replicas ...rel.Adapter) rel.Adapter

type PrimaryReplica

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

func (*PrimaryReplica) Aggregate

func (pr *PrimaryReplica) Aggregate(ctx context.Context, query rel.Query, mode string, field string) (int, error)

func (*PrimaryReplica) Apply

func (pr *PrimaryReplica) Apply(ctx context.Context, migration rel.Migration) error

func (*PrimaryReplica) Begin

func (pr *PrimaryReplica) Begin(ctx context.Context) (rel.Adapter, error)

func (*PrimaryReplica) Close

func (pr *PrimaryReplica) Close() error

func (*PrimaryReplica) Commit

func (pr *PrimaryReplica) Commit(ctx context.Context) error

func (*PrimaryReplica) Delete

func (pr *PrimaryReplica) Delete(ctx context.Context, query rel.Query) (int, error)

func (*PrimaryReplica) Exec

func (pr *PrimaryReplica) Exec(ctx context.Context, stmt string, args []interface{}) (int64, int64, error)

func (*PrimaryReplica) Insert

func (pr *PrimaryReplica) Insert(ctx context.Context, query rel.Query, primaryField string, mutates map[string]rel.Mutate, onConflict rel.OnConflict) (interface{}, error)

func (*PrimaryReplica) InsertAll

func (pr *PrimaryReplica) InsertAll(ctx context.Context, query rel.Query, primaryField string, fields []string, bulkMutates []map[string]rel.Mutate, onConflict rel.OnConflict) ([]interface{}, error)

func (*PrimaryReplica) Instrumentation

func (pr *PrimaryReplica) Instrumentation(instrumenter rel.Instrumenter)

func (*PrimaryReplica) Ping

func (pr *PrimaryReplica) Ping(ctx context.Context) error

func (*PrimaryReplica) Query

func (pr *PrimaryReplica) Query(ctx context.Context, query rel.Query) (rel.Cursor, error)

func (*PrimaryReplica) Rollback

func (pr *PrimaryReplica) Rollback(ctx context.Context) error

func (*PrimaryReplica) Update

func (pr *PrimaryReplica) Update(ctx context.Context, query rel.Query, primaryField string, mutates map[string]rel.Mutate) (int, error)

Last update: 2022-06-25