bridge

type Bridge struct {
	Options
	// contains filtered or unexported fields
}

type Options struct {
	PostgresAddress string
	NSQAddress      string
	Channel         string
	OnError         func(err error)
	OnProcess       func(postgresChannel, nsqChannel string, payload Payload)
}

type Payload struct {
	Pid             int    `json:"pid"`
	PostgresChannel string `json:"postgres_channel"`
	Data            string `json:"data"`
}