Versions in this module Expand all Collapse all v3 v3.3.0 Jul 18, 2024 Changes in this version + func GetInteractshURLSFromEvent(event map[string]interface{}) []string + type StopAtFirstMatchHandler struct + ResultChan chan T + func NewBlockingSPMHandler[T comparable](ctx context.Context, size int, maxResults int, spm bool) *StopAtFirstMatchHandler[T] + func NewNonBlockingSPMHandler[T comparable](ctx context.Context, maxResults int, spm bool) *StopAtFirstMatchHandler[T] + func (h *StopAtFirstMatchHandler[T]) Acquire() + func (h *StopAtFirstMatchHandler[T]) Cancel() + func (h *StopAtFirstMatchHandler[T]) Cancelled() bool + func (h *StopAtFirstMatchHandler[T]) CombinedResults() []T + func (h *StopAtFirstMatchHandler[T]) Done() <-chan struct{} + func (h *StopAtFirstMatchHandler[T]) FoundFirstMatch() bool + func (h *StopAtFirstMatchHandler[T]) MatchCallback(fn func()) + func (h *StopAtFirstMatchHandler[T]) Release() + func (h *StopAtFirstMatchHandler[T]) Resize(ctx context.Context, size int) error + func (h *StopAtFirstMatchHandler[T]) SetOnResultCallback(fn func(T)) + func (h *StopAtFirstMatchHandler[T]) Size() int + func (h *StopAtFirstMatchHandler[T]) Trigger() + func (h *StopAtFirstMatchHandler[T]) Wait() + type WorkPoolType uint + const Blocking + const NonBlocking
Go to main page