Discover Packages
github.com/bloodhoundad/azurehound/v2
pipeline
package
Version:
v2.1.2
Opens a new window with list of versions in this module.
Published: Oct 11, 2023
License: GPL-3.0
Opens a new window with license information.
Imports: 5
Opens a new window with list of imports.
Imported by: 3
Opens a new window with list of known importers.
Jump to ...
Documentation
Index
Constants
Variables
Functions
Batch(done, in, maxItems, maxTimeout)
Demux(done, in, size)
Filter(done, in, fn)
FormatJson(done, in)
Map(done, in, fn)
Mux(done, channels)
OrDone(done, in)
Tee(done, in, outputs)
TeeFixed(done, in, size)
ToAny(done, in)
Types
Source Files
Documentation Source Files Index Constants Variables Functions Types Batch(done, in, maxItems, maxTimeout) Demux(done, in, size) Filter(done, in, fn) FormatJson(done, in) Map(done, in, fn) Mux(done, channels) OrDone(done, in) Tee(done, in, outputs) TeeFixed(done, in, size) ToAny(done, in) type Result
Documentation
¶
func Batch[D, T any](done <-chan D, in <-chan T, maxItems int, maxTimeout time.Duration) <-chan []T
func Demux[D, T any](done <-chan D, in <-chan T, size int) []<-chan T
func Filter[D, T any](done <-chan D, in <-chan T, fn func(T) bool) <-chan T
func FormatJson[D, T any](done <-chan D, in <-chan T) <-chan string
func Map[D, T, U any](done <-chan D, in <-chan T, fn func(T) U) <-chan U
func Mux[D any](done <-chan D, channels ...<-chan any) <-chan any
func OrDone[D, T any](done <-chan D, in <-chan T) <-chan T
func Tee[D, T any](done <-chan D, in <-chan T, outputs ...chan T)
func TeeFixed[D, T any](done <-chan D, in <-chan T, size int) []<-chan T
func ToAny[D, T any](done <-chan D, in <-chan T) <-chan any
type Result
func Batch[D, T any ](done <-chan D, in <-chan T, maxItems int , maxTimeout time .Duration ) <-chan []T
func Demux[D, T any ](done <-chan D, in <-chan T, size int ) []<-chan T
Demux distributes the stream of data from a single channel across multiple channels to parallelize CPU use and I/O
func Filter[D, T any ](done <-chan D, in <-chan T, fn func(T) bool ) <-chan T
func FormatJson[D, T any ](done <-chan D, in <-chan T) <-chan string
func Map[D, T, U any ](done <-chan D, in <-chan T, fn func(T) U) <-chan U
func Mux[D any ](done <-chan D, channels ...<-chan any ) <-chan any
Mux joins multiple channels and returns a channel as single stream of data.
func OrDone[D, T any ](done <-chan D, in <-chan T) <-chan T
OrDone provides an explicit cancellation mechanism to ensure the encapsulated and downstream goroutines are cleaned
up. This frees the caller from depending on the input channel to close in order to free the goroutine, thus
preventing possible leaks.
func Tee[D, T any ](done <-chan D, in <-chan T, outputs ...chan T)
Tee copies the stream of data from a single channel to zero or more channels
func TeeFixed[D, T any ](done <-chan D, in <-chan T, size int ) []<-chan T
func ToAny[D, T any ](done <-chan D, in <-chan T) <-chan any
type Result[T any ] struct {
Error error
Ok T
}
Source Files
¶
Click to show internal directories.
Click to hide internal directories.