Retracted: Withdrawn; the module proxy serves these against commits that no longer exist here.
Documentation
¶
Index ¶
- type OracleSource
- func (o *OracleSource) Ack(ctx context.Context, msg hermod.Message) error
- func (o *OracleSource) Close() error
- func (o *OracleSource) DiscoverColumns(ctx context.Context, table string) ([]hermod.ColumnInfo, error)
- func (o *OracleSource) DiscoverDatabases(ctx context.Context) ([]string, error)
- func (o *OracleSource) DiscoverTables(ctx context.Context) ([]string, error)
- func (o *OracleSource) GetState() map[string]string
- func (o *OracleSource) Ping(ctx context.Context) error
- func (o *OracleSource) Read(ctx context.Context) (hermod.Message, error)
- func (o *OracleSource) Sample(ctx context.Context, table string) (hermod.Message, error)
- func (o *OracleSource) SetLogger(logger hermod.Logger)
- func (o *OracleSource) SetState(state map[string]string)
- func (o *OracleSource) Snapshot(ctx context.Context, tables ...string) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type OracleSource ¶
type OracleSource struct {
// contains filtered or unexported fields
}
OracleSource implements the hermod.Source interface for Oracle.
func NewOracleSource ¶
func (*OracleSource) Close ¶
func (o *OracleSource) Close() error
func (*OracleSource) DiscoverColumns ¶
func (o *OracleSource) DiscoverColumns(ctx context.Context, table string) ([]hermod.ColumnInfo, error)
func (*OracleSource) DiscoverDatabases ¶
func (o *OracleSource) DiscoverDatabases(ctx context.Context) ([]string, error)
func (*OracleSource) DiscoverTables ¶
func (o *OracleSource) DiscoverTables(ctx context.Context) ([]string, error)
func (*OracleSource) GetState ¶
func (o *OracleSource) GetState() map[string]string
func (*OracleSource) SetLogger ¶
func (o *OracleSource) SetLogger(logger hermod.Logger)
func (*OracleSource) SetState ¶
func (o *OracleSource) SetState(state map[string]string)
Source Files
Click to show internal directories.
Click to hide internal directories.