tool

Documentation

Index

• func CheckReady(ctx context.Context, sock string) <-chan bool
• func Run(t *testing.T, cmd string)
• func RunWithCombinedOutput(cmd string) (string, error)
• func RunWithOutput(cmd string) string
• func RunWithoutOutput(t *testing.T, cmd string)
• type AccessPatternMetrics
• type BackendMetrics
• type BlobCacheMetrics
• type Container
  • func (container *Container) AddFileToMount(t *testing.T, files map[string][]byte)
  • func (container *Container) AddFileToUpper(t *testing.T, files map[string][]byte)
  • func (container *Container) Destory(t *testing.T)
  • func (container *Container) Mount(t *testing.T)
  • func (container *Container) Serve(t *testing.T)
• type FileMetrics
• type GlobalMetrics
• type Image
  • func (image *Image) Build(t *testing.T, name string, files map[string][]byte)
• type InflightMetrics
• type Nydusd
  • func NewNydusd(conf NydusdConfig) (*Nydusd, error)
  • func (nydusd *Nydusd) GetAccessPatternMetrics(id string) ([]AccessPatternMetrics, error)
  • func (nydusd *Nydusd) GetBackendMetrics(id string) (*BackendMetrics, error)
  • func (nydusd *Nydusd) GetBlobCacheMetrics(id string) (*BlobCacheMetrics, error)
  • func (nydusd *Nydusd) GetFilesMetrics(id string) (map[string]FileMetrics, error)
  • func (nydusd *Nydusd) GetGlobalMetrics() (*GlobalMetrics, error)
  • func (nydusd *Nydusd) GetInflightMetrics() (*InflightMetrics, error)
  • func (nydusd *Nydusd) GetLatestFileMetrics() ([][]uint64, error)
  • func (nydusd *Nydusd) Mount() error
  • func (nydusd *Nydusd) MountByAPI(config NydusdConfig) error
  • func (nydusd *Nydusd) Umount() error
• type NydusdConfig
• type Registry
  • func (registry *Registry) Destory(t *testing.T)
  • func (registry *Registry) Serve(t *testing.T)

Functions

func CheckReady

func CheckReady(ctx context.Context, sock string) <-chan bool

func Run

func Run(t *testing.T, cmd string)

func RunWithCombinedOutput

func RunWithCombinedOutput(cmd string) (string, error)

func RunWithOutput

func RunWithOutput(cmd string) string

func RunWithoutOutput

func RunWithoutOutput(t *testing.T, cmd string)

Types

type AccessPatternMetrics

type AccessPatternMetrics struct {
	Ino                  uint64 `json:"ino"`
	NRRead               uint64 `json:"nr_read"`
	FirstAccessTimeSecs  uint   `json:"first_access_time_secs"`
	FirstAccessTimeNanos uint64 `json:"first_access_time_nanos"`
}

type BackendMetrics

type BackendMetrics struct {
}

type BlobCacheMetrics

type BlobCacheMetrics struct {
	PrefetchDataAmount uint64 `json:"prefetch_data_amount"`
}

type Container

type Container struct {
	WorkDir string
	// contains filtered or unexported fields
}

func (*Container) AddFileToMount

func (container *Container) AddFileToMount(t *testing.T, files map[string][]byte)

func (*Container) AddFileToUpper

func (container *Container) AddFileToUpper(t *testing.T, files map[string][]byte)

func (*Container) Destory

func (container *Container) Destory(t *testing.T)

func (*Container) Mount

func (container *Container) Mount(t *testing.T)

func (*Container) Serve

func (container *Container) Serve(t *testing.T)

type FileMetrics

type FileMetrics struct {
}

type GlobalMetrics

type GlobalMetrics struct {
	FilesAccountEnabled bool     `json:"files_account_enabled"`
	MeasureLatency      bool     `json:"measure_latency"`
	AccessPattern       bool     `json:"access_pattern_enabled"`
	DataRead            uint64   `json:"data_read"`
	FOPS                []uint64 `json:"fop_hits"`
}

type Image

type Image struct {
	WorkDir string
}

func (*Image) Build

func (image *Image) Build(t *testing.T, name string, files map[string][]byte)

type InflightMetrics

type InflightMetrics struct {
	Ino uint64 `json:"inode"`
}

type Nydusd

type Nydusd struct {
	NydusdConfig
}

func NewNydusd

func NewNydusd(conf NydusdConfig) (*Nydusd, error)

func (*Nydusd) GetAccessPatternMetrics

func (nydusd *Nydusd) GetAccessPatternMetrics(id string) ([]AccessPatternMetrics, error)

func (*Nydusd) GetBackendMetrics

func (nydusd *Nydusd) GetBackendMetrics(id string) (*BackendMetrics, error)

func (*Nydusd) GetBlobCacheMetrics

func (nydusd *Nydusd) GetBlobCacheMetrics(id string) (*BlobCacheMetrics, error)

func (*Nydusd) GetFilesMetrics

func (nydusd *Nydusd) GetFilesMetrics(id string) (map[string]FileMetrics, error)

func (*Nydusd) GetGlobalMetrics

func (nydusd *Nydusd) GetGlobalMetrics() (*GlobalMetrics, error)

func (*Nydusd) GetInflightMetrics

func (nydusd *Nydusd) GetInflightMetrics() (*InflightMetrics, error)

func (*Nydusd) GetLatestFileMetrics

func (nydusd *Nydusd) GetLatestFileMetrics() ([][]uint64, error)

func (*Nydusd) Mount

func (nydusd *Nydusd) Mount() error

func (*Nydusd) MountByAPI

func (nydusd *Nydusd) MountByAPI(config NydusdConfig) error

func (*Nydusd) Umount

func (nydusd *Nydusd) Umount() error

type NydusdConfig

type NydusdConfig struct {
	EnablePrefetch  bool
	NydusdPath      string
	BootstrapPath   string
	ConfigPath      string
	BackendType     string
	BackendConfig   string
	BlobCacheDir    string
	APISockPath     string
	MountPath       string
	RafsMode        string
	DigestValidate  bool
	CacheType       string
	CacheCompressed bool
	IOStatsFiles    bool
	LatestReadFiles bool
	AccessPattern   bool
	PrefetchFiles   []string
	AmplifyIO       uint64
}

type Registry

type Registry struct {
}

func (*Registry) Destory

func (registry *Registry) Destory(t *testing.T)

func (*Registry) Serve

func (registry *Registry) Serve(t *testing.T)