repository

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

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

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

type KeyValStoreIn interface {
	Set(context.Context, string, string, time.Duration) error
	Get(context.Context, string) (string, error)
	Del(ctx context.Context, key []string) (int64, error)
}

type NoSQL interface {
	Store(context.Context, string, interface{}) error
	Update(context.Context, string, interface{}, interface{}) error
	FindAll(context.Context, string, interface{}, interface{}) error
	FindOne(context.Context, string, interface{}, interface{}, interface{}) error
	Delete(context.Context, string, interface{}) error
	StartSession() (Session, error)
}

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

type Row interface {
	Scan(dest ...interface{}) error
}

type Rows interface {
	Scan(dest ...interface{}) error
	Next() bool
	Err() error
	Close() error
}

type SQL interface {
	ExecuteContext(context.Context, string, ...interface{}) error
	QueryContext(context.Context, string, ...interface{}) (Rows, error)
	QueryRowContext(context.Context, string, ...interface{}) Row
	BeginTx(ctx context.Context) (Tx, error)
}

type Session interface {
	WithTransaction(context.Context, func(context.Context) error) error
	EndSession(context.Context)
}

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

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

type Tx interface {
	ExecuteContext(context.Context, string, ...interface{}) error
	QueryContext(context.Context, string, ...interface{}) (Rows, error)
	QueryRowContext(context.Context, string, ...interface{}) Row
	Commit() error
	Rollback() error
}

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