router

type DBHandleI interface {
	Connect(string) bool
	InsertPayloadInTransaction([]json.RawMessage) error
}

type DestinationRouterT struct {
	DBHandle   DBHandleI   `json:"DBHandle"`
	RestHandle RestHandleI `json:"RestHandle"`
	Enabled    bool        `json:"Enabled"`
}

type HandleT struct {
	JobsDB                  *jobsdb.HandleT
	ConfigDB                *backendconfig.HandleT
	JobProcessRequestQ      chan *JobProcessRequestT
	JobProcessBatchRequestQ chan *JobProcessRequestT
	JobProcessResponseQ     chan *JobProcessResponseT
	// contains filtered or unexported fields
}

type JobProcessRequestT struct {
	JobID         int64           `json:"JobID"`
	AttemptNum    int             `json:"AttemptNum"`
	DestinationID int             `json:"DestinationID"`
	EventPayload  json.RawMessage `json:"EventPayload"`
}

type JobProcessResponseT struct {
	JobID         int64           `json:"JobID"`
	AttemptNum    int             `json:"AttemptNum"`
	State         string          `json:"State"`
	ErrorCode     string          `json:"ErrorCode"`
	ErrorResponse json.RawMessage `json:"ErrorResponse"`
}

type RestHandleI interface {
	Init(string) bool
	Send(json.RawMessage, map[string]interface{}) (int, string, []interface{})
}