fetcher

Documentation

Index

• type Fetcher
  • func NewFetcher(bearerToken, clusterId string, scheduler *scheduler.Scheduler, ...) (*Fetcher, error)
  • func (f *Fetcher) Cancel()
  • func (f *Fetcher) CatchClientSystemService(services []*service.Service) bool
  • func (f *Fetcher) ChangeClientConfigFromToken()
  • func (f *Fetcher) Done() <-chan struct{}
  • func (f *Fetcher) HandShake() error
  • func (f *Fetcher) Polling(ctx context.Context) error
  • func (f *Fetcher) RebounceClientPod(serviceId string)
  • func (f *Fetcher) RemainServices() map[string]service.ServiceStatus
  • func (f *Fetcher) RetryHandshake()
  • func (f *Fetcher) UpdateFailedToConvertServices(failed []*service.UpdateService)
  • func (f *Fetcher) UpdateServiceProcess()
  • func (f *Fetcher) UpgradeClient(serviceId string, args map[string]interface{}) (err error)

Types

type Fetcher

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

func NewFetcher

func NewFetcher(bearerToken, clusterId string, scheduler *scheduler.Scheduler, api server.ServerAPIInterface, fetchLimit int, clientVersion string) (*Fetcher, error)

func (*Fetcher) Cancel

func (f *Fetcher) Cancel()

func (*Fetcher) CatchClientSystemService

func (f *Fetcher) CatchClientSystemService(services []*service.Service) bool

func (*Fetcher) ChangeClientConfigFromToken

func (f *Fetcher) ChangeClientConfigFromToken()

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) RebounceClientPod

func (f *Fetcher) RebounceClientPod(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.UpdateService)

func (*Fetcher) UpdateServiceProcess

func (f *Fetcher) UpdateServiceProcess()

func (*Fetcher) UpgradeClient

func (f *Fetcher) UpgradeClient(serviceId string, args map[string]interface{}) (err error)