purge

package
v0.40.0 Latest Latest
Warning

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

 Go to latest Published: Apr 8, 2024 License: BSD-3-Clause Imports: 22 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.