Documentation
¶
Index ¶
- func Actor(t *testing.T, e *flowstate.Engine, fr flowstate.FlowRegistry, ...)
- func CallFlow(t *testing.T, e *flowstate.Engine, fr flowstate.FlowRegistry, ...)
- func CallFlowWithCommit(t *testing.T, e *flowstate.Engine, fr flowstate.FlowRegistry, ...)
- func CallFlowWithWatch(t *testing.T, e *flowstate.Engine, fr flowstate.FlowRegistry, ...)
- func Condition(t *testing.T, e *flowstate.Engine, fr flowstate.FlowRegistry, ...)
- func Cron(t *testing.T, e *flowstate.Engine, fr flowstate.FlowRegistry, ...)
- func DataFlowConfig(t *testing.T, e *flowstate.Engine, fr flowstate.FlowRegistry, ...)
- func DataStoreGet(t *testing.T, e *flowstate.Engine, fr flowstate.FlowRegistry, ...)
- func DataStoreGetWithCommit(t *testing.T, e *flowstate.Engine, fr flowstate.FlowRegistry, ...)
- func Delay(t *testing.T, e *flowstate.Engine, fr flowstate.FlowRegistry, ...)
- func Fork(t *testing.T, e *flowstate.Engine, fr flowstate.FlowRegistry, ...)
- func ForkJoin_FirstWins(t *testing.T, e *flowstate.Engine, fr flowstate.FlowRegistry, ...)
- func ForkJoin_LastWins(t *testing.T, e *flowstate.Engine, fr flowstate.FlowRegistry, ...)
- func Fork_WithCommit(t *testing.T, e *flowstate.Engine, fr flowstate.FlowRegistry, ...)
- func GetData(t *testing.T, e *flowstate.Engine, _ flowstate.FlowRegistry, ...)
- func GetManyLabels(t *testing.T, e *flowstate.Engine, _ flowstate.FlowRegistry, ...)
- func GetManyLatestOnly(t *testing.T, e *flowstate.Engine, fr flowstate.FlowRegistry, ...)
- func GetManyORLabels(t *testing.T, e *flowstate.Engine, fr flowstate.FlowRegistry, ...)
- func GetManySinceLatest(t *testing.T, e *flowstate.Engine, fr flowstate.FlowRegistry, ...)
- func GetManySinceRev(t *testing.T, e *flowstate.Engine, fr flowstate.FlowRegistry, ...)
- func GetManySinceTime(t *testing.T, e *flowstate.Engine, fr flowstate.FlowRegistry, ...)
- func GetOneByIDAndRev(t *testing.T, e *flowstate.Engine, fr flowstate.FlowRegistry, ...)
- func GetOneLatestByID(t *testing.T, e *flowstate.Engine, fr flowstate.FlowRegistry, ...)
- func GetOneLatestByLabel(t *testing.T, e *flowstate.Engine, fr flowstate.FlowRegistry, ...)
- func GetOneNotFound(t *testing.T, e *flowstate.Engine, fr flowstate.FlowRegistry, ...)
- func Mutex(t *testing.T, e *flowstate.Engine, fr flowstate.FlowRegistry, ...)
- func NewTestLogger(t *testing.T) (*slog.Logger, *slogassert.Handler)
- func Queue(t *testing.T, e *flowstate.Engine, fr flowstate.FlowRegistry, ...)
- func RateLimit(t *testing.T, e *flowstate.Engine, fr flowstate.FlowRegistry, ...)
- func SingleNode(t *testing.T, e *flowstate.Engine, fr flowstate.FlowRegistry, ...)
- func StoreData(t *testing.T, e *flowstate.Engine, _ flowstate.FlowRegistry, ...)
- func ThreeConsequentNodes(t *testing.T, e *flowstate.Engine, fr flowstate.FlowRegistry, ...)
- func Track(stateCtx *flowstate.StateCtx, trkr *Tracker)
- func TwoConsequentNodes(t *testing.T, e *flowstate.Engine, fr flowstate.FlowRegistry, ...)
- func TwoConsequentNodesWithCommit(t *testing.T, e *flowstate.Engine, fr flowstate.FlowRegistry, ...)
- func WatchLabels(t *testing.T, e *flowstate.Engine, fr flowstate.FlowRegistry, ...)
- func WatchORLabels(t *testing.T, e *flowstate.Engine, fr flowstate.FlowRegistry, ...)
- func WatchSinceLatest(t *testing.T, e *flowstate.Engine, fr flowstate.FlowRegistry, ...)
- func WatchSinceRev(t *testing.T, e *flowstate.Engine, fr flowstate.FlowRegistry, ...)
- func WatchSinceTime(t *testing.T, e *flowstate.Engine, fr flowstate.FlowRegistry, ...)
- type Suite
- type Tracker
- func (trkr *Tracker) Visited() []string
- func (trkr *Tracker) VisitedSorted() []string
- func (trkr *Tracker) WaitSortedVisitedEqual(t *testing.T, expVisited []string, wait time.Duration) []string
- func (trkr *Tracker) WaitVisitedCountGreaterOrEqual(t *testing.T, expVisited int, wait time.Duration) []string
- func (trkr *Tracker) WaitVisitedEqual(t *testing.T, expVisited []string, wait time.Duration) []string
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CallFlowWithCommit ¶
func CallFlowWithWatch ¶
func DataFlowConfig ¶
func DataStoreGet ¶
func DataStoreGetWithCommit ¶
func ForkJoin_FirstWins ¶
func ForkJoin_LastWins ¶
func Fork_WithCommit ¶
func GetManyLabels ¶
func GetManyLatestOnly ¶
func GetManyORLabels ¶
func GetManySinceLatest ¶
func GetManySinceRev ¶
func GetManySinceTime ¶
func GetOneByIDAndRev ¶
func GetOneLatestByID ¶
func GetOneLatestByLabel ¶
func GetOneNotFound ¶
func NewTestLogger ¶
func SingleNode ¶
func ThreeConsequentNodes ¶
func TwoConsequentNodes ¶
func WatchLabels ¶
func WatchORLabels ¶
func WatchSinceLatest ¶
func WatchSinceRev ¶
func WatchSinceTime ¶
Types ¶
type Suite ¶
type Suite struct {
SetUp func(t *testing.T) flowstate.Driver
SetUpDelayer bool
// contains filtered or unexported fields
}
func (*Suite) DisableGoleak ¶
func (s *Suite) DisableGoleak()
type Tracker ¶
type Tracker struct {
IncludeTaskID bool
IncludeState bool
// contains filtered or unexported fields
}
func (*Tracker) VisitedSorted ¶
func (*Tracker) WaitSortedVisitedEqual ¶
func (*Tracker) WaitVisitedCountGreaterOrEqual ¶
Source Files
¶
- actor.go
- call_flow.go
- call_flow_with_commit.go
- call_flow_with_watch.go
- condition.go
- cron.go
- data_flow_config.go
- data_store_get.go
- data_store_get_with_commit.go
- delay.go
- fork.go
- fork_join_first_wins.go
- fork_join_last_wins.go
- fork_with_commit.go
- get_data.go
- get_many_labels.go
- get_many_latest_only.go
- get_many_or_labels.go
- get_many_since_latest.go
- get_many_since_rev.go
- get_many_since_time.go
- get_one_by_id_and_rev.go
- get_one_latest_by_id.go
- get_one_latest_by_label.go
- get_one_not_found.go
- log.go
- mutex.go
- queue.go
- rate_limit.go
- single_node.go
- store_data.go
- suite.go
- three_consequent_nodes.go
- tracker.go
- two_consequent_nodes.go
- two_consequent_nodes_with_commit.go
- watch_labels.go
- watch_or_labels.go
- watch_since_latest.go
- watch_since_rev.go
- watch_since_time.go
Click to show internal directories.
Click to hide internal directories.