docstore

package
v4.4.5 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 13, 2024 License: AGPL-3.0 Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	DocumentType_name = map[int32]string{
		0: "JSON",
		1: "BINARY",
	}
	DocumentType_value = map[string]int32{
		"JSON":   0,
		"BINARY": 1,
	}
)

Enum value maps for DocumentType.

View Source
var DocStore_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "docstore.DocStore",
	HandlerType: (*DocStoreServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "PutDocument",
			Handler:    _DocStore_PutDocument_Handler,
		},
		{
			MethodName: "GetDocument",
			Handler:    _DocStore_GetDocument_Handler,
		},
		{
			MethodName: "DeleteDocuments",
			Handler:    _DocStore_DeleteDocuments_Handler,
		},
		{
			MethodName: "CountDocuments",
			Handler:    _DocStore_CountDocuments_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "ListDocuments",
			Handler:       _DocStore_ListDocuments_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "cells-docstore.proto",
}

DocStore_ServiceDesc is the grpc.ServiceDesc for DocStore service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source
var File_cells_docstore_proto protoreflect.FileDescriptor

Functions

func DeregisterDocStoreEnhancedServer

func DeregisterDocStoreEnhancedServer(s grpc.ServiceRegistrar, name string)

func RegisterDocStoreEnhancedServer

func RegisterDocStoreEnhancedServer(s grpc.ServiceRegistrar, srv NamedDocStoreServer)

func RegisterDocStoreServer

func RegisterDocStoreServer(s grpc.ServiceRegistrar, srv DocStoreServer)

Types

type CountDocumentsResponse

type CountDocumentsResponse struct {
	Total int64 `protobuf:"varint,1,opt,name=Total,proto3" json:"Total,omitempty"`
	// contains filtered or unexported fields
}

func (*CountDocumentsResponse) Descriptor deprecated

func (*CountDocumentsResponse) Descriptor() ([]byte, []int)

Deprecated: Use CountDocumentsResponse.ProtoReflect.Descriptor instead.

func (*CountDocumentsResponse) GetTotal

func (x *CountDocumentsResponse) GetTotal() int64

func (*CountDocumentsResponse) ProtoMessage

func (*CountDocumentsResponse) ProtoMessage()

func (*CountDocumentsResponse) ProtoReflect

func (x *CountDocumentsResponse) ProtoReflect() protoreflect.Message

func (*CountDocumentsResponse) Reset

func (x *CountDocumentsResponse) Reset()

func (*CountDocumentsResponse) String

func (x *CountDocumentsResponse) String() string

func (*CountDocumentsResponse) Validate

func (this *CountDocumentsResponse) Validate() error

type DeleteDocumentsRequest

type DeleteDocumentsRequest struct {
	StoreID    string         `protobuf:"bytes,1,opt,name=StoreID,proto3" json:"StoreID,omitempty"`
	DocumentID string         `protobuf:"bytes,2,opt,name=DocumentID,proto3" json:"DocumentID,omitempty"`
	Query      *DocumentQuery `protobuf:"bytes,3,opt,name=Query,proto3" json:"Query,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteDocumentsRequest) Descriptor deprecated

func (*DeleteDocumentsRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeleteDocumentsRequest.ProtoReflect.Descriptor instead.

func (*DeleteDocumentsRequest) GetDocumentID

func (x *DeleteDocumentsRequest) GetDocumentID() string

func (*DeleteDocumentsRequest) GetQuery

func (x *DeleteDocumentsRequest) GetQuery() *DocumentQuery

func (*DeleteDocumentsRequest) GetStoreID

func (x *DeleteDocumentsRequest) GetStoreID() string

func (*DeleteDocumentsRequest) ProtoMessage

func (*DeleteDocumentsRequest) ProtoMessage()

func (*DeleteDocumentsRequest) ProtoReflect

func (x *DeleteDocumentsRequest) ProtoReflect() protoreflect.Message

func (*DeleteDocumentsRequest) Reset

func (x *DeleteDocumentsRequest) Reset()

func (*DeleteDocumentsRequest) String

func (x *DeleteDocumentsRequest) String() string

func (*DeleteDocumentsRequest) Validate

func (this *DeleteDocumentsRequest) Validate() error

type DeleteDocumentsResponse

type DeleteDocumentsResponse struct {
	Success       bool  `protobuf:"varint,1,opt,name=Success,proto3" json:"Success,omitempty"`
	DeletionCount int32 `protobuf:"varint,2,opt,name=DeletionCount,proto3" json:"DeletionCount,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteDocumentsResponse) Descriptor deprecated

func (*DeleteDocumentsResponse) Descriptor() ([]byte, []int)

Deprecated: Use DeleteDocumentsResponse.ProtoReflect.Descriptor instead.

func (*DeleteDocumentsResponse) GetDeletionCount

func (x *DeleteDocumentsResponse) GetDeletionCount() int32

func (*DeleteDocumentsResponse) GetSuccess

func (x *DeleteDocumentsResponse) GetSuccess() bool

func (*DeleteDocumentsResponse) ProtoMessage

func (*DeleteDocumentsResponse) ProtoMessage()

func (*DeleteDocumentsResponse) ProtoReflect

func (x *DeleteDocumentsResponse) ProtoReflect() protoreflect.Message

func (*DeleteDocumentsResponse) Reset

func (x *DeleteDocumentsResponse) Reset()

func (*DeleteDocumentsResponse) String

func (x *DeleteDocumentsResponse) String() string

func (*DeleteDocumentsResponse) Validate

func (this *DeleteDocumentsResponse) Validate() error

type DocStoreClient

type DocStoreClient interface {
	PutDocument(ctx context.Context, in *PutDocumentRequest, opts ...grpc.CallOption) (*PutDocumentResponse, error)
	GetDocument(ctx context.Context, in *GetDocumentRequest, opts ...grpc.CallOption) (*GetDocumentResponse, error)
	DeleteDocuments(ctx context.Context, in *DeleteDocumentsRequest, opts ...grpc.CallOption) (*DeleteDocumentsResponse, error)
	CountDocuments(ctx context.Context, in *ListDocumentsRequest, opts ...grpc.CallOption) (*CountDocumentsResponse, error)
	ListDocuments(ctx context.Context, in *ListDocumentsRequest, opts ...grpc.CallOption) (DocStore_ListDocumentsClient, error)
}

DocStoreClient is the client API for DocStore 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 NewDocStoreClient

func NewDocStoreClient(cc grpc.ClientConnInterface) DocStoreClient

type DocStoreEnhancedServer

type DocStoreEnhancedServer map[string]NamedDocStoreServer

func (DocStoreEnhancedServer) CountDocuments

func (DocStoreEnhancedServer) DeleteDocuments

func (DocStoreEnhancedServer) GetDocument

func (DocStoreEnhancedServer) ListDocuments

func (DocStoreEnhancedServer) PutDocument

type DocStoreServer

type DocStoreServer interface {
	PutDocument(context.Context, *PutDocumentRequest) (*PutDocumentResponse, error)
	GetDocument(context.Context, *GetDocumentRequest) (*GetDocumentResponse, error)
	DeleteDocuments(context.Context, *DeleteDocumentsRequest) (*DeleteDocumentsResponse, error)
	CountDocuments(context.Context, *ListDocumentsRequest) (*CountDocumentsResponse, error)
	ListDocuments(*ListDocumentsRequest, DocStore_ListDocumentsServer) error
	// contains filtered or unexported methods
}

DocStoreServer is the server API for DocStore service. All implementations must embed UnimplementedDocStoreServer for forward compatibility

type DocStoreStub

type DocStoreStub struct {
	DocStoreServer
}

func (*DocStoreStub) Invoke

func (s *DocStoreStub) Invoke(ctx context.Context, method string, args interface{}, reply interface{}, opts ...grpc.CallOption) error

func (*DocStoreStub) NewStream

func (s *DocStoreStub) NewStream(ctx context.Context, desc *grpc.StreamDesc, method string, opts ...grpc.CallOption) (grpc.ClientStream, error)

type DocStoreStub_ListDocumentsStreamer

type DocStoreStub_ListDocumentsStreamer struct {
	stubs.ClientServerStreamerCore
}

func (*DocStoreStub_ListDocumentsStreamer) Send

type DocStore_ListDocumentsClient

type DocStore_ListDocumentsClient interface {
	Recv() (*ListDocumentsResponse, error)
	grpc.ClientStream
}

type DocStore_ListDocumentsServer

type DocStore_ListDocumentsServer interface {
	Send(*ListDocumentsResponse) error
	grpc.ServerStream
}

type Document

type Document struct {
	ID            string       `protobuf:"bytes,2,opt,name=ID,proto3" json:"ID,omitempty"`
	Type          DocumentType `protobuf:"varint,3,opt,name=Type,proto3,enum=docstore.DocumentType" json:"Type,omitempty"`
	Owner         string       `protobuf:"bytes,4,opt,name=Owner,proto3" json:"Owner,omitempty"`
	Data          string       `protobuf:"bytes,5,opt,name=Data,proto3" json:"Data,omitempty"`
	IndexableMeta string       `protobuf:"bytes,6,opt,name=IndexableMeta,proto3" json:"IndexableMeta,omitempty"`
	// contains filtered or unexported fields
}

func (*Document) Descriptor deprecated

func (*Document) Descriptor() ([]byte, []int)

Deprecated: Use Document.ProtoReflect.Descriptor instead.

func (*Document) GetData

func (x *Document) GetData() string

func (*Document) GetID

func (x *Document) GetID() string

func (*Document) GetIndexableMeta

func (x *Document) GetIndexableMeta() string

func (*Document) GetOwner

func (x *Document) GetOwner() string

func (*Document) GetType

func (x *Document) GetType() DocumentType

func (*Document) ProtoMessage

func (*Document) ProtoMessage()

func (*Document) ProtoReflect

func (x *Document) ProtoReflect() protoreflect.Message

func (*Document) Reset

func (x *Document) Reset()

func (*Document) String

func (x *Document) String() string

func (*Document) Validate

func (this *Document) Validate() error

type DocumentQuery

type DocumentQuery struct {
	ID        string `protobuf:"bytes,2,opt,name=ID,proto3" json:"ID,omitempty"`
	Owner     string `protobuf:"bytes,3,opt,name=Owner,proto3" json:"Owner,omitempty"`
	MetaQuery string `protobuf:"bytes,4,opt,name=MetaQuery,proto3" json:"MetaQuery,omitempty"`
	// contains filtered or unexported fields
}

func (*DocumentQuery) Descriptor deprecated

func (*DocumentQuery) Descriptor() ([]byte, []int)

Deprecated: Use DocumentQuery.ProtoReflect.Descriptor instead.

func (*DocumentQuery) GetID

func (x *DocumentQuery) GetID() string

func (*DocumentQuery) GetMetaQuery

func (x *DocumentQuery) GetMetaQuery() string

func (*DocumentQuery) GetOwner

func (x *DocumentQuery) GetOwner() string

func (*DocumentQuery) ProtoMessage

func (*DocumentQuery) ProtoMessage()

func (*DocumentQuery) ProtoReflect

func (x *DocumentQuery) ProtoReflect() protoreflect.Message

func (*DocumentQuery) Reset

func (x *DocumentQuery) Reset()

func (*DocumentQuery) String

func (x *DocumentQuery) String() string

func (*DocumentQuery) Validate

func (this *DocumentQuery) Validate() error

type DocumentType

type DocumentType int32
const (
	DocumentType_JSON   DocumentType = 0
	DocumentType_BINARY DocumentType = 1
)

func (DocumentType) Descriptor

func (DocumentType) Enum

func (x DocumentType) Enum() *DocumentType

func (DocumentType) EnumDescriptor deprecated

func (DocumentType) EnumDescriptor() ([]byte, []int)

Deprecated: Use DocumentType.Descriptor instead.

func (DocumentType) Number

func (DocumentType) String

func (x DocumentType) String() string

func (DocumentType) Type

type GetDocumentRequest

type GetDocumentRequest struct {
	StoreID    string `protobuf:"bytes,1,opt,name=StoreID,proto3" json:"StoreID,omitempty"`
	DocumentID string `protobuf:"bytes,2,opt,name=DocumentID,proto3" json:"DocumentID,omitempty"`
	// contains filtered or unexported fields
}

func (*GetDocumentRequest) Descriptor deprecated

func (*GetDocumentRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetDocumentRequest.ProtoReflect.Descriptor instead.

func (*GetDocumentRequest) GetDocumentID

func (x *GetDocumentRequest) GetDocumentID() string

func (*GetDocumentRequest) GetStoreID

func (x *GetDocumentRequest) GetStoreID() string

func (*GetDocumentRequest) ProtoMessage

func (*GetDocumentRequest) ProtoMessage()

func (*GetDocumentRequest) ProtoReflect

func (x *GetDocumentRequest) ProtoReflect() protoreflect.Message

func (*GetDocumentRequest) Reset

func (x *GetDocumentRequest) Reset()

func (*GetDocumentRequest) String

func (x *GetDocumentRequest) String() string

func (*GetDocumentRequest) Validate

func (this *GetDocumentRequest) Validate() error

type GetDocumentResponse

type GetDocumentResponse struct {
	Document  *Document `protobuf:"bytes,1,opt,name=Document,proto3" json:"Document,omitempty"`
	BinaryUrl string    `protobuf:"bytes,2,opt,name=BinaryUrl,proto3" json:"BinaryUrl,omitempty"`
	// contains filtered or unexported fields
}

func (*GetDocumentResponse) Descriptor deprecated

func (*GetDocumentResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetDocumentResponse.ProtoReflect.Descriptor instead.

func (*GetDocumentResponse) GetBinaryUrl

func (x *GetDocumentResponse) GetBinaryUrl() string

func (*GetDocumentResponse) GetDocument

func (x *GetDocumentResponse) GetDocument() *Document

func (*GetDocumentResponse) ProtoMessage

func (*GetDocumentResponse) ProtoMessage()

func (*GetDocumentResponse) ProtoReflect

func (x *GetDocumentResponse) ProtoReflect() protoreflect.Message

func (*GetDocumentResponse) Reset

func (x *GetDocumentResponse) Reset()

func (*GetDocumentResponse) String

func (x *GetDocumentResponse) String() string

func (*GetDocumentResponse) Validate

func (this *GetDocumentResponse) Validate() error

type ListDocumentsRequest

type ListDocumentsRequest struct {
	StoreID string         `protobuf:"bytes,1,opt,name=StoreID,proto3" json:"StoreID,omitempty"`
	Query   *DocumentQuery `protobuf:"bytes,2,opt,name=Query,proto3" json:"Query,omitempty"`
	// contains filtered or unexported fields
}

func (*ListDocumentsRequest) Descriptor deprecated

func (*ListDocumentsRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListDocumentsRequest.ProtoReflect.Descriptor instead.

func (*ListDocumentsRequest) GetQuery

func (x *ListDocumentsRequest) GetQuery() *DocumentQuery

func (*ListDocumentsRequest) GetStoreID

func (x *ListDocumentsRequest) GetStoreID() string

func (*ListDocumentsRequest) ProtoMessage

func (*ListDocumentsRequest) ProtoMessage()

func (*ListDocumentsRequest) ProtoReflect

func (x *ListDocumentsRequest) ProtoReflect() protoreflect.Message

func (*ListDocumentsRequest) Reset

func (x *ListDocumentsRequest) Reset()

func (*ListDocumentsRequest) String

func (x *ListDocumentsRequest) String() string

func (*ListDocumentsRequest) Validate

func (this *ListDocumentsRequest) Validate() error

type ListDocumentsResponse

type ListDocumentsResponse struct {
	Document  *Document `protobuf:"bytes,1,opt,name=Document,proto3" json:"Document,omitempty"`
	BinaryUrl string    `protobuf:"bytes,2,opt,name=BinaryUrl,proto3" json:"BinaryUrl,omitempty"`
	Score     int32     `protobuf:"varint,3,opt,name=Score,proto3" json:"Score,omitempty"`
	// contains filtered or unexported fields
}

func (*ListDocumentsResponse) Descriptor deprecated

func (*ListDocumentsResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListDocumentsResponse.ProtoReflect.Descriptor instead.

func (*ListDocumentsResponse) GetBinaryUrl

func (x *ListDocumentsResponse) GetBinaryUrl() string

func (*ListDocumentsResponse) GetDocument

func (x *ListDocumentsResponse) GetDocument() *Document

func (*ListDocumentsResponse) GetScore

func (x *ListDocumentsResponse) GetScore() int32

func (*ListDocumentsResponse) ProtoMessage

func (*ListDocumentsResponse) ProtoMessage()

func (*ListDocumentsResponse) ProtoReflect

func (x *ListDocumentsResponse) ProtoReflect() protoreflect.Message

func (*ListDocumentsResponse) Reset

func (x *ListDocumentsResponse) Reset()

func (*ListDocumentsResponse) String

func (x *ListDocumentsResponse) String() string

func (*ListDocumentsResponse) Validate

func (this *ListDocumentsResponse) Validate() error

type NamedDocStoreServer

type NamedDocStoreServer interface {
	DocStoreServer
	Name() string
}

type PutDocumentRequest

type PutDocumentRequest struct {
	StoreID    string    `protobuf:"bytes,1,opt,name=StoreID,proto3" json:"StoreID,omitempty"`
	DocumentID string    `protobuf:"bytes,2,opt,name=DocumentID,proto3" json:"DocumentID,omitempty"`
	Document   *Document `protobuf:"bytes,3,opt,name=Document,proto3" json:"Document,omitempty"`
	// contains filtered or unexported fields
}

func (*PutDocumentRequest) Descriptor deprecated

func (*PutDocumentRequest) Descriptor() ([]byte, []int)

Deprecated: Use PutDocumentRequest.ProtoReflect.Descriptor instead.

func (*PutDocumentRequest) GetDocument

func (x *PutDocumentRequest) GetDocument() *Document

func (*PutDocumentRequest) GetDocumentID

func (x *PutDocumentRequest) GetDocumentID() string

func (*PutDocumentRequest) GetStoreID

func (x *PutDocumentRequest) GetStoreID() string

func (*PutDocumentRequest) ProtoMessage

func (*PutDocumentRequest) ProtoMessage()

func (*PutDocumentRequest) ProtoReflect

func (x *PutDocumentRequest) ProtoReflect() protoreflect.Message

func (*PutDocumentRequest) Reset

func (x *PutDocumentRequest) Reset()

func (*PutDocumentRequest) String

func (x *PutDocumentRequest) String() string

func (*PutDocumentRequest) Validate

func (this *PutDocumentRequest) Validate() error

type PutDocumentResponse

type PutDocumentResponse struct {
	Document *Document `protobuf:"bytes,1,opt,name=Document,proto3" json:"Document,omitempty"`
	// contains filtered or unexported fields
}

func (*PutDocumentResponse) Descriptor deprecated

func (*PutDocumentResponse) Descriptor() ([]byte, []int)

Deprecated: Use PutDocumentResponse.ProtoReflect.Descriptor instead.

func (*PutDocumentResponse) GetDocument

func (x *PutDocumentResponse) GetDocument() *Document

func (*PutDocumentResponse) ProtoMessage

func (*PutDocumentResponse) ProtoMessage()

func (*PutDocumentResponse) ProtoReflect

func (x *PutDocumentResponse) ProtoReflect() protoreflect.Message

func (*PutDocumentResponse) Reset

func (x *PutDocumentResponse) Reset()

func (*PutDocumentResponse) String

func (x *PutDocumentResponse) String() string

func (*PutDocumentResponse) Validate

func (this *PutDocumentResponse) Validate() error

type ShareDocument

type ShareDocument struct {
	ShareType             string                      `json:"SHARE_TYPE"`
	ExpireTime            int64                       `json:"EXPIRE_TIME"`
	ShortFormUrl          string                      `json:"SHORT_FORM_URL"`
	RepositoryId          string                      `json:"REPOSITORY"`
	ParentRepositoryId    string                      `json:"PARENT_REPOSITORY_ID"`
	DownloadDisabled      bool                        `json:"DOWNLOAD_DISABLED"`
	ApplicationBase       string                      `json:"PYDIO_APPLICATION_BASE"`
	TemplateName          string                      `json:"PYDIO_TEMPLATE_NAME"`
	DownloadLimit         int64                       `json:"DOWNLOAD_LIMIT"`
	DownloadCount         int64                       `json:"DOWNLOAD_COUNT"`
	PreLogUser            string                      `json:"PRELOG_USER"`
	PresetLogin           string                      `json:"PRESET_LOGIN"`
	Target                string                      `json:"TARGET"`
	TargetUsers           map[string]*TargetUserEntry `json:"TARGET_USERS"`
	RestrictToTargetUsers bool                        `json:"RESTRICT_TO_TARGET_USERS"`
	OwnerId               string                      `json:"OWNER_ID"`
	PreUserUuid           string                      `json:"USER_UUID"`
}

HashDocument is a Json Marshallable representation of a document, compatible with legacy.

type TargetUserEntry

type TargetUserEntry struct {
	Display       string `json:"display"`
	DownloadCount int32  `json:"download_count"`
}

type UnimplementedDocStoreServer

type UnimplementedDocStoreServer struct {
}

UnimplementedDocStoreServer must be embedded to have forward compatible implementations.

func (UnimplementedDocStoreServer) CountDocuments

func (UnimplementedDocStoreServer) DeleteDocuments

func (UnimplementedDocStoreServer) GetDocument

func (UnimplementedDocStoreServer) ListDocuments

func (UnimplementedDocStoreServer) PutDocument

type UnsafeDocStoreServer

type UnsafeDocStoreServer interface {
	// contains filtered or unexported methods
}

UnsafeDocStoreServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DocStoreServer will result in compilation errors.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL