oracle

Documentation

Index

• func New(ctx context.Context, dataSourceName string, tlsInfo tls.Config, ...) (server.Backend, error)
• type OracleDialect
  • func NewOracleDialect(ctx context.Context, dataSourceName string, ...) (*OracleDialect, error)
  • 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

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