router

Documentation

Index

• func LimiterPriorityValueFrom(v, max int) kitsync.LimiterPriorityValue
• type Diagnostic
• type Factory
  • func (f *Factory) New(destination *backendconfig.DestinationT) *Handle
• type Handle
  • func (rt *Handle) Setup(destinationDefinition backendconfig.DestinationDefinitionT, log logger.Logger, ...)
  • func (rt *Handle) Shutdown()
  • func (rt *Handle) Start()
• type HandleDestOAuthRespParams
• type JobParameters
• type JobResponse
• type NetHandle
• type ResponseHandler
  • func NewResponseHandler(logger logger.Logger, responseRules map[string]interface{}) ResponseHandler

Functions

func LimiterPriorityValueFrom

func LimiterPriorityValueFrom(v, max int) kitsync.LimiterPriorityValue

Types

type Diagnostic

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

type Factory

type Factory struct {
	Logger           logger.Logger
	Reporting        reporter
	Multitenant      tenantStats
	BackendConfig    backendconfig.BackendConfig
	RouterDB         jobsdb.MultiTenantJobsDB
	ProcErrorDB      jobsdb.JobsDB
	TransientSources transientsource.Service
	RsourcesService  rsources.JobService
	ThrottlerFactory *throttler.Factory
	Debugger         destinationdebugger.DestinationDebugger
	AdaptiveLimit    func(int64) int64
}

func (*Factory) New

func (f *Factory) New(destination *backendconfig.DestinationT) *Handle

type Handle

type Handle struct {
	MultitenantI tenantStats

	Reporting reporter
	// contains filtered or unexported fields
}

Handle is the handle to this module.

func (*Handle) Setup

func (rt *Handle) Setup(
	destinationDefinition backendconfig.DestinationDefinitionT,
	log logger.Logger,
	config *config.Config,
	backendConfig backendconfig.BackendConfig,
	jobsDB jobsdb.MultiTenantJobsDB,
	errorDB jobsdb.JobsDB,
	transientSources transientsource.Service,
	rsourcesService rsources.JobService,
	debugger destinationdebugger.DestinationDebugger,
)

Setup initializes this module

func (*Handle) Shutdown

func (rt *Handle) Shutdown()

func (*Handle) Start

func (rt *Handle) Start()

type HandleDestOAuthRespParams

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

type JobParameters

type JobParameters struct {
	SourceID                string      `json:"source_id"`
	DestinationID           string      `json:"destination_id"`
	ReceivedAt              string      `json:"received_at"`
	TransformAt             string      `json:"transform_at"`
	SourceTaskRunID         string      `json:"source_task_run_id"`
	SourceJobID             string      `json:"source_job_id"`
	SourceJobRunID          string      `json:"source_job_run_id"`
	SourceDefinitionID      string      `json:"source_definition_id"`
	DestinationDefinitionID string      `json:"destination_definition_id"`
	SourceCategory          string      `json:"source_category"`
	RecordID                interface{} `json:"record_id"`
	MessageID               string      `json:"message_id"`
	WorkspaceID             string      `json:"workspaceId"`
	RudderAccountID         string      `json:"rudderAccountId"`
}

JobParameters struct holds source id and destination id of a job

type JobResponse

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

type NetHandle

type NetHandle interface {
	SendPost(ctx context.Context, structData integrations.PostParametersT) *utils.SendPostResponse
}

Network interface

type ResponseHandler

type ResponseHandler interface {
	IsSuccessStatus(respCode int, respBody string) (returnCode int)
}

ResponseHandler - handle destination response

func NewResponseHandler

func NewResponseHandler(logger logger.Logger, responseRules map[string]interface{}) ResponseHandler

NewResponseHandler returns a destination response handler. Can be nil(Check before using this)