action

Documentation

Index

• type Action
  • func NewAction[E storage.Entry](mode Moder[E]) *Action[E]
  • func (a *Action[E]) Done()
  • func (a *Action[E]) Finish() error
  • func (a *Action[E]) Output() []string
  • func (a *Action[E]) Prepare() error
  • func (a *Action[E]) Receive(items []E)
  • func (a *Action[E]) Run() error
  • func (a *Action[E]) State() []string
  • func (a *Action[E]) Summary() string
• type Actor
• type Moder

Types

type Action

type Action[E storage.Entry] struct {
	// contains filtered or unexported fields
}

func NewAction

func NewAction[E storage.Entry](mode Moder[E]) *Action[E]

func (*Action[E]) Done

func (a *Action[E]) Done()

func (*Action[E]) Finish

func (a *Action[E]) Finish() error

func (*Action[E]) Output

func (a *Action[E]) Output() []string

func (*Action[E]) Prepare

func (a *Action[E]) Prepare() error

func (*Action[E]) Receive

func (a *Action[E]) Receive(items []E)

func (*Action[E]) Run

func (a *Action[E]) Run() error

func (*Action[E]) State

func (a *Action[E]) State() []string

func (*Action[E]) Summary

func (a *Action[E]) Summary() string

type Actor

type Actor[E storage.Entry] interface {
	Prepare() error // preparation before processing data
	Receive([]E)    // receive data asynchronously
	Run() error     // Process data
	Done()          // triggered after upstream data processing
	Finish() error  // data processing completed
	Summary() string
	State() []string
	Output() []string
}

type Moder

type Moder[E storage.Entry] interface {
	Concurrency() int
	Tasker() task.Tasker[E]

	// Run
	// amount: input amount
	// effected: output effected amount
	Run([]E) (int, int) // Process data
}