glutton

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)
}

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)
	// 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 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 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
}