oracle

package
v0.0.11 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 18, 2023 License: Apache-2.0 Imports: 22 Imported by: 0

Documentation

Index

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) After

func (o OracleDialect) After(ctx context.Context, prefix string, rev, limit int64) (*sql.Rows, error)

func (OracleDialect) BeginTx

func (o OracleDialect) BeginTx(ctx context.Context, opts *sql.TxOptions) (server.Transaction, error)

func (OracleDialect) Compact

func (o OracleDialect) Compact(ctx context.Context, revision int64) (int64, error)

func (OracleDialect) Count

func (o OracleDialect) Count(ctx context.Context, prefix string) (int64, int64, 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) Fill

func (o OracleDialect) Fill(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 (o OracleDialect) GetRevision(ctx context.Context, revision int64) (*sql.Rows, error)

func (OracleDialect) GetSize

func (o OracleDialect) GetSize(ctx context.Context) (int64, error)

func (OracleDialect) Insert

func (o OracleDialect) Insert(ctx context.Context, key string, create, delete bool, createRevision, previousRevision int64, ttl int64, value, prevValue []byte) (id int64, err error)

func (OracleDialect) IsFill

func (o OracleDialect) IsFill(key string) bool

func (OracleDialect) List

func (o OracleDialect) List(ctx context.Context, prefix, startKey string, limit, revision int64, includeDeleted bool) (*sql.Rows, error)

func (OracleDialect) ListCurrent

func (o OracleDialect) ListCurrent(ctx context.Context, prefix string, limit int64, includeDeleted bool) (*sql.Rows, error)

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

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL