Documentation ¶
Index ¶
- type Config
- type Extractor
- func (ext *Extractor) BeginTxn(shard consumer.Shard, store consumer.Store) error
- func (*Extractor) ConsumeMessage(_ consumer.Shard, store consumer.Store, envelope message.Envelope, ...) error
- func (ext *Extractor) FinalizeTxn(shard consumer.Shard, store consumer.Store, publisher *message.Publisher) error
- func (ext *Extractor) FinishedTxn(shard consumer.Shard, store consumer.Store, op client.OpFuture)
- func (ext *Extractor) InitApplication(args runconsumer.InitArgs) error
- func (Extractor) NewConfig() runconsumer.Config
- func (ext *Extractor) NewMessage(spec *broker.JournalSpec) (message.Message, error)
- func (ext *Extractor) NewStore(shard consumer.Shard, rec *recoverylog.Recorder) (consumer.Store, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Config ¶
type Config struct { Factable CommonConfig `group:"Factable" namespace:"factable"` runconsumer.BaseConfig }
Config utilized by Extractor.
type Extractor ¶
type Extractor struct { Extractors factable.ExtractFns // contains filtered or unexported fields }
Extractor is a runconsumer.Application which extracts and locally combines relation DeltaEvents from events of an input journal.
func (*Extractor) ConsumeMessage ¶
func (*Extractor) FinalizeTxn ¶
func (*Extractor) FinishedTxn ¶
func (*Extractor) InitApplication ¶
func (ext *Extractor) InitApplication(args runconsumer.InitArgs) error
InitApplication initializes the Extractor.
func (Extractor) NewConfig ¶
func (Extractor) NewConfig() runconsumer.Config
NewConfig returns a new Spec.
func (*Extractor) NewMessage ¶
Click to show internal directories.
Click to hide internal directories.