tasks

Documentation

Index

• Variables
• type Map
  • func New[T any]() Map[T]
• type TaskData
• type Tasks
  • func Init[DT any](s stream.Stream, dataTypeName, dataTypeVersion string, ...) (ed Tasks[DT], err error)

Variables

var NothingToSelectError = fmt.Errorf("nothing to select")

Types

type Map

type Map[T any] interface {
	Store(id string, data T)
	Load(id string) (data T, ok bool)
	Delete(id string)
	Range(f func(k string, v T) bool)
}

func New

func New[T any]() Map[T]

type TaskData

type TaskData[DT any] struct {
	Id       uuid.UUID `json:"id"`
	Data     DT        `json:"data"`
	TimeOut  time.Time `json:"time_out,omitempty"`
	Selector string    `json:"selector"`
	Next     uuid.UUID `json:"next_id"`
}

type Tasks

type Tasks[DT any] interface {
	Create(uuid.UUID, DT) error
	Select() (TaskData[DT], error)
	Finish(uuid.UUID) error
}

func Init

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