orchestrator

Documentation

Index

• type Consumer
• type Notifier
• type Orchestrator
  • func NewOrchestrator(consumer Consumer, endpoint *url.URL, notifier Notifier) *Orchestrator
  • func (o *Orchestrator) Do() error

Types

type Consumer

type Consumer interface {
	Consume(endpoint *url.URL) (httpCode int, body []byte, err error)
}

type Notifier

type Notifier interface {
	Notify(endpoint *url.URL, httpCode int, body []byte, begin time.Time, end time.Time) error
}

type Orchestrator

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

func NewOrchestrator

func NewOrchestrator(consumer Consumer, endpoint *url.URL, notifier Notifier) *Orchestrator

func (*Orchestrator) Do

func (o *Orchestrator) Do() error