service

Documentation

Index

• type Handler
  • func NewHandler(conf *config.PipelineConfig, rpcServer egress.RPCServer) *Handler
  • func (h *Handler) Kill()
  • func (h *Handler) Run() error
• type ProcessManager
  • func NewProcessManager(conf *config.ServiceConfig, monitor *stats.Monitor) *ProcessManager
• type Service
  • func NewService(conf *config.ServiceConfig, rpcServer egress.RPCServer) *Service
  • func (s *Service) ListEgress() []string
  • func (s *Service) Run() error
  • func (s *Service) Status() ([]byte, error)
  • func (s *Service) Stop(kill bool)

Types

type Handler

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

func NewHandler

func NewHandler(conf *config.PipelineConfig, rpcServer egress.RPCServer) *Handler

func (*Handler) Kill

func (h *Handler) Kill()

func (*Handler) Run

func (h *Handler) Run() error

type ProcessManager

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

func NewProcessManager

func NewProcessManager(conf *config.ServiceConfig, monitor *stats.Monitor) *ProcessManager

type Service

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

func NewService

func NewService(conf *config.ServiceConfig, rpcServer egress.RPCServer) *Service

func (*Service) ListEgress

func (s *Service) ListEgress() []string

func (*Service) Run

func (s *Service) Run() error

func (*Service) Status

func (s *Service) Status() ([]byte, error)

func (*Service) Stop

func (s *Service) Stop(kill bool)