MCPcopy Create free account

hub / github.com/cloudwego/eino / functions

Functions3,994 in github.com/cloudwego/eino

⨍ Functions 3,994◇ Types & classes 1,204
FunctionTestTurnLoop_DeleteWithoutCheckPointDeleter_NoOp
(t *testing.T)
adk/turn_loop_test.go:4473
FunctionTestTurnLoop_GenInputError
(t *testing.T)
adk/turn_loop_test.go:305
FunctionTestTurnLoop_GenInputError_RecoverItems
(t *testing.T)
adk/turn_loop_test.go:981
FunctionTestTurnLoop_GenResumeNil_Error
(t *testing.T)
adk/turn_loop_test.go:2152
FunctionTestTurnLoop_GenResumeReturnsError
(t *testing.T)
adk/turn_loop_test.go:2299
FunctionTestTurnLoop_GetAgentError
(t *testing.T)
adk/turn_loop_test.go:321
FunctionTestTurnLoop_GetAgentError_RecoverConsumed
(t *testing.T)
adk/turn_loop_test.go:957
FunctionTestTurnLoop_OnAgentEventsError
(t *testing.T)
adk/turn_loop_test.go:2661
FunctionTestTurnLoop_OnAgentEventsReceivesEvents
(t *testing.T)
adk/turn_loop_test.go:1167
FunctionTestTurnLoop_PreemptAck_ClosesAfterCancelIsInitiated
(t *testing.T)
adk/turn_loop_test.go:544
FunctionTestTurnLoop_PreemptAck_ClosesImmediatelyIfLoopNotStarted
(t *testing.T)
adk/turn_loop_test.go:578
FunctionTestTurnLoop_PreemptBetweenTurnsAcksImmediately
(t *testing.T)
adk/turn_loop_test.go:3544
FunctionTestTurnLoop_PreemptDelay_NoMispreemptOnNaturalCompletion
(t *testing.T)
adk/turn_loop_test.go:739
FunctionTestTurnLoop_PreemptDuringPlanningCancelsUpcomingAgent
(t *testing.T)
adk/turn_loop_test.go:804
FunctionTestTurnLoop_PreemptThenStop_InterruptedItems_ReflectsStoppedTurn
TestTurnLoop_PreemptThenStop_InterruptedItems_ReflectsStoppedTurn verifies that when a preempt interrupts turn 1 and then Stop(WithImmediate()) cancel
adk/turn_loop_test.go:1702
FunctionTestTurnLoop_Preempt_CancelsCurrentAgent
(t *testing.T)
adk/turn_loop_test.go:383
FunctionTestTurnLoop_Preempt_DiscardsConsumedItems
(t *testing.T)
adk/turn_loop_test.go:440
FunctionTestTurnLoop_Preempt_EscalatesOnSecondPreempt
(t *testing.T)
adk/turn_loop_test.go:591
FunctionTestTurnLoop_Preempt_JoinsSafePointModesOnSecondPreempt
(t *testing.T)
adk/turn_loop_test.go:648
FunctionTestTurnLoop_Preempt_LoopStalledAfterSecondPreemptPush
TestTurnLoop_Preempt_LoopStalledAfterSecondPreemptPush covers a liveness regression where a preempted turn was followed by another preemptive Push and
adk/turn_loop_test.go:5909
FunctionTestTurnLoop_Preempt_WithAgentCancelMode
(t *testing.T)
adk/turn_loop_test.go:507
FunctionTestTurnLoop_PrepareAgentError_RecoverItemsInOrder
(t *testing.T)
adk/turn_loop_test.go:1001
FunctionTestTurnLoop_PushAfterStop_BufferedAsLateItems
(t *testing.T)
adk/turn_loop_test.go:4244
FunctionTestTurnLoop_PushAfterTakeLateItems_Panics
(t *testing.T)
adk/turn_loop_test.go:4302
FunctionTestTurnLoop_PushFromOnAgentEvents
(t *testing.T)
adk/turn_loop_test.go:2701
FunctionTestTurnLoop_PushStrategy_BetweenTurns
(t *testing.T)
adk/turn_loop_test.go:4026
FunctionTestTurnLoop_PushStrategy_ConsumedInspection
(t *testing.T)
adk/turn_loop_test.go:4184
FunctionTestTurnLoop_PushStrategy_DuringTurn
(t *testing.T)
adk/turn_loop_test.go:3960
FunctionTestTurnLoop_PushStrategy_DuringTurnTransition
(t *testing.T)
adk/turn_loop_test.go:3605
FunctionTestTurnLoop_PushStrategy_NestedStrategyStripped
(t *testing.T)
adk/turn_loop_test.go:4129
FunctionTestTurnLoop_PushStrategy_OverridesOtherOptions
(t *testing.T)
adk/turn_loop_test.go:4080
FunctionTestTurnLoop_Push_WithPreemptTimeout_RecursivePropagation
(t *testing.T)
adk/turn_loop_test.go:5849
FunctionTestTurnLoop_Push_WithoutPreempt_DoesNotCancel
(t *testing.T)
adk/turn_loop_test.go:704
FunctionTestTurnLoop_ResumeInterruptAgain_PreservesEnableStreamingCheckpoint
(t *testing.T)
adk/turn_loop_test.go:2510
FunctionTestTurnLoop_ResumeWaitsForInFlightPushBeforePlanning
(t *testing.T)
adk/turn_loop_test.go:2349
FunctionTestTurnLoop_ResumeWithParams
(t *testing.T)
adk/turn_loop_test.go:2441
FunctionTestTurnLoop_RunCtx_Propagation
(t *testing.T)
adk/turn_loop_test.go:2878
FunctionTestTurnLoop_SameCheckpointID_OverwritePattern
(t *testing.T)
adk/turn_loop_test.go:2198
FunctionTestTurnLoop_SkipCheckpoint_Sticky
(t *testing.T)
adk/turn_loop_test.go:4760
FunctionTestTurnLoop_StaleCheckpointDeletion_OnCleanResume
(t *testing.T)
adk/turn_loop_test.go:2038
FunctionTestTurnLoop_StopAfterGenInput_RecoverConsumed
(t *testing.T)
adk/turn_loop_test.go:926
FunctionTestTurnLoop_StopAfterReceive_RecoverItem
(t *testing.T)
adk/turn_loop_test.go:902
FunctionTestTurnLoop_StopBeforeRun_PushThenStop
(t *testing.T)
adk/turn_loop_test.go:4705
FunctionTestTurnLoop_StopBeforeRun_StopThenPush
(t *testing.T)
adk/turn_loop_test.go:4732
FunctionTestTurnLoop_StopBetweenTurnsAndResume
(t *testing.T)
adk/turn_loop_test.go:1536
FunctionTestTurnLoop_StopCallFromGenInput
(t *testing.T)
adk/turn_loop_test.go:2685
FunctionTestTurnLoop_StopCancel_InterruptedItems_PersistAndRestore
TestTurnLoop_StopCancel_InterruptedItems_PersistAndRestore verifies the full lifecycle: Stop(WithImmediate()) cancels a running agent, the exit state
adk/turn_loop_test.go:1598
FunctionTestTurnLoop_StopCause_EmptyWhenNoStop
(t *testing.T)
adk/turn_loop_test.go:4610
FunctionTestTurnLoop_StopCause_FirstNonEmptyWins
(t *testing.T)
adk/turn_loop_test.go:4671
FunctionTestTurnLoop_StopCause_InTurnContext
(t *testing.T)
adk/turn_loop_test.go:4623
FunctionTestTurnLoop_StopCheckPointIDInCancelError
(t *testing.T)
adk/turn_loop_test.go:1283
FunctionTestTurnLoop_StopConcurrentWithCallbackError_NoCheckpoint
(t *testing.T)
adk/turn_loop_test.go:4416
FunctionTestTurnLoop_StopIsIdempotent
(t *testing.T)
adk/turn_loop_test.go:235
FunctionTestTurnLoop_StopWhileIdle_SkipsCheckpoint
(t *testing.T)
adk/turn_loop_test.go:1512
FunctionTestTurnLoop_StopWithMode
(t *testing.T)
adk/turn_loop_test.go:371
FunctionTestTurnLoop_StopWithSkipCheckpoint
(t *testing.T)
adk/turn_loop_test.go:4525
FunctionTestTurnLoop_StopWithSkipCheckpoint_DeletesStaleCheckpoint
(t *testing.T)
adk/turn_loop_test.go:4552
FunctionTestTurnLoop_StopWithStopCause
(t *testing.T)
adk/turn_loop_test.go:4594
FunctionTestTurnLoop_StopWithoutCheckpointIDDoesNotPersist
(t *testing.T)
adk/turn_loop_test.go:1468
FunctionTestTurnLoop_Stop_EscalatesCancelMode
(t *testing.T)
adk/turn_loop_test.go:2602
FunctionTestTurnLoop_Stop_WithImmediate_RecursivePropagation
(t *testing.T)
adk/turn_loop_test.go:5806
FunctionTestTurnLoop_TakeLateItems_Idempotent
(t *testing.T)
adk/turn_loop_test.go:4279
FunctionTestTurnLoop_TakeLateItems_NeverCalled_NoImpact
(t *testing.T)
adk/turn_loop_test.go:4321
FunctionTestTurnLoop_TurnContext_BothPreemptedAndStopped
(t *testing.T)
adk/turn_loop_test.go:3856
FunctionTestTurnLoop_TurnContext_PreemptedChannel
(t *testing.T)
adk/turn_loop_test.go:2934
FunctionTestTurnLoop_TurnContext_StoppedChannel
(t *testing.T)
adk/turn_loop_test.go:3809
FunctionTestTurnLoop_UnhandledItemsOnStop
(t *testing.T)
adk/turn_loop_test.go:275
FunctionTestTurnLoop_WaitMultipleGoroutines
(t *testing.T)
adk/turn_loop_test.go:249
FunctionTestTypedConsumeStream_AgenticMidStreamError
(t *testing.T)
adk/failover_chatmodel_test.go:711
FunctionTestTypedConsumeStream_EmptyAgenticStream
(t *testing.T)
adk/failover_chatmodel_test.go:702
FunctionTestTypedToolEnhancedEventAgenticToolSearchResult
(t *testing.T)
adk/wrappers_test.go:2116
FunctionTestTypedToolEnhancedStreamEventAgenticMessageSetsStreamingMeta
(t *testing.T)
adk/wrappers_test.go:2010
FunctionTestTypedToolStreamEventAgenticMessageSetsStreamingMeta
(t *testing.T)
adk/wrappers_test.go:1977
FunctionTestUnboundedChan_BlockingReceive
(t *testing.T)
internal/channel_test.go:193
FunctionTestUnboundedChan_Close
(t *testing.T)
internal/channel_test.go:117
FunctionTestUnboundedChan_Concurrency
(t *testing.T)
internal/channel_test.go:130
FunctionTestUnboundedChan_Receive
(t *testing.T)
internal/channel_test.go:59
FunctionTestUnboundedChan_ReceiveFromClosed
(t *testing.T)
internal/channel_test.go:84
FunctionTestUnboundedChan_Send
(t *testing.T)
internal/channel_test.go:25
FunctionTestUnboundedChan_SendPanic
(t *testing.T)
internal/channel_test.go:45
FunctionTestUniqueSlice
(t *testing.T)
compose/graph_test.go:2068
FunctionTestUnknownTool
(t *testing.T)
compose/tool_node_test.go:682
FunctionTestUntilIdleFor
(t *testing.T)
adk/turn_loop_test.go:4848
FunctionTestUntilIdleFor_ContextCancelDuringIdleWait
(t *testing.T)
adk/turn_loop_test.go:5149
FunctionTestUntilIdleFor_DoesNotCancelRunningAgent
TestUntilIdleFor_DoesNotCancelRunningAgent verifies that Stop(UntilIdleFor) records an idle stop policy but does NOT create a pending cancel request f
adk/turn_loop_test.go:5016
FunctionTestUntilIdleFor_NonPositive_Panics
(t *testing.T)
adk/turn_loop_test.go:5884
FunctionTestUseMultiModalRead_Routing
(t *testing.T)
adk/middlewares/filesystem/filesystem_test.go:2434
FunctionTestUserAgenticMessage
(t *testing.T)
schema/agentic_message_test.go:1566
FunctionTestValidate
(t *testing.T)
compose/graph_test.go:346
FunctionTestValidateMultiAnyValueBranch
(t *testing.T)
compose/graph_test.go:640
FunctionTestValidatePages
(t *testing.T)
adk/middlewares/filesystem/filesystem_test.go:2616
FunctionTestValidateType
(t *testing.T)
compose/utils_test.go:47
FunctionTestValues
(t *testing.T)
internal/gmap/gmap_test.go:55
FunctionTestWillRetryError_RejectReason
(t *testing.T)
adk/chatmodel_retry_test.go:3190
FunctionTestWillRetryError_Unwrap
(t *testing.T)
adk/chatmodel_retry_test.go:770
FunctionTestWithCallbacksOption
(t *testing.T)
adk/callback_test.go:216
FunctionTestWithCancel_AfterBusinessInterrupt
TestWithCancel_AfterBusinessInterrupt verifies cancelFn returns ErrExecutionEnded when called after the agent has been interrupted by business logic.
adk/cancel_edge_test.go:298
FunctionTestWithCancel_AfterChatModel_WithTools
TestWithCancel_AfterChatModel_WithTools verifies CancelAfterChatModel fires when the model returns tool calls (the safe-point is on the tool-calls pat
adk/cancel_edge_test.go:432
FunctionTestWithCancel_AfterCompletion
TestWithCancel_AfterCompletion verifies cancelFn returns ErrExecutionEnded when called after a normal run finishes.
adk/cancel_edge_test.go:235
FunctionTestWithCancel_AfterError
TestWithCancel_AfterError verifies cancelFn returns ErrExecutionEnded when called after the agent errors out.
adk/cancel_edge_test.go:340
← previousnext →3,501–3,600 of 3,994, ranked by callers