integrations

Documentation

Index

• type BaseIntegration
  • func NewIntegration(id string, cogClient *internal.CdfClient, extractorID string, ...) *BaseIntegration
  • func (intgr *BaseIntegration) ReportRunStatus(camExternalID, status, msg string)
  • func (intgr *BaseIntegration) Stop()
  • func (intgr *BaseIntegration) StopProcessor(procId uint64)

Types

type BaseIntegration

type BaseIntegration struct {
	ID           string
	CogClient    *internal.CdfClient
	IsRunning    bool
	StateTracker *internal.StateTracker

	ConfigObserver *internal.CdfConfigObserver // remote config observer
	// contains filtered or unexported fields
}

BaseIntegration is a base class for all integrations. Integrations are long running processes that internally run one or more processors (goroutines) All processors share that same logic but configured differently. StateTracker is used to track the state of all processors and to control them.

func NewIntegration

func NewIntegration(id string, cogClient *internal.CdfClient, extractorID string, configObserver *internal.CdfConfigObserver) *BaseIntegration

func (*BaseIntegration) ReportRunStatus

func (intgr *BaseIntegration) ReportRunStatus(camExternalID, status, msg string)

func (*BaseIntegration) Stop

func (intgr *BaseIntegration) Stop()

func (*BaseIntegration) StopProcessor

func (intgr *BaseIntegration) StopProcessor(procId uint64)