pipeline

Documentation

Index

• func NewEchoProcessor(c *config.Config) (pipeline.Processor, error)
• type CreatePipelineRequest
• type EchoConfig
• type EchoProcessor
  • func (this *EchoProcessor) Name() string
  • func (this *EchoProcessor) Process(c *pipeline.Context) error
• type GetPipelinesResponse
• type PipeModule
  • func (module *PipeModule) Name() string
  • func (module *PipeModule) Setup()
  • func (module *PipeModule) Start() error
  • func (module *PipeModule) Stop() error
• type PipelineStatus
• type SearchPipelinesRequest

Functions

func NewEchoProcessor

func NewEchoProcessor(c *config.Config) (pipeline.Processor, error)

Types

type CreatePipelineRequest

type CreatePipelineRequest struct {
	pipeline.PipelineConfigV2
	Processors []map[string]interface{} `json:"processor"`
}

type EchoConfig

type EchoConfig struct {
	Message string `config:"message"`
}

type EchoProcessor

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

func (*EchoProcessor) Name

func (this *EchoProcessor) Name() string

func (*EchoProcessor) Process

func (this *EchoProcessor) Process(c *pipeline.Context) error

type GetPipelinesResponse

type GetPipelinesResponse map[string]*PipelineStatus

type PipeModule

type PipeModule struct {
	api.Handler
	// contains filtered or unexported fields
}

func (*PipeModule) Name

func (module *PipeModule) Name() string

func (*PipeModule) Setup

func (module *PipeModule) Setup()

func (*PipeModule) Start

func (module *PipeModule) Start() error

func (*PipeModule) Stop

func (module *PipeModule) Stop() error

type PipelineStatus

type PipelineStatus struct {
	State      pipeline.RunningState      `json:"state"`
	CreateTime time.Time                  `json:"create_time"`
	StartTime  *time.Time                 `json:"start_time"`
	EndTime    *time.Time                 `json:"end_time"`
	Context    util.MapStr                `json:"context"`
	Config     *pipeline.PipelineConfigV2 `json:"config"`
	Processors []map[string]interface{}   `json:"processor"`
}

type SearchPipelinesRequest

type SearchPipelinesRequest struct {
	Ids []string `json:"ids"`
}