manager

Documentation

Index

• type UpstreamChecker
  • func NewUpstreamChecker(managerURL, pipelineHash, processName string, retries int) UpstreamChecker
  • func (checker *UpstreamChecker) Start(wg *sync.WaitGroup)
  • func (checker *UpstreamChecker) StartBlocking()

Types

type UpstreamChecker

type UpstreamChecker struct {
	// Register is a channel via which you can register additional consumers
	Register chan chan bool

	ManagerURL   string
	PipelineHash string
	ProcessName  string
	// contains filtered or unexported fields
}

UpstreamChecker is the structure responsible for checking the state of upstream pipeline components by asking the manager It notifies all its consumber which can be registered

func NewUpstreamChecker

func NewUpstreamChecker(managerURL, pipelineHash, processName string, retries int) UpstreamChecker

NewUpstreamChecker creates a new instance of UpstreamChecker and intializes its necessary values

func (*UpstreamChecker) Start

func (checker *UpstreamChecker) Start(wg *sync.WaitGroup)

Start asychronously calls StartBlocking via Gorouting

func (*UpstreamChecker) StartBlocking

func (checker *UpstreamChecker) StartBlocking()

StartBlocking starts the main loop of the UpstreamChecker