bunexp

type DBReplica ¶

type DBReplica interface {
	bun.IConn
	PingContext(context.Context) error
	Close() error
}

type DBReplicaRole ¶

type DBReplicaRole int

const (
	DBReplicaReadOnly DBReplicaRole = 1 << iota
	DBReplicaBackup
)

type ReadWriteConnResolver ¶

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

TODO:

• make monitoring interval configurable
• make ping timeout configutable
• allow adding read/write replicas for multi-master replication

func NewReadWriteConnResolver(opts ...ReadWriteConnResolverOption) *ReadWriteConnResolver

func (r *ReadWriteConnResolver) Close() error

func (r *ReadWriteConnResolver) ResolveConn(query bun.Query) bun.IConn

type ReadWriteConnResolverOption ¶

type ReadWriteConnResolverOption func(r *ReadWriteConnResolver)

func WithDBReplica(db DBReplica, roles ...DBReplicaRole) ReadWriteConnResolverOption