types

type Blockdevice struct {
	Name      string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Major     int32  `protobuf:"varint,2,opt,name=major,proto3" json:"major,omitempty"`
	Minor     int32  `protobuf:"varint,3,opt,name=minor,proto3" json:"minor,omitempty"`
	Operation string `protobuf:"bytes,4,opt,name=operation,proto3" json:"operation,omitempty"`
	// contains filtered or unexported fields
}

type Error struct {
	Code    int32  `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	Domain  string `protobuf:"bytes,2,opt,name=domain,proto3" json:"domain,omitempty"`
	Source  string `protobuf:"bytes,3,opt,name=source,proto3" json:"source,omitempty"`
	Message string `protobuf:"bytes,4,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

type Event struct {
	Data *any.Any `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	Id   string   `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

type IO struct {
	Command   string `protobuf:"bytes,1,opt,name=command,proto3" json:"command,omitempty"`
	Pid       uint32 `protobuf:"varint,2,opt,name=pid,proto3" json:"pid,omitempty"`
	Disk      string `protobuf:"bytes,3,opt,name=disk,proto3" json:"disk,omitempty"`
	Operation string `protobuf:"bytes,4,opt,name=operation,proto3" json:"operation,omitempty"`
	// contains filtered or unexported fields
}

type SinkClient interface {
	Events(ctx context.Context, opts ...grpc.CallOption) (Sink_EventsClient, error)
}

type SinkServer interface {
	Events(Sink_EventsServer) error
}

type Sink_EventsClient interface {
	Send(*Event) error
	CloseAndRecv() (*empty.Empty, error)
	grpc.ClientStream
}

type Sink_EventsServer interface {
	SendAndClose(*empty.Empty) error
	Recv() (*Event, error)
	grpc.ServerStream
}

type UnimplementedSinkServer struct {
}