adapter

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

type Packet struct {
	EventName string
	Payload   []byte
}

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

type SourceConfig struct {
	Sources map[string]SourceEntry `json:"sources"`
}

type SourceEntry struct {
	SubscriberID        string       `json:"subscriber_id"`
	SubscriberName      string       `json:"subscriber_name"`
	Host                string       `json:"host"`
	Port                int          `json:"port"`
	WorkerCount         *int         `json:"worker_count",omitempty`
	ChunkSize           *int         `json:"chunk_size",omitempty`
	PingInterval        *int64       `json:"ping_interval",omitempty`
	MaxPingsOutstanding *int         `json:"max_pings_outstanding",omitempty`
	MaxReconnects       *int         `json:"max_reconnects",omitempty`
	Collections         *[]string    `json:"collections"`
	Verbose             *bool        `json:"verbose",omitempty`
	InitialLoad         *bool        `json:"initial_load", omitempty`
	OmittedCount        *uint64      `json:"omitted_count", omitempty`
	Events              SourceEvents `json:"events"`
}

type SourceEvents struct {
	Snapshot string `json:"snapshot"`
	Create   string `json:"create"`
	Update   string `json:"update"`
	Delete   string `json:"delete"`
}

type SourceInfo struct {
	SubscriberID        string
	SubscriberName      string
	Host                string
	Port                int
	WorkerCount         int
	ChunkSize           int
	PingInterval        int64
	MaxPingsOutstanding int
	MaxReconnects       int
	Collections         []string
	Verbose             bool
	InitialLoad         bool
	OmittedCount        uint64
	Events              SourceEvents
}

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