tasks

Documentation

Index

• Constants
• type TaskMetadata
• type Tasks
  • func Init[DT any](s stream.Stream, dataTypeName, dataTypeVersion string, ...) (ed Tasks[DT], err error)

Constants

const NoInterval time.Duration = 0

Types

type TaskMetadata

type TaskMetadata struct {
	Id       uuid.UUID     `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(time.Time, time.Duration, DT) error
}

func Init

func Init[DT any](s stream.Stream, dataTypeName, dataTypeVersion string, p stream.CryptoKeyProvider, execute func(DT) bool, ctx context.Context) (ed Tasks[DT], err error)