service

Documentation

Index

• Constants
• func NewComponentService() proto.Component
• func NewMetadata(metapath string) (proto.Metadata, error)
• func NewPipelineService(metadata proto.Metadata, pipelineManager PipelinerManager) proto.Pipeline
• func NewPluginService(metadata proto.Metadata) proto.Plugin
• func NewProcessorService() proto.Processor
• func TermVisualizer(w io.Writer, pipeline pipeline.Pipeliner) error
• type ErrorGroup
  • func (eg ErrorGroup) Error() error
• type PipelinerManager
  • func NewPipelinerManager() PipelinerManager
• type Receptor
• type Service
  • func NewService(metadata proto.Metadata) *Service
  • func (s *Service) Start() error
  • func (s *Service) Stop() error

Constants

const (
	METADATA_PATH     = "meta"
	METADATA_FILENAME = "meta.yaml"
)

Functions

func NewComponentService

func NewComponentService() proto.Component

func NewMetadata

func NewMetadata(metapath string) (proto.Metadata, error)

func NewPipelineService

func NewPipelineService(metadata proto.Metadata,
	pipelineManager PipelinerManager) proto.Pipeline

func NewPluginService

func NewPluginService(metadata proto.Metadata) proto.Plugin

func NewProcessorService

func NewProcessorService() proto.Processor

func TermVisualizer

func TermVisualizer(w io.Writer, pipeline pipeline.Pipeliner) error

Types

type ErrorGroup

type ErrorGroup []string

func (ErrorGroup) Error

func (eg ErrorGroup) Error() error

type PipelinerManager

type PipelinerManager interface {
	AddPipeline(config pipeline.Config) (pipeline.Pipeliner, error)
	RemovePipeline(name ...string) error
	RecreatePipeline(config pipeline.Config) (pipeline.Pipeliner, error)
	List() []pipeline.Pipeliner
	Find(name string) pipeline.Pipeliner
	Restart(name ...string) error
	Start(name ...string) error
	Stop(name ...string) error
}

func NewPipelinerManager

func NewPipelinerManager() PipelinerManager

type Receptor

type Receptor struct {
	StructName      string
	StructFieldName string
	InjectName      string
	ReflectType     string
}

type Service

type Service struct {
	proto.Pipeline
	proto.Component
	proto.Processor
	proto.Plugin
	proto.Server
	// contains filtered or unexported fields
}

func NewService

func NewService(metadata proto.Metadata) *Service

func (*Service) Start

func (s *Service) Start() error

func (*Service) Stop

func (s *Service) Stop() error