v0.4.5 Latest Latest

This package is not in the latest version of its module.

Go to latest
Published: Jul 24, 2020 License: MIT Imports: 13 Imported by: 1




This section is empty.


View Source
var URL = os.Getenv(urlEnv)

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


func VerifyManagerEnvs

func VerifyManagerEnvs() error

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


type UpstreamChecker added in v0.4.2

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 added in v0.4.2

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

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

func (*UpstreamChecker) Start added in v0.4.2

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

Start asychronously calls StartBlocking via Gorouting

func (*UpstreamChecker) StartBlocking added in v0.4.2

func (checker *UpstreamChecker) StartBlocking()

StartBlocking starts the main loop of the UpstreamChecker

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL