service

Documentation

Index

• Constants
• func Failed(c *gin.Context, err error)
• func NewComponentService() proto.Component
• func NewExecutorService(metadata proto.Metadata) proto.Executor
• func NewMetadata(metapath string) (proto.Metadata, error)
• func NewPluginService(metadata proto.Metadata) proto.Plugin
• func NewProcessorService() proto.Processor
• func SniffName(raw []byte) (string, error)
• func StartExecutorChildProcess(configPath, masterAddr string) (executor.Executor, error)
• func Success(c *gin.Context, data interface{})
• func TestPlugin(paths ...string) error
• type ErrorGroup
  • func (eg ErrorGroup) Error() error
• type Executor
• type ExecutorClient
  • func NewExecutorClient(addr string) *ExecutorClient
  • func (c *ExecutorClient) CheckDependence() []error
  • func (c *ExecutorClient) Config() string
  • func (c *ExecutorClient) Error() error
  • func (c *ExecutorClient) ListComponents() []executor.Component
  • func (c *ExecutorClient) ListProcessors() []executor.Processor
  • func (c *ExecutorClient) Monitor() monitor.Monitor
  • func (c *ExecutorClient) Name() string
  • func (c *ExecutorClient) Start() error
  • func (c *ExecutorClient) State() executor.State
  • func (c *ExecutorClient) Stop()
  • func (c *ExecutorClient) Visualize(w io.Writer, format string) error
• type ExecutorServer
  • func NewExecutorServer(exec executor.Executor) (*ExecutorServer, error)
  • func (p *ExecutorServer) Addr() string
  • func (p *ExecutorServer) Start() error
• 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 Failed

func Failed(c *gin.Context, err error)

func NewComponentService

func NewComponentService() proto.Component

func NewExecutorService

func NewExecutorService(metadata proto.Metadata) proto.Executor

func NewMetadata

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

func NewPluginService

func NewPluginService(metadata proto.Metadata) proto.Plugin

func NewProcessorService

func NewProcessorService() proto.Processor

func SniffName

func SniffName(raw []byte) (string, error)

func StartExecutorChildProcess

func StartExecutorChildProcess(configPath, masterAddr string) (executor.Executor, error)

func Success

func Success(c *gin.Context, data interface{})

func TestPlugin

func TestPlugin(paths ...string) error

Types

type ErrorGroup

type ErrorGroup []error

func (ErrorGroup) Error

func (eg ErrorGroup) Error() error

type Executor

type Executor struct {
	executor.Executor
	Type       string
	ConfigPath string
}

type ExecutorClient

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

func NewExecutorClient

func NewExecutorClient(addr string) *ExecutorClient

func (*ExecutorClient) CheckDependence

func (c *ExecutorClient) CheckDependence() []error

func (*ExecutorClient) Config

func (c *ExecutorClient) Config() string

func (*ExecutorClient) Error

func (c *ExecutorClient) Error() error

func (*ExecutorClient) ListComponents

func (c *ExecutorClient) ListComponents() []executor.Component

func (*ExecutorClient) ListProcessors

func (c *ExecutorClient) ListProcessors() []executor.Processor

func (*ExecutorClient) Monitor

func (c *ExecutorClient) Monitor() monitor.Monitor

func (*ExecutorClient) Name

func (c *ExecutorClient) Name() string

func (*ExecutorClient) Start

func (c *ExecutorClient) Start() error

func (*ExecutorClient) State

func (c *ExecutorClient) State() executor.State

func (*ExecutorClient) Stop

func (c *ExecutorClient) Stop()

func (*ExecutorClient) Visualize

func (c *ExecutorClient) Visualize(w io.Writer, format string) error

type ExecutorServer

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

func NewExecutorServer

func NewExecutorServer(exec executor.Executor) (*ExecutorServer, error)

func (*ExecutorServer) Addr

func (p *ExecutorServer) Addr() string

func (*ExecutorServer) Start

func (p *ExecutorServer) Start() error

type Service

type Service struct {
	proto.Executor
	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