purge

Documentation

Index

• type PodLister
• type PurgeAPI
  • func NewAPI(l PodLister, n rpaas.CacheManager) (*PurgeAPI, error)
  • func (p *PurgeAPI) PurgeCache(ctx context.Context, name string, args rpaas.PurgeCacheArgs) (int, error)
  • func (p *PurgeAPI) Start() error
  • func (p *PurgeAPI) Stop() error
• type Watcher
  • func NewWatcher(c client.Client) (*Watcher, error)
  • func (w *Watcher) ListPods(instance string) ([]rpaas.PodStatus, int32, error)

Types

type PodLister

type PodLister interface {
	ListPods(instance string) ([]rpaas.PodStatus, int32, error)
}

type PurgeAPI

type PurgeAPI struct {
	sync.Mutex

	Address string

	ShutdownTimeout time.Duration

	Shutdown chan struct{}
	// contains filtered or unexported fields
}

func NewAPI

func NewAPI(l PodLister, n rpaas.CacheManager) (*PurgeAPI, error)

func (*PurgeAPI) PurgeCache

func (p *PurgeAPI) PurgeCache(ctx context.Context, name string, args rpaas.PurgeCacheArgs) (int, error)

func (*PurgeAPI) Start

func (p *PurgeAPI) Start() error

Start runs the web server.

func (*PurgeAPI) Stop

func (p *PurgeAPI) Stop() error

Stop shut down the web server.

type Watcher

type Watcher struct {
	Client client.Client
}

func NewWatcher

func NewWatcher(c client.Client) (*Watcher, error)

func (*Watcher) ListPods

func (w *Watcher) ListPods(instance string) ([]rpaas.PodStatus, int32, error)