tasks

Documentation

Index

• Constants
• type TaskMetadata
• type Tasks
  • func Init[DT any](s stream.Stream, consBuilder consensus.ConsBuilderFunc, ...) (ed Tasks[DT], err error)

Constants

const NoInterval time.Duration = 0

Types

type TaskMetadata

type TaskMetadata struct {
	Id       string        `json:"id"`
	After    time.Time     `json:"after"`
	Interval time.Duration `json:"interval"`
}

TaskMetadata temp changed task to be the id that is used for strong and id seems to now only be used for events.

type Tasks

type Tasks[DT any] interface {
	Create(string, time.Time, time.Duration, DT) error
	Tasks() (tasks []TaskMetadata)
}

func Init

func Init[DT any](s stream.Stream, consBuilder consensus.ConsBuilderFunc, dataTypeName, dataTypeVersion string, p stream.CryptoKeyProvider, execute func(DT, context.Context) bool, timeout time.Duration, skipable bool, workers int, ctx context.Context) (ed Tasks[DT], err error)