glutton

type BurnCPURequest struct {

	// Wall-clock time to keep burning, in milliseconds.
	DurationMs int64 `protobuf:"varint,1,opt,name=duration_ms,json=durationMs,proto3" json:"duration_ms,omitempty"`
	// Number of goroutines burning concurrently; values < 1 read as 1.
	Parallelism int32 `protobuf:"varint,2,opt,name=parallelism,proto3" json:"parallelism,omitempty"`
	// contains filtered or unexported fields
}

type BurnCPUResponse struct {

	// Total hash iterations completed across all goroutines, so the burn
	// is observable and cannot be optimized away.
	Iterations int64 `protobuf:"varint,1,opt,name=iterations,proto3" json:"iterations,omitempty"`
	// contains filtered or unexported fields
}

type GluttonClient interface {
	// Tells glutton to write to RAM, either overwriting previously-used
	// RAM or allocating additional RAM per request instructions. Data written
	// will be random bytes.
	WriteRAM(ctx context.Context, in *WriteRAMRequest, opts ...grpc.CallOption) (*WriteRAMResponse, error)
	// Walks RAM previously allocated by WriteRAM: reads one byte per 4KiB
	// page across the requested size, so every touched page must be resident
	// before the response returns.
	ReadRAM(ctx context.Context, in *ReadRAMRequest, opts ...grpc.CallOption) (*ReadRAMResponse, error)
	// Tells glutton to write to disk using the specified mode. Data
	// written will be random bytes.
	WriteDisk(ctx context.Context, in *WriteDiskRequest, opts ...grpc.CallOption) (*WriteDiskResponse, error)
	// Tells glutton to read from disk using the specified mode.
	ReadDisk(ctx context.Context, in *ReadDiskRequest, opts ...grpc.CallOption) (*ReadDiskResponse, error)
	// Tells glutton to make sure it has the specified number of file
	// descriptors open. It will open or close file descriptors to
	// hit the desired count (note this count is in addition to the other
	// FDs needed to run the process).
	OpenFD(ctx context.Context, in *OpenFDRequest, opts ...grpc.CallOption) (*OpenFDResponse, error)
	// Send a request to the glutton, expecting the same response back.
	Ping(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*PingResponse, error)
	// Tells the glutton to send network traffic to a peer glutton.
	// messages will be sent on regular intervals separated by delay_ms.
	Gossip(ctx context.Context, in *GossipRequest, opts ...grpc.CallOption) (*GossipResponse, error)
	// Tells glutton to spin CPU for a wall-clock duration, hashing in a
	// tight loop across the requested number of goroutines. Models
	// compute-bound work such as compiling or running a test suite.
	BurnCPU(ctx context.Context, in *BurnCPURequest, opts ...grpc.CallOption) (*BurnCPUResponse, error)
	// Carries caller-supplied bytes over the wire into the glutton, which
	// writes them to a file under its data dir. Unlike WriteDisk, the bytes
	// cross the network, so the request models a download (git clone,
	// dependency fetch) arriving through the actor's ingress path.
	Ingest(ctx context.Context, in *IngestRequest, opts ...grpc.CallOption) (*IngestResponse, error)
	// Tells the glutton to consume CPU. The request sets the current CPU
	// load; calling again replaces it, and num_cores=0 stops it. See
	// UseCPURequest for the (goroutines x duty cycle) shape.
	UseCPU(ctx context.Context, in *UseCPURequest, opts ...grpc.CallOption) (*UseCPUResponse, error)
}

type GluttonServer interface {
	// Tells glutton to write to RAM, either overwriting previously-used
	// RAM or allocating additional RAM per request instructions. Data written
	// will be random bytes.
	WriteRAM(context.Context, *WriteRAMRequest) (*WriteRAMResponse, error)
	// Walks RAM previously allocated by WriteRAM: reads one byte per 4KiB
	// page across the requested size, so every touched page must be resident
	// before the response returns.
	ReadRAM(context.Context, *ReadRAMRequest) (*ReadRAMResponse, error)
	// Tells glutton to write to disk using the specified mode. Data
	// written will be random bytes.
	WriteDisk(context.Context, *WriteDiskRequest) (*WriteDiskResponse, error)
	// Tells glutton to read from disk using the specified mode.
	ReadDisk(context.Context, *ReadDiskRequest) (*ReadDiskResponse, error)
	// Tells glutton to make sure it has the specified number of file
	// descriptors open. It will open or close file descriptors to
	// hit the desired count (note this count is in addition to the other
	// FDs needed to run the process).
	OpenFD(context.Context, *OpenFDRequest) (*OpenFDResponse, error)
	// Send a request to the glutton, expecting the same response back.
	Ping(context.Context, *PingRequest) (*PingResponse, error)
	// Tells the glutton to send network traffic to a peer glutton.
	// messages will be sent on regular intervals separated by delay_ms.
	Gossip(context.Context, *GossipRequest) (*GossipResponse, error)
	// Tells glutton to spin CPU for a wall-clock duration, hashing in a
	// tight loop across the requested number of goroutines. Models
	// compute-bound work such as compiling or running a test suite.
	BurnCPU(context.Context, *BurnCPURequest) (*BurnCPUResponse, error)
	// Carries caller-supplied bytes over the wire into the glutton, which
	// writes them to a file under its data dir. Unlike WriteDisk, the bytes
	// cross the network, so the request models a download (git clone,
	// dependency fetch) arriving through the actor's ingress path.
	Ingest(context.Context, *IngestRequest) (*IngestResponse, error)
	// Tells the glutton to consume CPU. The request sets the current CPU
	// load; calling again replaces it, and num_cores=0 stops it. See
	// UseCPURequest for the (goroutines x duty cycle) shape.
	UseCPU(context.Context, *UseCPURequest) (*UseCPUResponse, error)
	// contains filtered or unexported methods
}

type GossipRequest struct {
	Peers []*Peer `protobuf:"bytes,1,rep,name=peers,proto3" json:"peers,omitempty"`
	// contains filtered or unexported fields
}

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

type IngestRequest struct {

	// name of the file the payload is written to
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// the bytes to write, carried in the request body over the network
	Payload []byte `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
	// append to the file instead of truncating it
	Append bool `protobuf:"varint,3,opt,name=append,proto3" json:"append,omitempty"`
	// contains filtered or unexported fields
}

type IngestResponse struct {

	// size of the file after the write
	Size int64 `protobuf:"varint,1,opt,name=size,proto3" json:"size,omitempty"`
	// sha256 of the payload as received, so the caller can verify transport
	Sha256 []byte `protobuf:"bytes,2,opt,name=sha256,proto3" json:"sha256,omitempty"`
	// contains filtered or unexported fields
}

type OpenFDRequest struct {

	// The total number of FDs for the glutton to open
	Count int32 `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

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

type Peer struct {
	Host    string `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
	DelayMs int32  `protobuf:"varint,2,opt,name=delay_ms,json=delayMs,proto3" json:"delay_ms,omitempty"`
	// contains filtered or unexported fields
}

type PingRequest struct {

	// The message to be echoed back from the ping
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

type PingResponse struct {

	// The message echoed back
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

type ReadDiskRequest struct {

	// name of the file to be read from
	Key      string   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	ReadMode ReadMode `protobuf:"varint,2,opt,name=read_mode,json=readMode,proto3,enum=glutton.ReadMode" json:"read_mode,omitempty"`
	// contains filtered or unexported fields
}

type ReadDiskResponse struct {

	// total size of bytes read
	Size int64 `protobuf:"varint,1,opt,name=size,proto3" json:"size,omitempty"`
	// sha256 of bytes read
	Sha256 []byte `protobuf:"bytes,2,opt,name=sha256,proto3" json:"sha256,omitempty"`
	// data read from the file. Empty under READ_MODE_DIGEST_ONLY.
	Data []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

type ReadMode int32

type ReadRAMRequest struct {

	// name of the array to be read
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// size of bytes to walk, with an optional unit suffix (e.g. "2Gi");
	// empty walks the whole array
	Size string `protobuf:"bytes,2,opt,name=size,proto3" json:"size,omitempty"`
	// contains filtered or unexported fields
}

type ReadRAMResponse struct {

	// total size of bytes walked
	Size int64 `protobuf:"varint,1,opt,name=size,proto3" json:"size,omitempty"`
	// XOR of the sampled bytes, so the reads are observable
	Checksum uint32 `protobuf:"varint,2,opt,name=checksum,proto3" json:"checksum,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedGluttonServer struct{}

type UnsafeGluttonServer interface {
	// contains filtered or unexported methods
}

type UseCPURequest struct {

	// Number of parallel goroutines to spin, each targeting duty_cycle
	// fraction of one CPU core. Set to 0 to stop all CPU load.
	NumCores int32 `protobuf:"varint,1,opt,name=num_cores,json=numCores,proto3" json:"num_cores,omitempty"`
	// Fraction of CPU time each goroutine should consume, in [0.0, 1.0].
	DutyCycle float64 `protobuf:"fixed64,2,opt,name=duty_cycle,json=dutyCycle,proto3" json:"duty_cycle,omitempty"`
	// Per-goroutine work/sleep cycle length in milliseconds. Defaults to
	// 100 when 0 or unset. Smaller values give smoother load at the cost
	// of scheduler and timer-wheel overhead.
	CycleLengthMs int32 `protobuf:"varint,3,opt,name=cycle_length_ms,json=cycleLengthMs,proto3" json:"cycle_length_ms,omitempty"`
	// Whether num_cores should be capped at GOMAXPROCS. Defaults to true
	// when unset. Uncapped (false) lets the caller force oversubscription
	// to test scheduler pressure, at the cost of goroutines running below
	// their target duty cycle.
	CapAtGomaxprocs *bool `protobuf:"varint,4,opt,name=cap_at_gomaxprocs,json=capAtGomaxprocs,proto3,oneof" json:"cap_at_gomaxprocs,omitempty"`
	// contains filtered or unexported fields
}

type UseCPUResponse struct {

	// The number of goroutines actually spun. Equals the request's
	// num_cores unless it was capped at GOMAXPROCS.
	NumCores int32 `protobuf:"varint,1,opt,name=num_cores,json=numCores,proto3" json:"num_cores,omitempty"`
	// contains filtered or unexported fields
}

type WriteDiskRequest struct {

	// name of the file to be written to
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// size of bytes to be written
	Size      int32     `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"`
	WriteMode WriteMode `protobuf:"varint,3,opt,name=write_mode,json=writeMode,proto3,enum=glutton.WriteMode" json:"write_mode,omitempty"`
	// contains filtered or unexported fields
}

type WriteDiskResponse struct {

	// size of the file after the write
	Size int64 `protobuf:"varint,1,opt,name=size,proto3" json:"size,omitempty"`
	// sha256 of the whole file after the write
	Sha256 []byte `protobuf:"bytes,2,opt,name=sha256,proto3" json:"sha256,omitempty"`
	// contains filtered or unexported fields
}

type WriteMode int32

type WriteRAMRequest struct {

	// name of the array to be written to
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// size of bytes to be written, with an optional unit suffix (e.g. "2Gi")
	Size      string    `protobuf:"bytes,2,opt,name=size,proto3" json:"size,omitempty"`
	WriteMode WriteMode `protobuf:"varint,3,opt,name=write_mode,json=writeMode,proto3,enum=glutton.WriteMode" json:"write_mode,omitempty"`
	// contains filtered or unexported fields
}

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