Documentation ¶
Index ¶
- Variables
- func RegisterSeederWithMetaServer(s grpc.ServiceRegistrar, srv SeederWithMetaServer)
- type CloseArgs
- type CloseReply
- type MetaArgs
- type MetaReply
- type ReadAtArgs
- type ReadAtReply
- type SeederWithMetaClient
- type SeederWithMetaServer
- type SyncArgs
- type SyncReply
- type TrackArgs
- type TrackReply
- type UnimplementedSeederWithMetaServer
- func (UnimplementedSeederWithMetaServer) Close(context.Context, *CloseArgs) (*CloseReply, error)
- func (UnimplementedSeederWithMetaServer) Meta(context.Context, *MetaArgs) (*MetaReply, error)
- func (UnimplementedSeederWithMetaServer) ReadAt(context.Context, *ReadAtArgs) (*ReadAtReply, error)
- func (UnimplementedSeederWithMetaServer) Sync(context.Context, *SyncArgs) (*SyncReply, error)
- func (UnimplementedSeederWithMetaServer) Track(context.Context, *TrackArgs) (*TrackReply, error)
- type UnsafeSeederWithMetaServer
Constants ¶
This section is empty.
Variables ¶
var File_seeder_with_meta_proto protoreflect.FileDescriptor
var SeederWithMeta_ServiceDesc = grpc.ServiceDesc{ ServiceName: "io.loopholelabs.drafter.migration.v1.SeederWithMeta", HandlerType: (*SeederWithMetaServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "ReadAt", Handler: _SeederWithMeta_ReadAt_Handler, }, { MethodName: "Track", Handler: _SeederWithMeta_Track_Handler, }, { MethodName: "Sync", Handler: _SeederWithMeta_Sync_Handler, }, { MethodName: "Close", Handler: _SeederWithMeta_Close_Handler, }, { MethodName: "Meta", Handler: _SeederWithMeta_Meta_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "seeder_with_meta.proto", }
SeederWithMeta_ServiceDesc is the grpc.ServiceDesc for SeederWithMeta service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterSeederWithMetaServer ¶
func RegisterSeederWithMetaServer(s grpc.ServiceRegistrar, srv SeederWithMetaServer)
Types ¶
type CloseArgs ¶
type CloseArgs struct {
// contains filtered or unexported fields
}
func (*CloseArgs) Descriptor
deprecated
func (*CloseArgs) ProtoMessage ¶
func (*CloseArgs) ProtoMessage()
func (*CloseArgs) ProtoReflect ¶
func (x *CloseArgs) ProtoReflect() protoreflect.Message
type CloseReply ¶
type CloseReply struct {
// contains filtered or unexported fields
}
func (*CloseReply) Descriptor
deprecated
func (*CloseReply) Descriptor() ([]byte, []int)
Deprecated: Use CloseReply.ProtoReflect.Descriptor instead.
func (*CloseReply) ProtoMessage ¶
func (*CloseReply) ProtoMessage()
func (*CloseReply) ProtoReflect ¶
func (x *CloseReply) ProtoReflect() protoreflect.Message
func (*CloseReply) Reset ¶
func (x *CloseReply) Reset()
func (*CloseReply) String ¶
func (x *CloseReply) String() string
type MetaArgs ¶
type MetaArgs struct {
// contains filtered or unexported fields
}
func (*MetaArgs) Descriptor
deprecated
func (*MetaArgs) ProtoMessage ¶
func (*MetaArgs) ProtoMessage()
func (*MetaArgs) ProtoReflect ¶
func (x *MetaArgs) ProtoReflect() protoreflect.Message
type MetaReply ¶
type MetaReply struct { Size int64 `protobuf:"varint,1,opt,name=Size,proto3" json:"Size,omitempty"` // contains filtered or unexported fields }
func (*MetaReply) Descriptor
deprecated
func (*MetaReply) ProtoMessage ¶
func (*MetaReply) ProtoMessage()
func (*MetaReply) ProtoReflect ¶
func (x *MetaReply) ProtoReflect() protoreflect.Message
type ReadAtArgs ¶
type ReadAtArgs struct { Length int32 `protobuf:"varint,1,opt,name=Length,proto3" json:"Length,omitempty"` Off int64 `protobuf:"varint,2,opt,name=Off,proto3" json:"Off,omitempty"` // contains filtered or unexported fields }
func (*ReadAtArgs) Descriptor
deprecated
func (*ReadAtArgs) Descriptor() ([]byte, []int)
Deprecated: Use ReadAtArgs.ProtoReflect.Descriptor instead.
func (*ReadAtArgs) GetLength ¶
func (x *ReadAtArgs) GetLength() int32
func (*ReadAtArgs) GetOff ¶
func (x *ReadAtArgs) GetOff() int64
func (*ReadAtArgs) ProtoMessage ¶
func (*ReadAtArgs) ProtoMessage()
func (*ReadAtArgs) ProtoReflect ¶
func (x *ReadAtArgs) ProtoReflect() protoreflect.Message
func (*ReadAtArgs) Reset ¶
func (x *ReadAtArgs) Reset()
func (*ReadAtArgs) String ¶
func (x *ReadAtArgs) String() string
type ReadAtReply ¶
type ReadAtReply struct { N int32 `protobuf:"varint,1,opt,name=N,proto3" json:"N,omitempty"` P []byte `protobuf:"bytes,2,opt,name=P,proto3" json:"P,omitempty"` // contains filtered or unexported fields }
func (*ReadAtReply) Descriptor
deprecated
func (*ReadAtReply) Descriptor() ([]byte, []int)
Deprecated: Use ReadAtReply.ProtoReflect.Descriptor instead.
func (*ReadAtReply) GetN ¶
func (x *ReadAtReply) GetN() int32
func (*ReadAtReply) GetP ¶
func (x *ReadAtReply) GetP() []byte
func (*ReadAtReply) ProtoMessage ¶
func (*ReadAtReply) ProtoMessage()
func (*ReadAtReply) ProtoReflect ¶
func (x *ReadAtReply) ProtoReflect() protoreflect.Message
func (*ReadAtReply) Reset ¶
func (x *ReadAtReply) Reset()
func (*ReadAtReply) String ¶
func (x *ReadAtReply) String() string
type SeederWithMetaClient ¶
type SeederWithMetaClient interface { ReadAt(ctx context.Context, in *ReadAtArgs, opts ...grpc.CallOption) (*ReadAtReply, error) Track(ctx context.Context, in *TrackArgs, opts ...grpc.CallOption) (*TrackReply, error) Sync(ctx context.Context, in *SyncArgs, opts ...grpc.CallOption) (*SyncReply, error) Close(ctx context.Context, in *CloseArgs, opts ...grpc.CallOption) (*CloseReply, error) Meta(ctx context.Context, in *MetaArgs, opts ...grpc.CallOption) (*MetaReply, error) }
SeederWithMetaClient is the client API for SeederWithMeta service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewSeederWithMetaClient ¶
func NewSeederWithMetaClient(cc grpc.ClientConnInterface) SeederWithMetaClient
type SeederWithMetaServer ¶
type SeederWithMetaServer interface { ReadAt(context.Context, *ReadAtArgs) (*ReadAtReply, error) Track(context.Context, *TrackArgs) (*TrackReply, error) Sync(context.Context, *SyncArgs) (*SyncReply, error) Close(context.Context, *CloseArgs) (*CloseReply, error) Meta(context.Context, *MetaArgs) (*MetaReply, error) // contains filtered or unexported methods }
SeederWithMetaServer is the server API for SeederWithMeta service. All implementations must embed UnimplementedSeederWithMetaServer for forward compatibility
type SyncArgs ¶
type SyncArgs struct {
// contains filtered or unexported fields
}
func (*SyncArgs) Descriptor
deprecated
func (*SyncArgs) ProtoMessage ¶
func (*SyncArgs) ProtoMessage()
func (*SyncArgs) ProtoReflect ¶
func (x *SyncArgs) ProtoReflect() protoreflect.Message
type SyncReply ¶
type SyncReply struct { DirtyOffsets []int64 `protobuf:"varint,1,rep,packed,name=DirtyOffsets,proto3" json:"DirtyOffsets,omitempty"` // contains filtered or unexported fields }
func (*SyncReply) Descriptor
deprecated
func (*SyncReply) GetDirtyOffsets ¶
func (*SyncReply) ProtoMessage ¶
func (*SyncReply) ProtoMessage()
func (*SyncReply) ProtoReflect ¶
func (x *SyncReply) ProtoReflect() protoreflect.Message
type TrackArgs ¶
type TrackArgs struct {
// contains filtered or unexported fields
}
func (*TrackArgs) Descriptor
deprecated
func (*TrackArgs) ProtoMessage ¶
func (*TrackArgs) ProtoMessage()
func (*TrackArgs) ProtoReflect ¶
func (x *TrackArgs) ProtoReflect() protoreflect.Message
type TrackReply ¶
type TrackReply struct {
// contains filtered or unexported fields
}
func (*TrackReply) Descriptor
deprecated
func (*TrackReply) Descriptor() ([]byte, []int)
Deprecated: Use TrackReply.ProtoReflect.Descriptor instead.
func (*TrackReply) ProtoMessage ¶
func (*TrackReply) ProtoMessage()
func (*TrackReply) ProtoReflect ¶
func (x *TrackReply) ProtoReflect() protoreflect.Message
func (*TrackReply) Reset ¶
func (x *TrackReply) Reset()
func (*TrackReply) String ¶
func (x *TrackReply) String() string
type UnimplementedSeederWithMetaServer ¶
type UnimplementedSeederWithMetaServer struct { }
UnimplementedSeederWithMetaServer must be embedded to have forward compatible implementations.
func (UnimplementedSeederWithMetaServer) Close ¶
func (UnimplementedSeederWithMetaServer) Close(context.Context, *CloseArgs) (*CloseReply, error)
func (UnimplementedSeederWithMetaServer) ReadAt ¶
func (UnimplementedSeederWithMetaServer) ReadAt(context.Context, *ReadAtArgs) (*ReadAtReply, error)
func (UnimplementedSeederWithMetaServer) Track ¶
func (UnimplementedSeederWithMetaServer) Track(context.Context, *TrackArgs) (*TrackReply, error)
type UnsafeSeederWithMetaServer ¶
type UnsafeSeederWithMetaServer interface {
// contains filtered or unexported methods
}
UnsafeSeederWithMetaServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to SeederWithMetaServer will result in compilation errors.