fetcher

Documentation

Index

• type Fetcher
  • func NewFetcher(bearerToken, manager, clusterId string, scheduler *scheduler.Scheduler) (*Fetcher, error)
  • func (f *Fetcher) Cancel()
  • func (f *Fetcher) CatchSynapseAgentService(services map[string]service.ServiceInterface) bool
  • func (f *Fetcher) ChangeAgentConfigFromToken()
  • func (f *Fetcher) ChangePollingInterval(interval int) (int, error)
  • func (f *Fetcher) Done() <-chan struct{}
  • func (f *Fetcher) HandShake() error
  • func (f *Fetcher) Polling(ctx context.Context) error
  • func (f *Fetcher) RebounceAgentPod(version service.Version, serviceId string)
  • func (f *Fetcher) RemainServices() map[string]service.ServiceStatus
  • func (f *Fetcher) RetryHandshake()
  • func (f *Fetcher) UpdateFailedToConvertServices(failed []service.FailedConvertService)
  • func (f *Fetcher) UpdateServiceProcess()
  • func (f *Fetcher) UpgradeAgent(version service.Version, serviceId string, args map[string]interface{}) (err error)

Types

type Fetcher

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

func NewFetcher

func NewFetcher(bearerToken, manager, clusterId string, scheduler *scheduler.Scheduler) (*Fetcher, error)

func (*Fetcher) Cancel

func (f *Fetcher) Cancel()

func (*Fetcher) CatchSynapseAgentService

func (f *Fetcher) CatchSynapseAgentService(services map[string]service.ServiceInterface) bool

func (*Fetcher) ChangeAgentConfigFromToken

func (f *Fetcher) ChangeAgentConfigFromToken()

func (*Fetcher) ChangePollingInterval

func (f *Fetcher) ChangePollingInterval(interval int) (int, error)

func (*Fetcher) Done

func (f *Fetcher) Done() <-chan struct{}

func (*Fetcher) HandShake

func (f *Fetcher) HandShake() error

func (*Fetcher) Polling

func (f *Fetcher) Polling(ctx context.Context) error

func (*Fetcher) RebounceAgentPod

func (f *Fetcher) RebounceAgentPod(version service.Version, serviceId string)

func (*Fetcher) RemainServices

func (f *Fetcher) RemainServices() map[string]service.ServiceStatus

func (*Fetcher) RetryHandshake

func (f *Fetcher) RetryHandshake()

func (*Fetcher) UpdateFailedToConvertServices

func (f *Fetcher) UpdateFailedToConvertServices(failed []service.FailedConvertService)

func (*Fetcher) UpdateServiceProcess

func (f *Fetcher) UpdateServiceProcess()

func (*Fetcher) UpgradeAgent

func (f *Fetcher) UpgradeAgent(version service.Version, serviceId string, args map[string]interface{}) (err error)