publisher

type ConnectionCreator func(endpoint string) (PublishingConnection, error)

type Job struct {
	PublishingEndpoint string

	BackendHost string
	BackendPort int

	AppDomain  string
	AppName    string
	StartRange int
	EndRange   int
}

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

type PublishingConnection interface {
	Publish(subj string, data []byte) error
	Close()
}

type RouteData struct {
	Host string   `json:"host"`
	Port int      `json:"port"`
	URIs []string `json:"uris"`
}