manager

Documentation

Index

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

Variables

var URL = os.Getenv(urlEnv)

URL is the url at which we can reach this pipeline's manager

Functions

func VerifyManagerEnvs

func VerifyManagerEnvs() error

VerifyManagerEnvs checks whether each of the environment variables returned a non-empty value

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