pipeline

Documentation

Index

• type Pipeline
  • func (p Pipeline) Bool(name string, d bool) bool
  • func (p Pipeline) Driver() string
  • 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 interface{})

Types

type Pipeline

type Pipeline map[string]interface{}

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) 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 interface{})

With pipeline value