Versions in this module Expand all Collapse all v1 v1.0.0 Aug 21, 2023 Changes in this version + var ContentWriter_ServiceDesc = grpc.ServiceDesc + var File_contentwriter_v1_contentwriter_proto protoreflect.FileDescriptor + var File_contentwriter_v1_resources_proto protoreflect.FileDescriptor + var RecordType_name = map[int32]string + var RecordType_value = map[string]int32 + func RegisterContentWriterServer(s grpc.ServiceRegistrar, srv ContentWriterServer) + type ContentWriterClient interface + Write func(ctx context.Context, opts ...grpc.CallOption) (ContentWriter_WriteClient, error) + func NewContentWriterClient(cc grpc.ClientConnInterface) ContentWriterClient + type ContentWriterServer interface + Write func(ContentWriter_WriteServer) error + type ContentWriter_WriteClient interface + CloseAndRecv func() (*WriteReply, error) + Send func(*WriteRequest) error + type ContentWriter_WriteServer interface + Recv func() (*WriteRequest, error) + SendAndClose func(*WriteReply) error + type CrawledContent struct + Date *timestamppb.Timestamp + Digest string + TargetUri string + WarcId string + func (*CrawledContent) Descriptor() ([]byte, []int) + func (*CrawledContent) ProtoMessage() + func (x *CrawledContent) GetDate() *timestamppb.Timestamp + func (x *CrawledContent) GetDigest() string + func (x *CrawledContent) GetTargetUri() string + func (x *CrawledContent) GetWarcId() string + func (x *CrawledContent) ProtoReflect() protoreflect.Message + func (x *CrawledContent) Reset() + func (x *CrawledContent) String() string + type Data struct + Data []byte + RecordNum int32 + func (*Data) Descriptor() ([]byte, []int) + func (*Data) ProtoMessage() + func (x *Data) GetData() []byte + func (x *Data) GetRecordNum() int32 + func (x *Data) ProtoReflect() protoreflect.Message + func (x *Data) Reset() + func (x *Data) String() string + type RecordType int32 + const RecordType_CONTINUATION + const RecordType_CONVERSION + const RecordType_METADATA + const RecordType_REQUEST + const RecordType_RESOURCE + const RecordType_RESPONSE + const RecordType_REVISIT + const RecordType_WARCINFO + func (RecordType) Descriptor() protoreflect.EnumDescriptor + func (RecordType) EnumDescriptor() ([]byte, []int) + func (RecordType) Type() protoreflect.EnumType + func (x RecordType) Enum() *RecordType + func (x RecordType) Number() protoreflect.EnumNumber + func (x RecordType) String() string + type StorageRef struct + RecordType RecordType + StorageRef string + WarcId string + func (*StorageRef) Descriptor() ([]byte, []int) + func (*StorageRef) ProtoMessage() + func (x *StorageRef) GetRecordType() RecordType + func (x *StorageRef) GetStorageRef() string + func (x *StorageRef) GetWarcId() string + func (x *StorageRef) ProtoReflect() protoreflect.Message + func (x *StorageRef) Reset() + func (x *StorageRef) String() string + type UnimplementedContentWriterServer struct + func (UnimplementedContentWriterServer) Write(ContentWriter_WriteServer) error + type UnsafeContentWriterServer interface + type WriteReply struct + Meta *WriteResponseMeta + func (*WriteReply) Descriptor() ([]byte, []int) + func (*WriteReply) ProtoMessage() + func (x *WriteReply) GetMeta() *WriteResponseMeta + func (x *WriteReply) ProtoReflect() protoreflect.Message + func (x *WriteReply) Reset() + func (x *WriteReply) String() string + type WriteRequest struct + Value isWriteRequest_Value + func (*WriteRequest) Descriptor() ([]byte, []int) + func (*WriteRequest) ProtoMessage() + func (m *WriteRequest) GetValue() isWriteRequest_Value + func (x *WriteRequest) GetCancel() string + func (x *WriteRequest) GetMeta() *WriteRequestMeta + func (x *WriteRequest) GetPayload() *Data + func (x *WriteRequest) GetProtocolHeader() *Data + func (x *WriteRequest) ProtoReflect() protoreflect.Message + func (x *WriteRequest) Reset() + func (x *WriteRequest) String() string + type WriteRequestMeta struct + CollectionRef *v1.ConfigRef + ExecutionId string + FetchTimeStamp *timestamppb.Timestamp + IpAddress string + RecordMeta map[int32]*WriteRequestMeta_RecordMeta + TargetUri string + func (*WriteRequestMeta) Descriptor() ([]byte, []int) + func (*WriteRequestMeta) ProtoMessage() + func (x *WriteRequestMeta) GetCollectionRef() *v1.ConfigRef + func (x *WriteRequestMeta) GetExecutionId() string + func (x *WriteRequestMeta) GetFetchTimeStamp() *timestamppb.Timestamp + func (x *WriteRequestMeta) GetIpAddress() string + func (x *WriteRequestMeta) GetRecordMeta() map[int32]*WriteRequestMeta_RecordMeta + func (x *WriteRequestMeta) GetTargetUri() string + func (x *WriteRequestMeta) ProtoReflect() protoreflect.Message + func (x *WriteRequestMeta) Reset() + func (x *WriteRequestMeta) String() string + type WriteRequestMeta_RecordMeta struct + BlockDigest string + PayloadDigest string + RecordContentType string + RecordNum int32 + Size int64 + SubCollection v1.Collection_SubCollectionType + Type RecordType + WarcConcurrentTo []string + func (*WriteRequestMeta_RecordMeta) Descriptor() ([]byte, []int) + func (*WriteRequestMeta_RecordMeta) ProtoMessage() + func (x *WriteRequestMeta_RecordMeta) GetBlockDigest() string + func (x *WriteRequestMeta_RecordMeta) GetPayloadDigest() string + func (x *WriteRequestMeta_RecordMeta) GetRecordContentType() string + func (x *WriteRequestMeta_RecordMeta) GetRecordNum() int32 + func (x *WriteRequestMeta_RecordMeta) GetSize() int64 + func (x *WriteRequestMeta_RecordMeta) GetSubCollection() v1.Collection_SubCollectionType + func (x *WriteRequestMeta_RecordMeta) GetType() RecordType + func (x *WriteRequestMeta_RecordMeta) GetWarcConcurrentTo() []string + func (x *WriteRequestMeta_RecordMeta) ProtoReflect() protoreflect.Message + func (x *WriteRequestMeta_RecordMeta) Reset() + func (x *WriteRequestMeta_RecordMeta) String() string + type WriteRequest_Cancel struct + Cancel string + type WriteRequest_Meta struct + Meta *WriteRequestMeta + type WriteRequest_Payload struct + Payload *Data + type WriteRequest_ProtocolHeader struct + ProtocolHeader *Data + type WriteResponseMeta struct + RecordMeta map[int32]*WriteResponseMeta_RecordMeta + func (*WriteResponseMeta) Descriptor() ([]byte, []int) + func (*WriteResponseMeta) ProtoMessage() + func (x *WriteResponseMeta) GetRecordMeta() map[int32]*WriteResponseMeta_RecordMeta + func (x *WriteResponseMeta) ProtoReflect() protoreflect.Message + func (x *WriteResponseMeta) Reset() + func (x *WriteResponseMeta) String() string + type WriteResponseMeta_RecordMeta struct + BlockDigest string + CollectionFinalName string + PayloadDigest string + RecordNum int32 + RevisitReferenceId string + StorageRef string + Type RecordType + WarcId string + func (*WriteResponseMeta_RecordMeta) Descriptor() ([]byte, []int) + func (*WriteResponseMeta_RecordMeta) ProtoMessage() + func (x *WriteResponseMeta_RecordMeta) GetBlockDigest() string + func (x *WriteResponseMeta_RecordMeta) GetCollectionFinalName() string + func (x *WriteResponseMeta_RecordMeta) GetPayloadDigest() string + func (x *WriteResponseMeta_RecordMeta) GetRecordNum() int32 + func (x *WriteResponseMeta_RecordMeta) GetRevisitReferenceId() string + func (x *WriteResponseMeta_RecordMeta) GetStorageRef() string + func (x *WriteResponseMeta_RecordMeta) GetType() RecordType + func (x *WriteResponseMeta_RecordMeta) GetWarcId() string + func (x *WriteResponseMeta_RecordMeta) ProtoReflect() protoreflect.Message + func (x *WriteResponseMeta_RecordMeta) Reset() + func (x *WriteResponseMeta_RecordMeta) String() string v1.0.0-rc.1 Jul 14, 2023
Go to main page