telemetry

Documentation

Index

• Constants
• type PipelineTelemetry
• type Service
  • func (s *Service) Enabled() bool
  • func (s *Service) Name() string
  • func (s *Service) PipelineFinished(pipelineId, instanceId string, data map[string]interface{})
  • func (s *Service) PipelineStarted(pipelineId, instanceId string, data map[string]interface{})
  • func (s *Service) StageFinished(pipelineId, instanceId, stageId string, data map[string]interface{})
  • func (s *Service) StageStarted(pipelineId, instanceId, stageId string, data map[string]interface{})
  • func (s *Service) Start() error
  • func (s *Service) Stop() error
• type ServiceFactory
  • func (s *ServiceFactory) NewService(config *service.Config) (service.Service, error)

Constants

const (
	EnvTelemetryPort     = "FLOGO_STREAM_TELEMETRY_PORT"
	DefaultTelemetryPort = 9999

	MsgPipelineStarted  = "pipeline-started"
	MsgPipelineFinished = "pipeline-finished"
	MsgStageStarted     = "stage-started"
	MsgStageFinished    = "stage-finished"
)

Types

type PipelineTelemetry

type PipelineTelemetry struct {
	PipelineId string                 `json:"pipelineId"`
	InstanceId string                 `json:"instanceId"`
	Type       string                 `json:"type"`
	StageId    string                 `json:"stageId,omitempty"`
	Data       map[string]interface{} `json:"data"`
}

type Service

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

func (*Service) Enabled

func (s *Service) Enabled() bool

DEPRECATED

func (*Service) Name

func (s *Service) Name() string

func (*Service) PipelineFinished

func (s *Service) PipelineFinished(pipelineId, instanceId string, data map[string]interface{})

func (*Service) PipelineStarted

func (s *Service) PipelineStarted(pipelineId, instanceId string, data map[string]interface{})

func (*Service) StageFinished

func (s *Service) StageFinished(pipelineId, instanceId, stageId string, data map[string]interface{})

func (*Service) StageStarted

func (s *Service) StageStarted(pipelineId, instanceId, stageId string, data map[string]interface{})

func (*Service) Start

func (s *Service) Start() error

func (*Service) Stop

func (s *Service) Stop() error

type ServiceFactory

type ServiceFactory struct {
}

func (*ServiceFactory) NewService

func (s *ServiceFactory) NewService(config *service.Config) (service.Service, error)