dispatchpayload

package

v0.1.58 Latest Latest Go to latest Published: Oct 26, 2026 License: Apache-2.0 Imports: 5 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/viant/agently-core

Links

Open Source Insights

Documentation ¶

Index ¶

func Active(ctx context.Context) bool
func CloneProvenance(src, dst context.Context) context.Context
func CloseProvenance(ctx context.Context)
func HasArtifactReference(value any) bool
func OriginalArguments(ctx context.Context) map[string]interface{}
func ResolveDispatchPayload(ctx context.Context, name string, args map[string]interface{}) (map[string]interface{}, func(string) string, error)
func Session(ctx context.Context, name string) (any, bool)
func SetOriginalArguments(ctx context.Context, args map[string]interface{})
func StoreSession(ctx context.Context, name string, session any, close func()) bool
func WithDispatchPayloadResolver(ctx context.Context, resolver DispatchPayloadResolver) context.Context
func WithState(ctx context.Context) (context.Context, func())
type DispatchPayloadResolver
type State

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func Active ¶

func Active(ctx context.Context) bool

func CloneProvenance ¶

func CloneProvenance(src, dst context.Context) context.Context

CloneProvenance transfers only process-owned original references and a lease on the same isolated RPC session to an existing owned async lifecycle.

func CloseProvenance ¶

func CloseProvenance(ctx context.Context)

func HasArtifactReference ¶

func HasArtifactReference(value any) bool

HasArtifactReference scans existing JSON arguments without cloning/serialization.

func OriginalArguments ¶

func OriginalArguments(ctx context.Context) map[string]interface{}

func ResolveDispatchPayload ¶

func ResolveDispatchPayload(ctx context.Context, name string, args map[string]interface{}) (map[string]interface{}, func(string) string, error)

func Session ¶

func Session(ctx context.Context, name string) (any, bool)

func SetOriginalArguments ¶

func SetOriginalArguments(ctx context.Context, args map[string]interface{})

func StoreSession ¶

func StoreSession(ctx context.Context, name string, session any, close func()) bool

func WithDispatchPayloadResolver ¶

func WithDispatchPayloadResolver(ctx context.Context, resolver DispatchPayloadResolver) context.Context

func WithState ¶

func WithState(ctx context.Context) (context.Context, func())

Types ¶

type DispatchPayloadResolver ¶

type DispatchPayloadResolver func(context.Context, string, map[string]interface{}) (map[string]interface{}, func(string) string, error)

DispatchPayloadResolver runs only at an authorized server dispatch boundary. sanitize must remove payload echoes before results enter logs or history.

type State ¶

type State struct {
	sync.Mutex
	// contains filtered or unexported fields
}

Source Files ¶

View all Source files

context.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL