repository

Aug 29, 2020

Changes in this version

+ type Savepointer interface

+ RollbackSavepoint func(ctx context.Context, tx *query.Transaction, name string) error

+ Savepoint func(ctx context.Context, tx *query.Transaction, name string) error

Aug 27, 2020

Changes in this version

type Repository

+ UpdateModels func(ctx context.Context, s *query.Scope) (int64, error)

Aug 9, 2020

Changes in this version

+ var ErrAuthorization = errors.Wrap(ErrRepository, "authorization")

+ var ErrConnection = errors.Wrap(ErrRepository, "connection")

+ var ErrNotImplements = errors.Wrap(ErrRepository, "not implements")

+ var ErrRepository = errors.New("repository")

+ var ErrReservedName = errors.Wrap(ErrRepository, "reserved name")

Aug 7, 2020

Changes in this version

+ var ClassAuthorization errors.Class

+ var ClassConnection errors.Class

+ var ClassReservedName errors.Class

+ var ClassService errors.Class

+ type Closer interface

+ Close func(ctx context.Context) error

+ type Dialer interface

+ Dial func(ctx context.Context) error

+ type Exister interface

+ Exists func(context.Context, *query.Scope) (bool, error)

+ type HealthChecker interface

+ HealthCheck func(ctx context.Context) (*HealthResponse, error)

+ type ModelRegistrar interface

+ RegisterModels func(models ...*mapping.ModelStruct) error

+ type Option func(o *Options)

+ func WithDatabase(db string) Option

+ func WithHost(host string) Option

+ func WithMaxTimeout(maxTimeout time.Duration) Option

+ func WithPassword(password string) Option

+ func WithPort(port int) Option

+ func WithProtocol(proto string) Option

+ func WithTLSConfig(tlsConfig *tls.Config) Option

+ func WithURI(uri string) Option

+ func WithUsername(username string) Option

+ type Options struct

+ Database string

+ Host string

+ MaxTimeout *time.Duration

+ Password string

+ Port uint16

+ Protocol string

+ TLSConfig *tls.Config

+ URI string

+ Username string

type Repository

+ Count func(ctx context.Context, s *query.Scope) (int64, error)

+ Delete func(ctx context.Context, s *query.Scope) (int64, error)

+ Find func(ctx context.Context, s *query.Scope) error

+ Insert func(ctx context.Context, s *query.Scope) error

+ Update func(ctx context.Context, s *query.Scope) (int64, error)

+ type Runner interface

+ Run func(ctx context.Context) error

+ type Transactioner interface

+ Begin func(ctx context.Context, tx *query.Transaction) error

+ Commit func(ctx context.Context, tx *query.Transaction) error

+ ID func() string

+ Rollback func(ctx context.Context, tx *query.Transaction) error

+ type Upserter interface

+ Upsert func(ctx context.Context, s *query.Scope) error

May 11, 2020

Changes in this version

+ var ClassFactoryAlreadyRegistered errors.Class

+ var ClassNotImplements errors.Class

+ var MjrRepository errors.Major

type Factory

+ DriverName func() string

+ type HealthResponse struct

+ Notes []string

+ Output string

+ Status HealthStatus

+ type HealthStatus int

+ const StatusFail

+ const StatusPass

+ const StatusWarn

+ func (s HealthStatus) MarshalText() ([]byte, error)

+ func (s HealthStatus) String() string

+ type Migrator interface

+ MigrateModels func(ctx context.Context, models ...*mapping.ModelStruct) error

+ type Proxy interface

type Repository

+ Dial func(ctx context.Context) error

+ FactoryName func() string

+ HealthCheck func(ctx context.Context) (*HealthResponse, error)

+ ID func() string

+ RegisterModels func(models ...*mapping.ModelStruct) error

May 30, 2019

Changes in this version

+ func CloseAll(ctx context.Context) error

+ type FactoryCloser interface

+ Close func(ctx context.Context, done chan<- interface{})

+ type Namer interface

+ RepositoryName func() string

type Repository

+ Close func(ctx context.Context) error

May 26, 2019

Changes in this version

+ func RegisterFactory(f Factory) error

+ type Factory interface

+ New func(structer ModelStructer, model *mapping.ModelStruct) (Repository, error)

+ func GetFactory(name string) Factory

+ type ModelStructer interface

+ ModelStruct func(model interface{}) (*mapping.ModelStruct, error)

+ type Repository interface

+ RepositoryName func() string

+ func GetRepository(structer ModelStructer, model interface{}) (Repository, error)