fanout

Documentation

Index

• func ConcurrentResponseErrors(ctx context.Context, worker func(ctx context.Context, value interface{}) error, ...) chan error
• func ConcurrentResponseItems(ctx context.Context, ...) chan Item
• func ReadErrorsChannel(ch chan error) error
• func ReadItemChannel(ch chan Item) ([]interface{}, error)
• type Item

Functions

func ConcurrentResponseErrors

func ConcurrentResponseErrors(ctx context.Context, worker func(ctx context.Context, value interface{}) error, parameters ...interface{}) chan error

ConcurrentResponseErrors process with errors channel

func ConcurrentResponseItems

func ConcurrentResponseItems(ctx context.Context, worker func(
	ctx context.Context,
	value interface{},
) (interface{}, error), parameters ...interface{}) chan Item

ConcurrentResponseItems process with items channel

func ReadErrorsChannel

func ReadErrorsChannel(ch chan error) error

ReadErrorsChannel reads error's channel and constructs error

func ReadItemChannel

func ReadItemChannel(ch chan Item) ([]interface{}, error)

ReadItemChannel reads items channel and constructs error

Types

type Item

type Item struct {
	// contains filtered or unexported fields
}

Item is fan out general item