Documentation
¶
Index ¶
Constants ¶
View Source
const (
ContentTypeJSON = "application/json"
)
View Source
const (
KAFKA_TIMEOUT_MS = 30000 // 30 seconds
)
View Source
const (
SYNC_BUCKET = "sync"
)
Variables ¶
View Source
var Retry = 5 * time.Second
retry interval
View Source
var Verbose = false
Functions ¶
This section is empty.
Types ¶
type Delivery ¶
type Delivery struct { DBPath string Send chan interface{} Transport Transport // contains filtered or unexported fields }
func NewDelivery ¶ added in v0.2.0
type StdLogger ¶
type StdLogger interface { Print(...interface{}) Printf(string, ...interface{}) Println(...interface{}) Fatal(...interface{}) Fatalf(string, ...interface{}) Fatalln(...interface{}) Panic(...interface{}) Panicf(string, ...interface{}) Panicln(...interface{}) }
Compatible with standard package "log"
var Logger StdLogger
May be replaced by another logger
Click to show internal directories.
Click to hide internal directories.