proto

package
v0.0.0-...-3bfe646 Latest Latest
Warning

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

 Go to latest Published: Jun 28, 2023 License: Apache-2.0 Imports: 16 Imported by: 4

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func DurationFromProto 

func DurationFromProto(d *types.Duration) (time.Duration, error)

DurationFromProto returns a time.Duration from the given protobuf value

func DurationProto 

func DurationProto(d time.Duration) *types.Duration

DurationProto returns a protobuf equivalent for the specified time.Duration

func RegisterValidationServer 

func RegisterValidationServer(s *grpc.Server, srv ValidationServer)

Types

type Addr 

type Addr struct {
	// Network specifies the type of network (tcp, udp)
	Network string `protobuf:"bytes,1,opt,name=network,proto3" json:"network,omitempty"`
	// Addr specifies the address as IP or IP:port
	Addr                 string   `protobuf:"bytes,2,opt,name=addr,proto3" json:"addr,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Addr defines an endpoint address

func (Addr) Address 

func (r Addr) Address() string

Address returns a text representation of this server

func (*Addr) Descriptor 

func (*Addr) Descriptor() ([]byte, []int)

func (*Addr) GetAddr 

func (m *Addr) GetAddr() string

func (*Addr) GetNetwork 

func (m *Addr) GetNetwork() string

func (*Addr) ProtoMessage 

func (*Addr) ProtoMessage()

func (*Addr) Reset 

func (m *Addr) Reset()

func (*Addr) String 

func (m *Addr) String() string

func (*Addr) XXX_DiscardUnknown 

func (m *Addr) XXX_DiscardUnknown()

func (*Addr) XXX_Marshal 

func (m *Addr) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Addr) XXX_Merge 

func (m *Addr) XXX_Merge(src proto.Message)

func (*Addr) XXX_Size 

func (m *Addr) XXX_Size() int

func (*Addr) XXX_Unmarshal 

func (m *Addr) XXX_Unmarshal(b []byte) error

type CheckBandwidthRequest 

type CheckBandwidthRequest struct {
	// Listen specifies the listen endpoint
	Listen *Addr `protobuf:"bytes,1,opt,name=listen,proto3" json:"listen,omitempty"`
	// Ping specifies the ping endpoints
	Ping []*Addr `protobuf:"bytes,2,rep,name=ping,proto3" json:"ping,omitempty"`
	// Duration specifies the maximum duration for the request
	Duration             *types.Duration `protobuf:"bytes,3,opt,name=duration,proto3" json:"duration,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

CheckBandwidthRequest describes a bandwidth check network test

func (CheckBandwidthRequest) Check 

func (r CheckBandwidthRequest) Check() error

Check makes sure the request is correct

func (*CheckBandwidthRequest) Descriptor 

func (*CheckBandwidthRequest) Descriptor() ([]byte, []int)

func (*CheckBandwidthRequest) GetDuration 

func (m *CheckBandwidthRequest) GetDuration() *types.Duration

func (*CheckBandwidthRequest) GetListen 

func (m *CheckBandwidthRequest) GetListen() *Addr

func (*CheckBandwidthRequest) GetPing 

func (m *CheckBandwidthRequest) GetPing() []*Addr

func (*CheckBandwidthRequest) ProtoMessage 

func (*CheckBandwidthRequest) ProtoMessage()

func (*CheckBandwidthRequest) Reset 

func (m *CheckBandwidthRequest) Reset()

func (*CheckBandwidthRequest) String 

func (m *CheckBandwidthRequest) String() string

func (*CheckBandwidthRequest) XXX_DiscardUnknown 

func (m *CheckBandwidthRequest) XXX_DiscardUnknown()

func (*CheckBandwidthRequest) XXX_Marshal 

func (m *CheckBandwidthRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CheckBandwidthRequest) XXX_Merge 

func (m *CheckBandwidthRequest) XXX_Merge(src proto.Message)

func (*CheckBandwidthRequest) XXX_Size 

func (m *CheckBandwidthRequest) XXX_Size() int

func (*CheckBandwidthRequest) XXX_Unmarshal 

func (m *CheckBandwidthRequest) XXX_Unmarshal(b []byte) error

type CheckBandwidthResponse 

type CheckBandwidthResponse struct {
	// Bandwidth is the result of a bandwidth test
	Bandwidth            uint64   `protobuf:"varint,1,opt,name=bandwidth,proto3" json:"bandwidth,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

CheckBandwidthResponse describes the results of a bandwidth check

func (*CheckBandwidthResponse) Descriptor 

func (*CheckBandwidthResponse) Descriptor() ([]byte, []int)

func (*CheckBandwidthResponse) GetBandwidth 

func (m *CheckBandwidthResponse) GetBandwidth() uint64

func (*CheckBandwidthResponse) ProtoMessage 

func (*CheckBandwidthResponse) ProtoMessage()

func (*CheckBandwidthResponse) Reset 

func (m *CheckBandwidthResponse) Reset()

func (*CheckBandwidthResponse) String 

func (m *CheckBandwidthResponse) String() string

func (*CheckBandwidthResponse) XXX_DiscardUnknown 

func (m *CheckBandwidthResponse) XXX_DiscardUnknown()

func (*CheckBandwidthResponse) XXX_Marshal 

func (m *CheckBandwidthResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CheckBandwidthResponse) XXX_Merge 

func (m *CheckBandwidthResponse) XXX_Merge(src proto.Message)

func (*CheckBandwidthResponse) XXX_Size 

func (m *CheckBandwidthResponse) XXX_Size() int

func (*CheckBandwidthResponse) XXX_Unmarshal 

func (m *CheckBandwidthResponse) XXX_Unmarshal(b []byte) error

type CheckDisksRequest 

type CheckDisksRequest struct {
	// Jobs specifies a list of fio jobs to execute.
	Jobs []*FioJobSpec `protobuf:"bytes,1,rep,name=jobs,proto3" json:"jobs,omitempty"`
	// FioPath specifies the path to fio executable.
	FioPath              string   `protobuf:"bytes,2,opt,name=fio_path,json=fioPath,proto3" json:"fio_path,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

CheckDisksRequest describes a disks performance test request.

func (*CheckDisksRequest) CheckAndSetDefaults 

func (r *CheckDisksRequest) CheckAndSetDefaults() error

CheckAndSetDefaults validates the request and sets defaults.

func (*CheckDisksRequest) Descriptor 

func (*CheckDisksRequest) Descriptor() ([]byte, []int)

func (*CheckDisksRequest) GetFioPath 

func (m *CheckDisksRequest) GetFioPath() string

func (*CheckDisksRequest) GetJobs 

func (m *CheckDisksRequest) GetJobs() []*FioJobSpec

func (*CheckDisksRequest) ProtoMessage 

func (*CheckDisksRequest) ProtoMessage()

func (*CheckDisksRequest) Reset 

func (m *CheckDisksRequest) Reset()

func (*CheckDisksRequest) String 

func (m *CheckDisksRequest) String() string

func (*CheckDisksRequest) XXX_DiscardUnknown 

func (m *CheckDisksRequest) XXX_DiscardUnknown()

func (*CheckDisksRequest) XXX_Marshal 

func (m *CheckDisksRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CheckDisksRequest) XXX_Merge 

func (m *CheckDisksRequest) XXX_Merge(src proto.Message)

func (*CheckDisksRequest) XXX_Size 

func (m *CheckDisksRequest) XXX_Size() int

func (*CheckDisksRequest) XXX_Unmarshal 

func (m *CheckDisksRequest) XXX_Unmarshal(b []byte) error

type CheckDisksResponse 

type CheckDisksResponse struct {
	// Jobs is a list of executed fio jobs.
	Jobs                 []*FioJobResult `protobuf:"bytes,1,rep,name=jobs,proto3" json:"jobs,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

CheckDisksResponse is the result of the disk performance test.

func (*CheckDisksResponse) Descriptor 

func (*CheckDisksResponse) Descriptor() ([]byte, []int)

func (*CheckDisksResponse) GetJobs 

func (m *CheckDisksResponse) GetJobs() []*FioJobResult

func (*CheckDisksResponse) ProtoMessage 

func (*CheckDisksResponse) ProtoMessage()

func (*CheckDisksResponse) Reset 

func (m *CheckDisksResponse) Reset()

func (*CheckDisksResponse) String 

func (m *CheckDisksResponse) String() string

func (*CheckDisksResponse) XXX_DiscardUnknown 

func (m *CheckDisksResponse) XXX_DiscardUnknown()

func (*CheckDisksResponse) XXX_Marshal 

func (m *CheckDisksResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CheckDisksResponse) XXX_Merge 

func (m *CheckDisksResponse) XXX_Merge(src proto.Message)

func (*CheckDisksResponse) XXX_Size 

func (m *CheckDisksResponse) XXX_Size() int

func (*CheckDisksResponse) XXX_Unmarshal 

func (m *CheckDisksResponse) XXX_Unmarshal(b []byte) error

type CheckPortsRequest 

type CheckPortsRequest struct {
	// Listen specifies the listen endpoints
	Listen []*Addr `protobuf:"bytes,1,rep,name=listen,proto3" json:"listen,omitempty"`
	// Ping specifies the ping endpoints
	Ping []*Addr `protobuf:"bytes,2,rep,name=ping,proto3" json:"ping,omitempty"`
	// Duration specifies the maximum duration for the request
	Duration             *types.Duration `protobuf:"bytes,3,opt,name=duration,proto3" json:"duration,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

CheckPortsRequest describes a ports network test request

func (CheckPortsRequest) Check 

func (r CheckPortsRequest) Check() error

Check makes sure the request is correct

func (*CheckPortsRequest) Descriptor 

func (*CheckPortsRequest) Descriptor() ([]byte, []int)

func (*CheckPortsRequest) GetDuration 

func (m *CheckPortsRequest) GetDuration() *types.Duration

func (*CheckPortsRequest) GetListen 

func (m *CheckPortsRequest) GetListen() []*Addr

func (*CheckPortsRequest) GetPing 

func (m *CheckPortsRequest) GetPing() []*Addr

func (*CheckPortsRequest) ProtoMessage 

func (*CheckPortsRequest) ProtoMessage()

func (*CheckPortsRequest) Reset 

func (m *CheckPortsRequest) Reset()

func (*CheckPortsRequest) String 

func (m *CheckPortsRequest) String() string

func (*CheckPortsRequest) XXX_DiscardUnknown 

func (m *CheckPortsRequest) XXX_DiscardUnknown()

func (*CheckPortsRequest) XXX_Marshal 

func (m *CheckPortsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CheckPortsRequest) XXX_Merge 

func (m *CheckPortsRequest) XXX_Merge(src proto.Message)

func (*CheckPortsRequest) XXX_Size 

func (m *CheckPortsRequest) XXX_Size() int

func (*CheckPortsRequest) XXX_Unmarshal 

func (m *CheckPortsRequest) XXX_Unmarshal(b []byte) error

type CheckPortsResponse 

type CheckPortsResponse struct {
	// Listen describes the listen test results
	Listen []*ServerResult `protobuf:"bytes,1,rep,name=listen,proto3" json:"listen,omitempty"`
	// Ping describes the ping test results
	Ping                 []*ServerResult `protobuf:"bytes,2,rep,name=ping,proto3" json:"ping,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

CheckPortsResponse describes the results of a ports network test

func (*CheckPortsResponse) Descriptor 

func (*CheckPortsResponse) Descriptor() ([]byte, []int)

func (CheckPortsResponse) FailureCount 

func (r CheckPortsResponse) FailureCount() int

FailureCount returns number of failures in the response

func (*CheckPortsResponse) GetListen 

func (m *CheckPortsResponse) GetListen() []*ServerResult

func (*CheckPortsResponse) GetPing 

func (m *CheckPortsResponse) GetPing() []*ServerResult

func (*CheckPortsResponse) ProtoMessage 

func (*CheckPortsResponse) ProtoMessage()

func (*CheckPortsResponse) Reset 

func (m *CheckPortsResponse) Reset()

func (*CheckPortsResponse) String 

func (m *CheckPortsResponse) String() string

func (*CheckPortsResponse) XXX_DiscardUnknown 

func (m *CheckPortsResponse) XXX_DiscardUnknown()

func (*CheckPortsResponse) XXX_Marshal 

func (m *CheckPortsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CheckPortsResponse) XXX_Merge 

func (m *CheckPortsResponse) XXX_Merge(src proto.Message)

func (*CheckPortsResponse) XXX_Size 

func (m *CheckPortsResponse) XXX_Size() int

func (*CheckPortsResponse) XXX_Unmarshal 

func (m *CheckPortsResponse) XXX_Unmarshal(b []byte) error

type Docker 

type Docker struct {
	// StorageDriver specifies the Docker storage driver
	StorageDriver        string   `protobuf:"bytes,1,opt,name=storage_driver,json=storageDriver,proto3" json:"storage_driver,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Docker groups Docker-relevant attributes to validate

func (*Docker) Descriptor 

func (*Docker) Descriptor() ([]byte, []int)

func (*Docker) GetStorageDriver 

func (m *Docker) GetStorageDriver() string

func (*Docker) ProtoMessage 

func (*Docker) ProtoMessage()

func (*Docker) Reset 

func (m *Docker) Reset()

func (*Docker) String 

func (m *Docker) String() string

func (*Docker) XXX_DiscardUnknown 

func (m *Docker) XXX_DiscardUnknown()

func (*Docker) XXX_Marshal 

func (m *Docker) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Docker) XXX_Merge 

func (m *Docker) XXX_Merge(src proto.Message)

func (*Docker) XXX_Size 

func (m *Docker) XXX_Size() int

func (*Docker) XXX_Unmarshal 

func (m *Docker) XXX_Unmarshal(b []byte) error

type FioJobResult 

type FioJobResult struct {
	// JobName is the name of the job.
	JobName string `protobuf:"bytes,1,opt,name=job_name,json=jobName,proto3" json:"jobname"`
	// Read contains metrics related to performed reads.
	Read *FioReadResult `protobuf:"bytes,2,opt,name=read,proto3" json:"read"`
	// Write contains metrics related to performed writes.
	Write *FioWriteResult `protobuf:"bytes,3,opt,name=write,proto3" json:"write"`
	// Sync contains metrics related to performed fsync calls.
	Sync                 *FioSyncResult `protobuf:"bytes,4,opt,name=sync,proto3" json:"sync"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

FioJobResult represents a result of a single fio job.

func (*FioJobResult) Descriptor 

func (*FioJobResult) Descriptor() ([]byte, []int)

func (FioJobResult) GetFsyncLatency 

func (r FioJobResult) GetFsyncLatency() int64

GetFsyncLatency returns 99th percentile of fsync latency in milliseconds.

func (*FioJobResult) GetJobName 

func (m *FioJobResult) GetJobName() string

func (*FioJobResult) GetRead 

func (m *FioJobResult) GetRead() *FioReadResult

func (*FioJobResult) GetSync 

func (m *FioJobResult) GetSync() *FioSyncResult

func (*FioJobResult) GetWrite 

func (m *FioJobResult) GetWrite() *FioWriteResult

func (FioJobResult) GetWriteIOPS 

func (r FioJobResult) GetWriteIOPS() float64

GetWriteIOPS returns number of write iops.

func (*FioJobResult) ProtoMessage 

func (*FioJobResult) ProtoMessage()

func (*FioJobResult) Reset 

func (m *FioJobResult) Reset()

func (*FioJobResult) String 

func (m *FioJobResult) String() string

func (*FioJobResult) XXX_DiscardUnknown 

func (m *FioJobResult) XXX_DiscardUnknown()

func (*FioJobResult) XXX_Marshal 

func (m *FioJobResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FioJobResult) XXX_Merge 

func (m *FioJobResult) XXX_Merge(src proto.Message)

func (*FioJobResult) XXX_Size 

func (m *FioJobResult) XXX_Size() int

func (*FioJobResult) XXX_Unmarshal 

func (m *FioJobResult) XXX_Unmarshal(b []byte) error

type FioJobSpec 

type FioJobSpec struct {
	// Name is the job name.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// ReadWrite specifies the I/O pattern.
	ReadWrite string `protobuf:"bytes,2,opt,name=read_write,json=readWrite,proto3" json:"read_write,omitempty"`
	// IOEngine specifies I/O engine to use.
	IoEngine string `protobuf:"bytes,3,opt,name=io_engine,json=ioEngine,proto3" json:"io_engine,omitempty"`
	// Fdatasync specifies whether to sync data.
	Fdatasync bool `protobuf:"varint,4,opt,name=fdatasync,proto3" json:"fdatasync,omitempty"`
	// Filename specifies the test file path.
	Filename string `protobuf:"bytes,5,opt,name=filename,proto3" json:"filename,omitempty"`
	// BlockSize is the block size used for I/O.
	BlockSize string `protobuf:"bytes,6,opt,name=block_size,json=blockSize,proto3" json:"block_size,omitempty"`
	// Size is the total test file size.
	Size_ string `protobuf:"bytes,7,opt,name=size,proto3" json:"size,omitempty"`
	// Runtime limits the maximum test runtime.
	Runtime              *types.Duration `protobuf:"bytes,8,opt,name=runtime,proto3" json:"runtime,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

FioJobSpec describes a single fio job.

func (FioJobSpec) Check 

func (r FioJobSpec) Check() error

Check validates the fio job spec.

func (*FioJobSpec) Descriptor 

func (*FioJobSpec) Descriptor() ([]byte, []int)

func (FioJobSpec) Flags 

func (r FioJobSpec) Flags() (flags []string)

Flags returns command-line flags for this fio job spec.

func (*FioJobSpec) GetBlockSize 

func (m *FioJobSpec) GetBlockSize() string

func (*FioJobSpec) GetFdatasync 

func (m *FioJobSpec) GetFdatasync() bool

func (*FioJobSpec) GetFilename 

func (m *FioJobSpec) GetFilename() string

func (*FioJobSpec) GetIoEngine 

func (m *FioJobSpec) GetIoEngine() string

func (*FioJobSpec) GetName 

func (m *FioJobSpec) GetName() string

func (*FioJobSpec) GetReadWrite 

func (m *FioJobSpec) GetReadWrite() string

func (*FioJobSpec) GetRuntime 

func (m *FioJobSpec) GetRuntime() *types.Duration

func (*FioJobSpec) GetSize_ 

func (m *FioJobSpec) GetSize_() string

func (*FioJobSpec) ProtoMessage 

func (*FioJobSpec) ProtoMessage()

func (*FioJobSpec) Reset 

func (m *FioJobSpec) Reset()

func (*FioJobSpec) String 

func (m *FioJobSpec) String() string

func (*FioJobSpec) XXX_DiscardUnknown 

func (m *FioJobSpec) XXX_DiscardUnknown()

func (*FioJobSpec) XXX_Marshal 

func (m *FioJobSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FioJobSpec) XXX_Merge 

func (m *FioJobSpec) XXX_Merge(src proto.Message)

func (*FioJobSpec) XXX_Size 

func (m *FioJobSpec) XXX_Size() int

func (*FioJobSpec) XXX_Unmarshal 

func (m *FioJobSpec) XXX_Unmarshal(b []byte) error

type FioReadResult 

type FioReadResult struct {
	// IOPS is the number of read iops.
	Iops                 float64  `protobuf:"fixed64,1,opt,name=iops,proto3" json:"iops"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

FioReadResult contains read-related metrics.

func (*FioReadResult) Descriptor 

func (*FioReadResult) Descriptor() ([]byte, []int)

func (*FioReadResult) GetIops 

func (m *FioReadResult) GetIops() float64

func (*FioReadResult) ProtoMessage 

func (*FioReadResult) ProtoMessage()

func (*FioReadResult) Reset 

func (m *FioReadResult) Reset()

func (*FioReadResult) String 

func (m *FioReadResult) String() string

func (*FioReadResult) XXX_DiscardUnknown 

func (m *FioReadResult) XXX_DiscardUnknown()

func (*FioReadResult) XXX_Marshal 

func (m *FioReadResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FioReadResult) XXX_Merge 

func (m *FioReadResult) XXX_Merge(src proto.Message)

func (*FioReadResult) XXX_Size 

func (m *FioReadResult) XXX_Size() int

func (*FioReadResult) XXX_Unmarshal 

func (m *FioReadResult) XXX_Unmarshal(b []byte) error

type FioSyncLatency 

type FioSyncLatency struct {
	// Percentile is the fsync percentile buckets.
	Percentile           map[string]int64 `` /* 152-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

FioSyncLatency contains fsync latencies distribution.

func (*FioSyncLatency) Descriptor 

func (*FioSyncLatency) Descriptor() ([]byte, []int)

func (*FioSyncLatency) GetPercentile 

func (m *FioSyncLatency) GetPercentile() map[string]int64

func (*FioSyncLatency) ProtoMessage 

func (*FioSyncLatency) ProtoMessage()

func (*FioSyncLatency) Reset 

func (m *FioSyncLatency) Reset()

func (*FioSyncLatency) String 

func (m *FioSyncLatency) String() string

func (*FioSyncLatency) XXX_DiscardUnknown 

func (m *FioSyncLatency) XXX_DiscardUnknown()

func (*FioSyncLatency) XXX_Marshal 

func (m *FioSyncLatency) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FioSyncLatency) XXX_Merge 

func (m *FioSyncLatency) XXX_Merge(src proto.Message)

func (*FioSyncLatency) XXX_Size 

func (m *FioSyncLatency) XXX_Size() int

func (*FioSyncLatency) XXX_Unmarshal 

func (m *FioSyncLatency) XXX_Unmarshal(b []byte) error

type FioSyncResult 

type FioSyncResult struct {
	// Latency contains fsync latencies distribution.
	Latency              *FioSyncLatency `protobuf:"bytes,1,opt,name=latency,proto3" json:"lat_ns"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

FioSyncResult contains fsync-related metrics.

func (*FioSyncResult) Descriptor 

func (*FioSyncResult) Descriptor() ([]byte, []int)

func (*FioSyncResult) GetLatency 

func (m *FioSyncResult) GetLatency() *FioSyncLatency

func (*FioSyncResult) ProtoMessage 

func (*FioSyncResult) ProtoMessage()

func (*FioSyncResult) Reset 

func (m *FioSyncResult) Reset()

func (*FioSyncResult) String 

func (m *FioSyncResult) String() string

func (*FioSyncResult) XXX_DiscardUnknown 

func (m *FioSyncResult) XXX_DiscardUnknown()

func (*FioSyncResult) XXX_Marshal 

func (m *FioSyncResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FioSyncResult) XXX_Merge 

func (m *FioSyncResult) XXX_Merge(src proto.Message)

func (*FioSyncResult) XXX_Size 

func (m *FioSyncResult) XXX_Size() int

func (*FioSyncResult) XXX_Unmarshal 

func (m *FioSyncResult) XXX_Unmarshal(b []byte) error

type FioWriteResult 

type FioWriteResult struct {
	// IOPS is the number of write iops.
	Iops                 float64  `protobuf:"fixed64,1,opt,name=iops,proto3" json:"iops"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

FioWriteResult contains write-related metrics.

func (*FioWriteResult) Descriptor 

func (*FioWriteResult) Descriptor() ([]byte, []int)

func (*FioWriteResult) GetIops 

func (m *FioWriteResult) GetIops() float64

func (*FioWriteResult) ProtoMessage 

func (*FioWriteResult) ProtoMessage()

func (*FioWriteResult) Reset 

func (m *FioWriteResult) Reset()

func (*FioWriteResult) String 

func (m *FioWriteResult) String() string

func (*FioWriteResult) XXX_DiscardUnknown 

func (m *FioWriteResult) XXX_DiscardUnknown()

func (*FioWriteResult) XXX_Marshal 

func (m *FioWriteResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FioWriteResult) XXX_Merge 

func (m *FioWriteResult) XXX_Merge(src proto.Message)

func (*FioWriteResult) XXX_Size 

func (m *FioWriteResult) XXX_Size() int

func (*FioWriteResult) XXX_Unmarshal 

func (m *FioWriteResult) XXX_Unmarshal(b []byte) error

type ServerResult 

type ServerResult struct {
	// Code specifies the result, with 0 for success
	Code int32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	// Error specifies an error message
	Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// Server specifies which server the result is from
	Server               *Addr    `protobuf:"bytes,3,opt,name=server,proto3" json:"server,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

ServerResult defines the operation result for a server

func (*ServerResult) Descriptor 

func (*ServerResult) Descriptor() ([]byte, []int)

func (*ServerResult) GetCode 

func (m *ServerResult) GetCode() int32

func (*ServerResult) GetError 

func (m *ServerResult) GetError() string

func (*ServerResult) GetServer 

func (m *ServerResult) GetServer() *Addr

func (*ServerResult) ProtoMessage 

func (*ServerResult) ProtoMessage()

func (*ServerResult) Reset 

func (m *ServerResult) Reset()

func (ServerResult) Result 

func (r ServerResult) Result() string

Result returns a text representation of this result

func (*ServerResult) String 

func (m *ServerResult) String() string

func (*ServerResult) XXX_DiscardUnknown 

func (m *ServerResult) XXX_DiscardUnknown()

func (*ServerResult) XXX_Marshal 

func (m *ServerResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ServerResult) XXX_Merge 

func (m *ServerResult) XXX_Merge(src proto.Message)

func (*ServerResult) XXX_Size 

func (m *ServerResult) XXX_Size() int

func (*ServerResult) XXX_Unmarshal 

func (m *ServerResult) XXX_Unmarshal(b []byte) error

type UnimplementedValidationServer 

type UnimplementedValidationServer struct {
}

UnimplementedValidationServer can be embedded to have forward compatible implementations.

func (*UnimplementedValidationServer) CheckBandwidth 

func (*UnimplementedValidationServer) CheckBandwidth(ctx context.Context, req *CheckBandwidthRequest) (*CheckBandwidthResponse, error)

func (*UnimplementedValidationServer) CheckDisks 

func (*UnimplementedValidationServer) CheckDisks(ctx context.Context, req *CheckDisksRequest) (*CheckDisksResponse, error)

func (*UnimplementedValidationServer) CheckPorts 

func (*UnimplementedValidationServer) CheckPorts(ctx context.Context, req *CheckPortsRequest) (*CheckPortsResponse, error)

func (*UnimplementedValidationServer) Validate 

func (*UnimplementedValidationServer) Validate(ctx context.Context, req *ValidateRequest) (*ValidateResponse, error)

type ValidateOptions 

type ValidateOptions struct {
	// VxlanPort is the custom overlay network port
	VxlanPort int32 `protobuf:"varint,1,opt,name=vxlan_port,json=vxlanPort,proto3" json:"vxlan_port,omitempty"`
	// DnsAddrs specifies the list of listen IP addresses for coredns
	DnsAddrs []string `protobuf:"bytes,2,rep,name=dns_addrs,json=dnsAddrs,proto3" json:"dns_addrs,omitempty"`
	// DnsPort specifies the DNS port for coredns
	DnsPort              int32    `protobuf:"varint,3,opt,name=dns_port,json=dnsPort,proto3" json:"dns_port,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

ValidateOptions is additional validation options

func (*ValidateOptions) Descriptor 

func (*ValidateOptions) Descriptor() ([]byte, []int)

func (*ValidateOptions) GetDnsAddrs 

func (m *ValidateOptions) GetDnsAddrs() []string

func (*ValidateOptions) GetDnsPort 

func (m *ValidateOptions) GetDnsPort() int32

func (*ValidateOptions) GetVxlanPort 

func (m *ValidateOptions) GetVxlanPort() int32

func (*ValidateOptions) ProtoMessage 

func (*ValidateOptions) ProtoMessage()

func (*ValidateOptions) Reset 

func (m *ValidateOptions) Reset()

func (*ValidateOptions) String 

func (m *ValidateOptions) String() string

func (*ValidateOptions) XXX_DiscardUnknown 

func (m *ValidateOptions) XXX_DiscardUnknown()

func (*ValidateOptions) XXX_Marshal 

func (m *ValidateOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ValidateOptions) XXX_Merge 

func (m *ValidateOptions) XXX_Merge(src proto.Message)

func (*ValidateOptions) XXX_Size 

func (m *ValidateOptions) XXX_Size() int

func (*ValidateOptions) XXX_Unmarshal 

func (m *ValidateOptions) XXX_Unmarshal(b []byte) error

type ValidateRequest 

type ValidateRequest struct {
	// Manifest specifies the application manifest with
	// requirements
	Manifest []byte `protobuf:"bytes,1,opt,name=manifest,proto3" json:"manifest,omitempty"`
	// Profile specifies the node profile to validate against
	Profile string `protobuf:"bytes,2,opt,name=profile,proto3" json:"profile,omitempty"`
	// FullRequirements forces validation of all requirements
	// from the manifest.
	// This is used to validate requirements during installation.
	FullRequirements bool `protobuf:"varint,3,opt,name=full_requirements,json=fullRequirements,proto3" json:"full_requirements,omitempty"`
	// ValidateOptions is additional validation options
	Options *ValidateOptions `protobuf:"bytes,4,opt,name=options,proto3" json:"options,omitempty"`
	// Docker specifies the Docker configuration to validate
	Docker               *Docker  `protobuf:"bytes,5,opt,name=docker,proto3" json:"docker,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

ValidateRequest defines a request to run validation

func (*ValidateRequest) Descriptor 

func (*ValidateRequest) Descriptor() ([]byte, []int)

func (*ValidateRequest) GetDocker 

func (m *ValidateRequest) GetDocker() *Docker

func (*ValidateRequest) GetFullRequirements 

func (m *ValidateRequest) GetFullRequirements() bool

func (*ValidateRequest) GetManifest 

func (m *ValidateRequest) GetManifest() []byte

func (*ValidateRequest) GetOptions 

func (m *ValidateRequest) GetOptions() *ValidateOptions

func (*ValidateRequest) GetProfile 

func (m *ValidateRequest) GetProfile() string

func (*ValidateRequest) ProtoMessage 

func (*ValidateRequest) ProtoMessage()

func (*ValidateRequest) Reset 

func (m *ValidateRequest) Reset()

func (*ValidateRequest) String 

func (m *ValidateRequest) String() string

func (*ValidateRequest) XXX_DiscardUnknown 

func (m *ValidateRequest) XXX_DiscardUnknown()

func (*ValidateRequest) XXX_Marshal 

func (m *ValidateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ValidateRequest) XXX_Merge 

func (m *ValidateRequest) XXX_Merge(src proto.Message)

func (*ValidateRequest) XXX_Size 

func (m *ValidateRequest) XXX_Size() int

func (*ValidateRequest) XXX_Unmarshal 

func (m *ValidateRequest) XXX_Unmarshal(b []byte) error

type ValidateResponse 

type ValidateResponse struct {
	// Failed lists the failed probes
	Failed               []*agentpb.Probe `protobuf:"bytes,1,rep,name=failed,proto3" json:"failed,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

ValidateResponse describes a validation response

func (*ValidateResponse) Descriptor 

func (*ValidateResponse) Descriptor() ([]byte, []int)

func (*ValidateResponse) GetFailed 

func (m *ValidateResponse) GetFailed() []*agentpb.Probe

func (*ValidateResponse) ProtoMessage 

func (*ValidateResponse) ProtoMessage()

func (*ValidateResponse) Reset 

func (m *ValidateResponse) Reset()

func (*ValidateResponse) String 

func (m *ValidateResponse) String() string

func (*ValidateResponse) XXX_DiscardUnknown 

func (m *ValidateResponse) XXX_DiscardUnknown()

func (*ValidateResponse) XXX_Marshal 

func (m *ValidateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ValidateResponse) XXX_Merge 

func (m *ValidateResponse) XXX_Merge(src proto.Message)

func (*ValidateResponse) XXX_Size 

func (m *ValidateResponse) XXX_Size() int

func (*ValidateResponse) XXX_Unmarshal 

func (m *ValidateResponse) XXX_Unmarshal(b []byte) error

type ValidationClient 

type ValidationClient interface {
	// CheckPorts executes a ports network test
	CheckPorts(ctx context.Context, in *CheckPortsRequest, opts ...grpc.CallOption) (*CheckPortsResponse, error)
	// CheckBandwidth executes a bandwidth network test
	CheckBandwidth(ctx context.Context, in *CheckBandwidthRequest, opts ...grpc.CallOption) (*CheckBandwidthResponse, error)
	// CheckDisks executes performance test for the specified disks
	CheckDisks(ctx context.Context, in *CheckDisksRequest, opts ...grpc.CallOption) (*CheckDisksResponse, error)
	// Validate validatest this node against the requirements
	// from a manifest.
	Validate(ctx context.Context, in *ValidateRequest, opts ...grpc.CallOption) (*ValidateResponse, error)
}

ValidationClient is the client API for Validation service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewValidationClient 

func NewValidationClient(cc *grpc.ClientConn) ValidationClient

type ValidationServer 

type ValidationServer interface {
	// CheckPorts executes a ports network test
	CheckPorts(context.Context, *CheckPortsRequest) (*CheckPortsResponse, error)
	// CheckBandwidth executes a bandwidth network test
	CheckBandwidth(context.Context, *CheckBandwidthRequest) (*CheckBandwidthResponse, error)
	// CheckDisks executes performance test for the specified disks
	CheckDisks(context.Context, *CheckDisksRequest) (*CheckDisksResponse, error)
	// Validate validatest this node against the requirements
	// from a manifest.
	Validate(context.Context, *ValidateRequest) (*ValidateResponse, error)
}

ValidationServer is the server API for Validation service.

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.