workflow

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

type BackfillerParams struct {
	fx.In
	fxparams.Params
	Runtime   cadence.Runtime
	Reader    *activity.Reader
	Extractor *activity.Extractor
	Loader    *activity.Loader
}

type BackfillerRequest struct {
	Tag                     uint32
	StartHeight             uint64
	EndHeight               uint64 `validate:"gt=0,gtfield=StartHeight"`
	UpdateWatermark         bool
	NumConcurrentExtractors int     // Optional. If not specified, it is read from the workflow config.
	BatchSize               uint64  // Optional. If not specified, it is read from the workflow config.
	MiniBatchSize           uint64  // Optional. If not specified, it is read from the workflow config.
	CheckpointSize          uint64  // Optional. If not specified, it is read from the workflow config.
	MaxReprocessedPerBatch  uint64  // Optional. If not specified, it is read from the workflow config.
	RehydrateFromTag        *uint32 // Optional. If not specified, rehydration is disabled.
	UpgradeFromTag          *uint32 // Optional. If not specified, upgrade is disabled.
	DataCompression         string  // Optional. If not specified, it is read from the workflow config.
	Failover                bool    // Optional. If not specified, it is set as false.
}

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

type BenchmarkerParams struct {
	fx.In
	fxparams.Params
	Runtime cadence.Runtime
	Config  *config.Config
}

type BenchmarkerRequest struct {
	Tag                     uint32
	StartHeight             uint64
	EndHeight               uint64 `validate:"gt=0,gtfield=StartHeight"`
	StepSize                uint64 `validate:"gt=0"`
	SamplesToTest           uint64 `validate:"gt=0"`
	NumConcurrentExtractors int    `validate:"gt=0"`
	MiniBatchSize           uint64
}

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

type CrossValidatorParams struct {
	fx.In
	fxparams.Params
	Runtime        cadence.Runtime
	CrossValidator *activity.CrossValidator
}

type CrossValidatorRequest struct {
	StartHeight             uint64
	Tag                     uint32
	ValidationHeightPadding uint64 // Optional. If not specified, it is read from the workflow config.
	BatchSize               uint64 // Optional. If not specified, it is read from the workflow config.
	CheckpointSize          uint64 // Optional. If not specified, it is read from the workflow config.
	Parallelism             int    // Optional. If not specified, it is read from the workflow config.
	BackoffInterval         string // Optional. If not specified, it is read from the workflow config.
}

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

type EventBackfillerParams struct {
	fx.In
	fxparams.Params
	Runtime         cadence.Runtime
	EventReader     *activity.EventReader
	EventReconciler *activity.EventReconciler
	EventLoader     *activity.EventLoader
}

type EventBackfillerRequest struct {
	Tag                 uint32
	EventTag            uint32
	UpgradeFromEventTag uint32
	StartSequence       uint64 `validate:"gt=0"`
	EndSequence         uint64 `validate:"gt=0,gtfield=StartSequence"`
	BatchSize           uint64 // Optional. If not specified, it is read from the workflow config.
	CheckpointSize      uint64 // Optional. If not specified, it is read from the workflow config.
}

type InstrumentedRequest interface {
	GetTags() map[string]string
}

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

type ManagerParams struct {
	fx.In
	fxparams.Params
	Lifecycle       fx.Lifecycle
	Runtime         cadence.Runtime
	Backfiller      *Backfiller
	Poller          *Poller
	Benchmarker     *Benchmarker
	Monitor         *Monitor
	Streamer        *Streamer
	CrossValidator  *CrossValidator
	EventBackfiller *EventBackfiller
	Replicator      *Replicator
}

type MetricOption func(scope tally.Scope) tally.Scope

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

type MonitorParams struct {
	fx.In
	fxparams.Params
	Runtime   cadence.Runtime
	Validator *activity.Validator
}

type MonitorRequest struct {
	StartHeight             uint64
	Tag                     uint32
	StartEventId            int64  // Optional. If not specified or less than metastorage.EventIdStartValue, it will be set as metastorage.EventIdStartValue.
	ValidationHeightPadding uint64 // Optional. If not specified, it is read from the workflow config.
	BatchSize               uint64 // Optional. If not specified, it is read from the workflow config.
	EventBatchSize          uint64 // Optional. If not specified, it is read from the workflow config.
	CheckpointSize          uint64 // Optional. If not specified, it is read from the workflow config.
	BackoffInterval         string // Optional. If not specified, it is read from the workflow config.
	Parallelism             int    // Optional. If not specified, it is read from the workflow config.
	EventTag                uint32 // Optional.
	Failover                bool   // Optional. If not specified, it is set as false.
}

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

type PollerParams struct {
	fx.In
	fxparams.Params
	Runtime       cadence.Runtime
	Syncer        *activity.Syncer
	LivenessCheck *activity.LivenessCheck
}

type PollerRequest struct {
	Tag                          uint32
	MinStartHeight               uint64
	MaxBlocksToSync              uint64
	BackoffInterval              string
	Parallelism                  int
	CheckpointSize               uint64
	DataCompression              string
	RetryableErrorCount          int
	Failover                     bool
	ConsensusFailover            bool
	FastSync                     bool
	NumBlocksToSkip              uint64
	TransactionsWriteParallelism int
	ConsensusValidation          *bool
	ConsensusValidationMuted     *bool
	State                        *PollerState
}

type PollerState struct {
	LastLivenessCheckTimestamp  int64
	LivenessCheckViolationCount uint64
}

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

type ReplicatorParams struct {
	fx.In
	fxparams.Params
	Runtime         cadence.Runtime
	Replicator      *activity.Replicator
	UpdateWatermark *activity.UpdateWatermark
}

type ReplicatorRequest struct {
	Tag             uint32
	StartHeight     uint64
	EndHeight       uint64 `validate:"gt=0,gtfield=StartHeight"`
	UpdateWatermark bool
	DataCompression string // Optional. If not specified, it is read from the workflow config.
	BatchSize       uint64 // Optional. If not specified, it is read from the workflow config.
	MiniBatchSize   uint64 // Optional. If not specified, it is read from the workflow config.
	CheckpointSize  uint64 // Optional. If not specified, it is read from the workflow config.
	Parallelism     int    // Optional. If not specified, it is read from the workflow config.
}

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

type StreamerParams struct {
	fx.In
	fxparams.Params
	Runtime  cadence.Runtime
	Streamer *activity.Streamer
}

type StreamerRequest struct {
	BatchSize             uint64 // Optional. If not specified, it is read from the workflow config.
	CheckpointSize        uint64 // Optional. If not specified, it is read from the workflow config.
	BackoffInterval       string // Optional. If not specified, it is read from the workflow config.
	MaxAllowedReorgHeight uint64 // Optional. If not specified, it is read from the workflow config.
	EventTag              uint32 // Optional.
	Tag                   uint32 // Optional.
}

type WorkflowIdentity int