processor

Documentation

Index

• Constants
• Variables
• func ConvertToFilteredTransformerResponse(events []transformer.TransformerEventT, filterUnsupportedMessageTypes bool) transformer.ResponseT
• func ProcessorManagerSetup(processor *HandleT)
• func RegisterAdminHandlers(readonlyProcErrorDB jobsdb.ReadonlyJobsDB)
• func SetDisableDedupFeature(b bool) bool
• func SetFeaturesRetryAttempts(overrideAttempts int)
• func SetIsUnlocked(unlockVar bool)
• func SetMainLoopTimeout(timeout time.Duration)
• type DestStatT
• type HandleT
  • func NewProcessor() *HandleT
  • func (proc *HandleT) Pause()
  • func (proc *HandleT) Print()
  • func (proc *HandleT) Resume()
  • func (proc *HandleT) Setup(backendConfig backendconfig.BackendConfig, gatewayDB jobsdb.JobsDB, ...)
  • func (proc *HandleT) Start()
  • func (proc *HandleT) Status() interface{}
• type MetricMetadata
• type ParametersT
• type PauseT
• type ProcessorManagerI
  • func GetProcessorManager() (ProcessorManagerI, error)
• type ProcessorManagerT
  • func (pm *ProcessorManagerT) Pause()
  • func (pm *ProcessorManagerT) Resume()
• type TransformRequestT

Constants

const DEST_TRANSFORMATION = "DEST_TRANSFORMATION"

const USER_TRANSFORMATION = "USER_TRANSFORMATION"

Variables

var (
	GWCustomVal string
)

Functions

func ConvertToFilteredTransformerResponse

func ConvertToFilteredTransformerResponse(events []transformer.TransformerEventT, filterUnsupportedMessageTypes bool) transformer.ResponseT

func ProcessorManagerSetup

func ProcessorManagerSetup(processor *HandleT)

func RegisterAdminHandlers

func RegisterAdminHandlers(readonlyProcErrorDB jobsdb.ReadonlyJobsDB)

func SetDisableDedupFeature

func SetDisableDedupFeature(b bool) bool

SetDisableDedupFeature overrides SetDisableDedupFeature configuration and returns previous value

func SetFeaturesRetryAttempts

func SetFeaturesRetryAttempts(overrideAttempts int)

func SetIsUnlocked

func SetIsUnlocked(unlockVar bool)

func SetMainLoopTimeout

func SetMainLoopTimeout(timeout time.Duration)

Types

type DestStatT

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

type HandleT

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

HandleT is an handle to this object used in main.go

func NewProcessor

func NewProcessor() *HandleT

NewProcessor creates a new Processor intanstace

func (*HandleT) Pause

func (proc *HandleT) Pause()

Pause is a blocking call. Pause returns after the processor is paused.

func (*HandleT) Print

func (proc *HandleT) Print()

Print the internal structure

func (*HandleT) Resume

func (proc *HandleT) Resume()

func (*HandleT) Setup

func (proc *HandleT) Setup(backendConfig backendconfig.BackendConfig, gatewayDB jobsdb.JobsDB, routerDB jobsdb.JobsDB, batchRouterDB jobsdb.JobsDB, errorDB jobsdb.JobsDB, clearDB *bool, reporting types.ReportingI)

Setup initializes the module

func (*HandleT) Start

func (proc *HandleT) Start()

Start starts this processor's main loops.

func (*HandleT) Status

func (proc *HandleT) Status() interface{}

type MetricMetadata

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

type ParametersT

type ParametersT struct {
	SourceID        string `json:"source_id"`
	DestinationID   string `json:"destination_id"`
	ReceivedAt      string `json:"received_at"`
	TransformAt     string `json:"transform_at"`
	MessageID       string `json:"message_id"`
	GatewayJobID    int64  `json:"gateway_job_id"`
	SourceBatchID   string `json:"source_batch_id"`
	SourceTaskID    string `json:"source_task_id"`
	SourceTaskRunID string `json:"source_task_run_id"`
	SourceJobID     string `json:"source_job_id"`
	SourceJobRunID  string `json:"source_job_run_id"`
	EventName       string `json:"event_name"`
	EventType       string `json:"event_type"`
}

type PauseT

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

type ProcessorManagerI

type ProcessorManagerI interface {
	Pause()
	Resume()
}

var (
	ProcessorManager ProcessorManagerI
)

func GetProcessorManager

func GetProcessorManager() (ProcessorManagerI, error)

type ProcessorManagerT

type ProcessorManagerT struct {
	Processor *HandleT
}

func (*ProcessorManagerT) Pause

func (pm *ProcessorManagerT) Pause()

func (*ProcessorManagerT) Resume

func (pm *ProcessorManagerT) Resume()

type TransformRequestT

type TransformRequestT struct {
	Event          []transformer.TransformerEventT
	Stage          string
	ProcessingTime float64
	Index          int
}