Versions in this module Expand all Collapse all v1 v1.1.0 Jun 15, 2026 Changes in this version + type DataSlot struct + func NewDataSlot() *DataSlot + func (s *DataSlot) Done() <-chan struct{} + func (s *DataSlot) Get(ctx context.Context) (any, error) + func (s *DataSlot) IsReady() bool + func (s *DataSlot) Set(value any) + func (s *DataSlot) SetOnce(value any) + func (s *DataSlot) SetOrUpdate(value any) + func (s *DataSlot) TryGet() (any, bool) + type FlowContext struct + func NewFlowContext(ctx context.Context) *FlowContext + func (c *FlowContext) Cancel(err error) + func (c *FlowContext) Done() <-chan struct{} + func (c *FlowContext) Err() error + func (c *FlowContext) Get(key string) (any, error) + func (c *FlowContext) GetContext() context.Context + func (c *FlowContext) GetError() error + func (c *FlowContext) IsReady(key string) bool + func (c *FlowContext) Set(key string, value any) + func (c *FlowContext) SetError(err error) error + func (c *FlowContext) SetOnce(key string, value any) + func (c *FlowContext) SetOrUpdate(key string, value any) + func (c *FlowContext) TryGet(key string) (any, bool) + func (c *FlowContext) Wait(key string) (any, error) + func (c *FlowContext) WaitAll(keys ...string) (map[string]any, error) + func (c *FlowContext) WaitAllWithContext(ctx context.Context, keys ...string) (map[string]any, error) + func (c *FlowContext) WaitForAny(keys ...string) (string, any, error) + func (c *FlowContext) WaitWithContext(ctx context.Context, key string) (any, error) + type SafeMap struct + func (s *SafeMap[K, V]) Clear() + func (s *SafeMap[K, V]) Delete(key K) + func (s *SafeMap[K, V]) Exist(key K) bool + func (s *SafeMap[K, V]) Get(key K) (V, bool) + func (s *SafeMap[K, V]) GetOrSet(key K, createFn func() V) V + func (s *SafeMap[K, V]) MustGet(key K) V + func (s *SafeMap[K, V]) Range(fn func(key K, value V) bool) + func (s *SafeMap[K, V]) Set(key K, value V)
Go to main page