publisher

Documentation

Index

• type ConnectionCreator
• type Job
• type Publisher
  • func NewPublisher(job Job, publishDelay time.Duration) *Publisher
  • func (p *Publisher) Finish()
  • func (p *Publisher) Initialize(c ConnectionCreator) error
  • func (p *Publisher) PublishRouteRegistrations() error
• type PublishingConnection
• type RouteData

Types

type ConnectionCreator

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

type Job

type Job struct {
	PublishingEndpoint string

	BackendHost string
	BackendPort int

	AppDomain  string
	AppName    string
	StartRange int
	EndRange   int
}

type Publisher

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

func NewPublisher

func NewPublisher(job Job, publishDelay time.Duration) *Publisher

func (*Publisher) Finish

func (p *Publisher) Finish()

func (*Publisher) Initialize

func (p *Publisher) Initialize(c ConnectionCreator) error

func (*Publisher) PublishRouteRegistrations

func (p *Publisher) PublishRouteRegistrations() error

type PublishingConnection

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

type RouteData

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