pipeline

Documentation

Index

• type Pipeline
  • func (p *Pipeline) Bool(name string, d bool) bool
  • func (p *Pipeline) Driver() string
  • func (p *Pipeline) Get(key string) any
  • func (p *Pipeline) Has(name string) bool
  • func (p *Pipeline) Int(name string, d int) int
  • func (p *Pipeline) Map(name string, out map[string]string) error
  • func (p *Pipeline) Name() string
  • func (p *Pipeline) Priority() int64
  • func (p *Pipeline) String(name string, d string) string
  • func (p *Pipeline) With(name string, value any)

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

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