registrar

Documentation

Index

• type IRetryableRegistrar
• type RetryableRegistrar
  • func NewRetryableRegistrar(agentCtx agentCtx.ICoreAgentContext) *RetryableRegistrar
  • func (r *RetryableRegistrar) GetRegistrationAttemptedChan() chan struct{}
  • func (r *RetryableRegistrar) RegisterWithRetry()
  • func (r *RetryableRegistrar) Start() error
  • func (r *RetryableRegistrar) Stop()

Types

type IRetryableRegistrar

type IRetryableRegistrar interface {
	Start() error
	Stop()
	GetRegistrationAttemptedChan() chan struct{}
}

type RetryableRegistrar

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

func NewRetryableRegistrar

func NewRetryableRegistrar(agentCtx agentCtx.ICoreAgentContext) *RetryableRegistrar

func (*RetryableRegistrar) GetRegistrationAttemptedChan

func (r *RetryableRegistrar) GetRegistrationAttemptedChan() chan struct{}

GetRegistrationAttemptedChan returns a channel that is written to and closed after registration is attempted or has succeeded

func (*RetryableRegistrar) RegisterWithRetry

func (r *RetryableRegistrar) RegisterWithRetry()

func (*RetryableRegistrar) Start

func (r *RetryableRegistrar) Start() error

func (*RetryableRegistrar) Stop

func (r *RetryableRegistrar) Stop()