integrations

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(id string, cogClient *internal.CdfClient, extractorID string, configObserver *internal.CdfConfigObserver) *BaseIntegration

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

func (intgr *BaseIntegration) Stop()

func (intgr *BaseIntegration) StopProcessor(procId uint64)