Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

router

package

Go to main page

Versions in this module

v1

v1.2.0

Nov 20, 2023

v1.1.1

Oct 11, 2023

v1.1.0

Sep 23, 2023

Changes in this version

+ var BATCH_JOB_PROCESS_TIMEOUT time.Duration

+ var DB_BATCH_FETCH_SIZE int

+ var JOB_RESPONSE_BATCH_TIMEOUT time.Duration

+ var MAX_BATCH_PAYLOAD_SIZE int

+ var MAX_PROCESS_WORKER int

+ func BackendConfigSubscriber()

+ func UpdateRouterConfig(connection backendconfig.ConnectionDetailT)

+ type DBHandleI interface

+ Connect func(string) bool

+ InsertPayloadInTransaction func([]json.RawMessage) error

+ type DestinationRouterT struct

+ DBHandle DBHandleI

+ Enabled bool

+ RestHandle RestHandleI

type HandleT

+ ConfigDB *backendconfig.HandleT

+ JobProcessBatchRequestQ chan *JobProcessRequestT

+ JobProcessRequestQ chan *JobProcessRequestT

+ JobProcessResponseQ chan *JobProcessResponseT

+ JobsDB *jobsdb.HandleT

+ func (router *HandleT) CreateNewJobWithFailedEvents(events []interface{}, destinationID int)

+ func (router *HandleT) JobsRequestWorker()

+ func (router *HandleT) JobsResponseWorker()

+ func (router *HandleT) ProcessBatchRouterJobs()

+ func (router *HandleT) ProcessRouterJobs(index int)

+ type JobProcessRequestT struct

+ AttemptNum int

+ DestinationID int

+ EventPayload json.RawMessage

+ JobID int64

+ type JobProcessResponseT struct

+ AttemptNum int

+ ErrorCode string

+ ErrorResponse json.RawMessage

+ JobID int64

+ State string

+ type RestHandleI interface

+ Init func(string) bool

+ Send func(json.RawMessage, map[string]interface{}) (int, string, []interface{})

v1.0.1

Jul 21, 2023

v1.0.0

Jul 21, 2023

Changes in this version

+ type HandleT struct

+ func (rt *HandleT) Disable()

+ func (rt *HandleT) Enable()

+ func (rt *HandleT) Setup(jobsDB *jobsdb.HandleT, destID string, warehouse integrations.HandleT)

+ type NetHandleT struct

+ func (network *NetHandleT) Setup(destID string)

JackTT - Gopher 🇻🇳