Versions in this module Expand all Collapse all v0 v0.1.0 Sep 9, 2026 Changes in this version + const Glutton_Gossip_FullMethodName + const Glutton_OpenFD_FullMethodName + const Glutton_Ping_FullMethodName + const Glutton_ReadDisk_FullMethodName + const Glutton_ReadRAM_FullMethodName + const Glutton_WriteDisk_FullMethodName + const Glutton_WriteRAM_FullMethodName + var File_glutton_proto protoreflect.FileDescriptor + var Glutton_ServiceDesc = grpc.ServiceDesc + var ReadMode_name = map[int32]string + var ReadMode_value = map[string]int32 + var WriteMode_name = map[int32]string + var WriteMode_value = map[string]int32 + func RegisterGluttonServer(s grpc.ServiceRegistrar, srv GluttonServer) + type GluttonClient interface + Gossip func(ctx context.Context, in *GossipRequest, opts ...grpc.CallOption) (*GossipResponse, error) + OpenFD func(ctx context.Context, in *OpenFDRequest, opts ...grpc.CallOption) (*OpenFDResponse, error) + Ping func(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*PingResponse, error) + ReadDisk func(ctx context.Context, in *ReadDiskRequest, opts ...grpc.CallOption) (*ReadDiskResponse, error) + ReadRAM func(ctx context.Context, in *ReadRAMRequest, opts ...grpc.CallOption) (*ReadRAMResponse, error) + WriteDisk func(ctx context.Context, in *WriteDiskRequest, opts ...grpc.CallOption) (*WriteDiskResponse, error) + WriteRAM func(ctx context.Context, in *WriteRAMRequest, opts ...grpc.CallOption) (*WriteRAMResponse, error) + func NewGluttonClient(cc grpc.ClientConnInterface) GluttonClient + type GluttonServer interface + Gossip func(context.Context, *GossipRequest) (*GossipResponse, error) + OpenFD func(context.Context, *OpenFDRequest) (*OpenFDResponse, error) + Ping func(context.Context, *PingRequest) (*PingResponse, error) + ReadDisk func(context.Context, *ReadDiskRequest) (*ReadDiskResponse, error) + ReadRAM func(context.Context, *ReadRAMRequest) (*ReadRAMResponse, error) + WriteDisk func(context.Context, *WriteDiskRequest) (*WriteDiskResponse, error) + WriteRAM func(context.Context, *WriteRAMRequest) (*WriteRAMResponse, error) + type GossipRequest struct + Peers []*Peer + func (*GossipRequest) Descriptor() ([]byte, []int) + func (*GossipRequest) ProtoMessage() + func (x *GossipRequest) GetPeers() []*Peer + func (x *GossipRequest) ProtoReflect() protoreflect.Message + func (x *GossipRequest) Reset() + func (x *GossipRequest) String() string + type GossipResponse struct + func (*GossipResponse) Descriptor() ([]byte, []int) + func (*GossipResponse) ProtoMessage() + func (x *GossipResponse) ProtoReflect() protoreflect.Message + func (x *GossipResponse) Reset() + func (x *GossipResponse) String() string + type OpenFDRequest struct + Count int32 + func (*OpenFDRequest) Descriptor() ([]byte, []int) + func (*OpenFDRequest) ProtoMessage() + func (x *OpenFDRequest) GetCount() int32 + func (x *OpenFDRequest) ProtoReflect() protoreflect.Message + func (x *OpenFDRequest) Reset() + func (x *OpenFDRequest) String() string + type OpenFDResponse struct + func (*OpenFDResponse) Descriptor() ([]byte, []int) + func (*OpenFDResponse) ProtoMessage() + func (x *OpenFDResponse) ProtoReflect() protoreflect.Message + func (x *OpenFDResponse) Reset() + func (x *OpenFDResponse) String() string + type Peer struct + DelayMs int32 + Host string + func (*Peer) Descriptor() ([]byte, []int) + func (*Peer) ProtoMessage() + func (x *Peer) GetDelayMs() int32 + func (x *Peer) GetHost() string + func (x *Peer) ProtoReflect() protoreflect.Message + func (x *Peer) Reset() + func (x *Peer) String() string + type PingRequest struct + Message string + func (*PingRequest) Descriptor() ([]byte, []int) + func (*PingRequest) ProtoMessage() + func (x *PingRequest) GetMessage() string + func (x *PingRequest) ProtoReflect() protoreflect.Message + func (x *PingRequest) Reset() + func (x *PingRequest) String() string + type PingResponse struct + Message string + func (*PingResponse) Descriptor() ([]byte, []int) + func (*PingResponse) ProtoMessage() + func (x *PingResponse) GetMessage() string + func (x *PingResponse) ProtoReflect() protoreflect.Message + func (x *PingResponse) Reset() + func (x *PingResponse) String() string + type ReadDiskRequest struct + Key string + ReadMode ReadMode + func (*ReadDiskRequest) Descriptor() ([]byte, []int) + func (*ReadDiskRequest) ProtoMessage() + func (x *ReadDiskRequest) GetKey() string + func (x *ReadDiskRequest) GetReadMode() ReadMode + func (x *ReadDiskRequest) ProtoReflect() protoreflect.Message + func (x *ReadDiskRequest) Reset() + func (x *ReadDiskRequest) String() string + type ReadDiskResponse struct + Data []byte + Sha256 []byte + Size int64 + func (*ReadDiskResponse) Descriptor() ([]byte, []int) + func (*ReadDiskResponse) ProtoMessage() + func (x *ReadDiskResponse) GetData() []byte + func (x *ReadDiskResponse) GetSha256() []byte + func (x *ReadDiskResponse) GetSize() int64 + func (x *ReadDiskResponse) ProtoReflect() protoreflect.Message + func (x *ReadDiskResponse) Reset() + func (x *ReadDiskResponse) String() string + type ReadMode int32 + const ReadMode_READ_MODE_DATA + const ReadMode_READ_MODE_DIGEST_ONLY + func (ReadMode) Descriptor() protoreflect.EnumDescriptor + func (ReadMode) EnumDescriptor() ([]byte, []int) + func (ReadMode) Type() protoreflect.EnumType + func (x ReadMode) Enum() *ReadMode + func (x ReadMode) Number() protoreflect.EnumNumber + func (x ReadMode) String() string + type ReadRAMRequest struct + Key string + Size string + func (*ReadRAMRequest) Descriptor() ([]byte, []int) + func (*ReadRAMRequest) ProtoMessage() + func (x *ReadRAMRequest) GetKey() string + func (x *ReadRAMRequest) GetSize() string + func (x *ReadRAMRequest) ProtoReflect() protoreflect.Message + func (x *ReadRAMRequest) Reset() + func (x *ReadRAMRequest) String() string + type ReadRAMResponse struct + Checksum uint32 + Size int64 + func (*ReadRAMResponse) Descriptor() ([]byte, []int) + func (*ReadRAMResponse) ProtoMessage() + func (x *ReadRAMResponse) GetChecksum() uint32 + func (x *ReadRAMResponse) GetSize() int64 + func (x *ReadRAMResponse) ProtoReflect() protoreflect.Message + func (x *ReadRAMResponse) Reset() + func (x *ReadRAMResponse) String() string + type UnimplementedGluttonServer struct + func (UnimplementedGluttonServer) Gossip(context.Context, *GossipRequest) (*GossipResponse, error) + func (UnimplementedGluttonServer) OpenFD(context.Context, *OpenFDRequest) (*OpenFDResponse, error) + func (UnimplementedGluttonServer) Ping(context.Context, *PingRequest) (*PingResponse, error) + func (UnimplementedGluttonServer) ReadDisk(context.Context, *ReadDiskRequest) (*ReadDiskResponse, error) + func (UnimplementedGluttonServer) ReadRAM(context.Context, *ReadRAMRequest) (*ReadRAMResponse, error) + func (UnimplementedGluttonServer) WriteDisk(context.Context, *WriteDiskRequest) (*WriteDiskResponse, error) + func (UnimplementedGluttonServer) WriteRAM(context.Context, *WriteRAMRequest) (*WriteRAMResponse, error) + type UnsafeGluttonServer interface + type WriteDiskRequest struct + Key string + Size int32 + WriteMode WriteMode + func (*WriteDiskRequest) Descriptor() ([]byte, []int) + func (*WriteDiskRequest) ProtoMessage() + func (x *WriteDiskRequest) GetKey() string + func (x *WriteDiskRequest) GetSize() int32 + func (x *WriteDiskRequest) GetWriteMode() WriteMode + func (x *WriteDiskRequest) ProtoReflect() protoreflect.Message + func (x *WriteDiskRequest) Reset() + func (x *WriteDiskRequest) String() string + type WriteDiskResponse struct + Sha256 []byte + Size int64 + func (*WriteDiskResponse) Descriptor() ([]byte, []int) + func (*WriteDiskResponse) ProtoMessage() + func (x *WriteDiskResponse) GetSha256() []byte + func (x *WriteDiskResponse) GetSize() int64 + func (x *WriteDiskResponse) ProtoReflect() protoreflect.Message + func (x *WriteDiskResponse) Reset() + func (x *WriteDiskResponse) String() string + type WriteMode int32 + const WriteMode_WRITE_MODE_OVERWRITE + const WriteMode_WRITE_MODE_OVERWRITE_ROTATE + const WriteMode_WRITE_MODE_TRUNCATE + func (WriteMode) Descriptor() protoreflect.EnumDescriptor + func (WriteMode) EnumDescriptor() ([]byte, []int) + func (WriteMode) Type() protoreflect.EnumType + func (x WriteMode) Enum() *WriteMode + func (x WriteMode) Number() protoreflect.EnumNumber + func (x WriteMode) String() string + type WriteRAMRequest struct + Key string + Size string + WriteMode WriteMode + func (*WriteRAMRequest) Descriptor() ([]byte, []int) + func (*WriteRAMRequest) ProtoMessage() + func (x *WriteRAMRequest) GetKey() string + func (x *WriteRAMRequest) GetSize() string + func (x *WriteRAMRequest) GetWriteMode() WriteMode + func (x *WriteRAMRequest) ProtoReflect() protoreflect.Message + func (x *WriteRAMRequest) Reset() + func (x *WriteRAMRequest) String() string + type WriteRAMResponse struct + func (*WriteRAMResponse) Descriptor() ([]byte, []int) + func (*WriteRAMResponse) ProtoMessage() + func (x *WriteRAMResponse) ProtoReflect() protoreflect.Message + func (x *WriteRAMResponse) Reset() + func (x *WriteRAMResponse) String() string