logtracker

Documentation

Index

• Constants
• type EmbeddedLogPositionRow
• type EmbeddedLogTracker
  • func NewEmbeddedLogTracker(sqlxDB *sqlx.DB, config *oracle.OracleSource, transferID string) (*EmbeddedLogTracker, error)
  • func (tracker *EmbeddedLogTracker) ClearPosition() error
  • func (tracker *EmbeddedLogTracker) Init() error
  • func (tracker *EmbeddedLogTracker) ReadPosition() (*common.LogPosition, error)
  • func (tracker *EmbeddedLogTracker) TransferID() string
  • func (tracker *EmbeddedLogTracker) WritePosition(position *common.LogPosition) error
• type InMemoryLogTracker
  • func NewInMemoryLogTracker(transferID string) (*InMemoryLogTracker, error)
  • func (tracker *InMemoryLogTracker) ClearPosition() error
  • func (tracker *InMemoryLogTracker) Init() error
  • func (tracker *InMemoryLogTracker) ReadPosition() (*common.LogPosition, error)
  • func (tracker *InMemoryLogTracker) TransferID() string
  • func (tracker *InMemoryLogTracker) WritePosition(position *common.LogPosition) error
• type InternalLogTracker
  • func NewInternalLogTracker(controlPlaneClient coordinator.Coordinator, transferID string) (*InternalLogTracker, error)
  • func (tracker *InternalLogTracker) ClearPosition() error
  • func (tracker *InternalLogTracker) Init() error
  • func (tracker *InternalLogTracker) ReadPosition() (*common.LogPosition, error)
  • func (tracker *InternalLogTracker) TransferID() string
  • func (tracker *InternalLogTracker) WritePosition(position *common.LogPosition) error
• type LogTracker

Constants

const (
	OracleStateKey = "oracle_state"
)

Types

type EmbeddedLogPositionRow

type EmbeddedLogPositionRow struct {
	SCN       uint64    `db:"SCN"`
	RSID      *string   `db:"RS_ID"`
	SSN       *uint64   `db:"SSN"`
	Type      string    `db:"TYPE"`
	Timestamp time.Time `db:"TS"`
}

type EmbeddedLogTracker

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

func NewEmbeddedLogTracker

func NewEmbeddedLogTracker(sqlxDB *sqlx.DB, config *oracle.OracleSource, transferID string) (*EmbeddedLogTracker, error)

func (*EmbeddedLogTracker) ClearPosition

func (tracker *EmbeddedLogTracker) ClearPosition() error

func (*EmbeddedLogTracker) Init

func (tracker *EmbeddedLogTracker) Init() error

func (*EmbeddedLogTracker) ReadPosition

func (tracker *EmbeddedLogTracker) ReadPosition() (*common.LogPosition, error)

func (*EmbeddedLogTracker) TransferID

func (tracker *EmbeddedLogTracker) TransferID() string

func (*EmbeddedLogTracker) WritePosition

func (tracker *EmbeddedLogTracker) WritePosition(position *common.LogPosition) error

type InMemoryLogTracker

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

func NewInMemoryLogTracker

func NewInMemoryLogTracker(transferID string) (*InMemoryLogTracker, error)

func (*InMemoryLogTracker) ClearPosition

func (tracker *InMemoryLogTracker) ClearPosition() error

func (*InMemoryLogTracker) Init

func (tracker *InMemoryLogTracker) Init() error

func (*InMemoryLogTracker) ReadPosition

func (tracker *InMemoryLogTracker) ReadPosition() (*common.LogPosition, error)

func (*InMemoryLogTracker) TransferID

func (tracker *InMemoryLogTracker) TransferID() string

func (*InMemoryLogTracker) WritePosition

func (tracker *InMemoryLogTracker) WritePosition(position *common.LogPosition) error

type InternalLogTracker

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

func NewInternalLogTracker

func NewInternalLogTracker(controlPlaneClient coordinator.Coordinator, transferID string) (*InternalLogTracker, error)

func (*InternalLogTracker) ClearPosition

func (tracker *InternalLogTracker) ClearPosition() error

func (*InternalLogTracker) Init

func (tracker *InternalLogTracker) Init() error

func (*InternalLogTracker) ReadPosition

func (tracker *InternalLogTracker) ReadPosition() (*common.LogPosition, error)

func (*InternalLogTracker) TransferID

func (tracker *InternalLogTracker) TransferID() string

func (*InternalLogTracker) WritePosition

func (tracker *InternalLogTracker) WritePosition(position *common.LogPosition) error

type LogTracker

type LogTracker interface {
	TransferID() string
	Init() error
	ClearPosition() error
	ReadPosition() (*common.LogPosition, error)
	WritePosition(position *common.LogPosition) error
}