pipeline

package
v2.23.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 12, 2022 License: MIT Imports: 2 Imported by: 30

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Pipeline

type Pipeline map[string]any

Pipeline defines pipeline options.

func (*Pipeline) Bool

func (p *Pipeline) Bool(name string, d bool) bool

Bool must return option value as bool or return default value.

func (*Pipeline) Driver

func (p *Pipeline) Driver() string

Driver associated with the pipeline.

func (*Pipeline) Get added in v2.20.1

func (p *Pipeline) Get(key string) any

Get used to get the data associated with the key

func (*Pipeline) Has

func (p *Pipeline) Has(name string) bool

Has checks if value presented in pipeline.

func (*Pipeline) Int

func (p *Pipeline) Int(name string, d int) int

Int must return option value as string or return default value.

func (*Pipeline) Map

func (p *Pipeline) Map(name string, out map[string]string) error

Map must return nested map value or empty config. Here might be sqs attributes or tags for example

func (*Pipeline) Name

func (p *Pipeline) Name() string

Name returns pipeline name.

func (*Pipeline) Priority

func (p *Pipeline) Priority() int64

Priority returns default pipeline priority

func (*Pipeline) String

func (p *Pipeline) String(name string, d string) string

String must return option value as string or return default value.

func (*Pipeline) With

func (p *Pipeline) With(name string, value any)

With pipeline value

Jump to

Keyboard shortcuts

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