Documentation
¶
Index ¶
- func New(ctx context.Context, dataSourceName string, tlsInfo tls.Config, ...) (server.Backend, error)
- type OracleDialect
- func (o OracleDialect) After(ctx context.Context, prefix string, rev, limit int64) (*sql.Rows, error)
- func (o OracleDialect) BeginTx(ctx context.Context, opts *sql.TxOptions) (server.Transaction, error)
- func (o OracleDialect) Compact(ctx context.Context, revision int64) (int64, error)
- func (o OracleDialect) Count(ctx context.Context, prefix string) (int64, int64, error)
- func (o OracleDialect) CurrentRevision(ctx context.Context) (int64, error)
- func (o OracleDialect) DeleteRevision(ctx context.Context, revision int64) error
- func (o OracleDialect) Fill(ctx context.Context, revision int64) error
- func (o OracleDialect) FillRetryDelay(ctx context.Context)
- func (o OracleDialect) GetCompactRevision(ctx context.Context) (int64, error)
- func (o OracleDialect) GetRevision(ctx context.Context, revision int64) (*sql.Rows, error)
- func (o OracleDialect) GetSize(ctx context.Context) (int64, error)
- func (o OracleDialect) Insert(ctx context.Context, key string, create, delete bool, ...) (id int64, err error)
- func (o OracleDialect) IsFill(key string) bool
- func (o OracleDialect) List(ctx context.Context, prefix, startKey string, limit, revision int64, ...) (*sql.Rows, error)
- func (o OracleDialect) ListCurrent(ctx context.Context, prefix string, limit int64, includeDeleted bool) (*sql.Rows, error)
- func (o *OracleDialect) Migrate(ctx context.Context)
- func (o OracleDialect) PostCompact(ctx context.Context) error
- func (o OracleDialect) SetCompactRevision(ctx context.Context, revision int64) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func New ¶
func New(ctx context.Context, dataSourceName string, tlsInfo tls.Config, connPoolConfig generic.ConnectionPoolConfig, metricsRegisterer prometheus.Registerer) (server.Backend, error)
Types ¶
type OracleDialect ¶
type OracleDialect struct {
DB *sql.DB
GormDB *gorm.DB
KineTable *kine.Kine
PostCompactSQL string
GetSizeSQL string
FillRetryDuration time.Duration
Retry generic.ErrRetry
InsertRetry generic.ErrRetry
TranslateErr generic.TranslateErr
ErrCode generic.ErrCode
// contains filtered or unexported fields
}
func NewOracleDialect ¶
func NewOracleDialect(ctx context.Context, dataSourceName string, connPoolConfig generic.ConnectionPoolConfig, metricsRegisterer prometheus.Registerer) (*OracleDialect, error)
func (OracleDialect) BeginTx ¶
func (o OracleDialect) BeginTx(ctx context.Context, opts *sql.TxOptions) (server.Transaction, error)
func (OracleDialect) CurrentRevision ¶
func (o OracleDialect) CurrentRevision(ctx context.Context) (int64, error)
func (OracleDialect) DeleteRevision ¶
func (o OracleDialect) DeleteRevision(ctx context.Context, revision int64) error
func (OracleDialect) FillRetryDelay ¶
func (o OracleDialect) FillRetryDelay(ctx context.Context)
func (OracleDialect) GetCompactRevision ¶
func (o OracleDialect) GetCompactRevision(ctx context.Context) (int64, error)
func (OracleDialect) GetRevision ¶
func (OracleDialect) IsFill ¶
func (o OracleDialect) IsFill(key string) bool
func (OracleDialect) ListCurrent ¶
func (*OracleDialect) Migrate ¶
func (o *OracleDialect) Migrate(ctx context.Context)
func (OracleDialect) PostCompact ¶
func (o OracleDialect) PostCompact(ctx context.Context) error
func (OracleDialect) SetCompactRevision ¶
func (o OracleDialect) SetCompactRevision(ctx context.Context, revision int64) error
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.