Documentation
¶
Index ¶
- Constants
- Variables
- func DeregisterFileKeyManagerEnhancedServer(s grpc.ServiceRegistrar, name string)
- func DeregisterNodeChangesStreamerEnhancedServer(s grpc.ServiceRegistrar, name string)
- func DeregisterNodeContentReaderEnhancedServer(s grpc.ServiceRegistrar, name string)
- func DeregisterNodeContentWriterEnhancedServer(s grpc.ServiceRegistrar, name string)
- func DeregisterNodeEventsProviderEnhancedServer(s grpc.ServiceRegistrar, name string)
- func DeregisterNodeProviderEnhancedServer(s grpc.ServiceRegistrar, name string)
- func DeregisterNodeProviderStreamerEnhancedServer(s grpc.ServiceRegistrar, name string)
- func DeregisterNodeReceiverEnhancedServer(s grpc.ServiceRegistrar, name string)
- func DeregisterNodeReceiverStreamEnhancedServer(s grpc.ServiceRegistrar, name string)
- func DeregisterNodeVersionerEnhancedServer(s grpc.ServiceRegistrar, name string)
- func DeregisterSearcherEnhancedServer(s grpc.ServiceRegistrar, name string)
- func DeregisterSessionIndexerEnhancedServer(s grpc.ServiceRegistrar, name string)
- func DeregisterSyncChangesEnhancedServer(s grpc.ServiceRegistrar, name string)
- func IgnoreNodeForOutput(ctx context.Context, node *Node) bool
- func NewStreamerMock(ctx context.Context, nodes map[string]Node) grpc.ClientStream
- func PredefineError(f ErrorThrower)
- func RegisterFileKeyManagerEnhancedServer(s grpc.ServiceRegistrar, srv NamedFileKeyManagerServer)
- func RegisterFileKeyManagerServer(s grpc.ServiceRegistrar, srv FileKeyManagerServer)
- func RegisterNodeChangesStreamerEnhancedServer(s grpc.ServiceRegistrar, srv NamedNodeChangesStreamerServer)
- func RegisterNodeChangesStreamerServer(s grpc.ServiceRegistrar, srv NodeChangesStreamerServer)
- func RegisterNodeContentReaderEnhancedServer(s grpc.ServiceRegistrar, srv NamedNodeContentReaderServer)
- func RegisterNodeContentReaderServer(s grpc.ServiceRegistrar, srv NodeContentReaderServer)
- func RegisterNodeContentWriterEnhancedServer(s grpc.ServiceRegistrar, srv NamedNodeContentWriterServer)
- func RegisterNodeContentWriterServer(s grpc.ServiceRegistrar, srv NodeContentWriterServer)
- func RegisterNodeEventsProviderEnhancedServer(s grpc.ServiceRegistrar, srv NamedNodeEventsProviderServer)
- func RegisterNodeEventsProviderServer(s grpc.ServiceRegistrar, srv NodeEventsProviderServer)
- func RegisterNodeProviderEnhancedServer(s grpc.ServiceRegistrar, srv NamedNodeProviderServer)
- func RegisterNodeProviderServer(s grpc.ServiceRegistrar, srv NodeProviderServer)
- func RegisterNodeProviderStreamerEnhancedServer(s grpc.ServiceRegistrar, srv NamedNodeProviderStreamerServer)
- func RegisterNodeProviderStreamerServer(s grpc.ServiceRegistrar, srv NodeProviderStreamerServer)
- func RegisterNodeReceiverEnhancedServer(s grpc.ServiceRegistrar, srv NamedNodeReceiverServer)
- func RegisterNodeReceiverServer(s grpc.ServiceRegistrar, srv NodeReceiverServer)
- func RegisterNodeReceiverStreamEnhancedServer(s grpc.ServiceRegistrar, srv NamedNodeReceiverStreamServer)
- func RegisterNodeReceiverStreamServer(s grpc.ServiceRegistrar, srv NodeReceiverStreamServer)
- func RegisterNodeVersionerEnhancedServer(s grpc.ServiceRegistrar, srv NamedNodeVersionerServer)
- func RegisterNodeVersionerServer(s grpc.ServiceRegistrar, srv NodeVersionerServer)
- func RegisterSearcherEnhancedServer(s grpc.ServiceRegistrar, srv NamedSearcherServer)
- func RegisterSearcherServer(s grpc.ServiceRegistrar, srv SearcherServer)
- func RegisterSessionIndexerEnhancedServer(s grpc.ServiceRegistrar, srv NamedSessionIndexerServer)
- func RegisterSessionIndexerServer(s grpc.ServiceRegistrar, srv SessionIndexerServer)
- func RegisterSyncChangesEnhancedServer(s grpc.ServiceRegistrar, srv NamedSyncChangesServer)
- func RegisterSyncChangesServer(s grpc.ServiceRegistrar, srv SyncChangesServer)
- func ShouldError(obj interface{}, fn string, params ...interface{}) error
- type ChangeLog
- func (*ChangeLog) Descriptor() ([]byte, []int)deprecated
- func (x *ChangeLog) GetData() []byte
- func (x *ChangeLog) GetDescription() string
- func (x *ChangeLog) GetEvent() *NodeChangeEvent
- func (x *ChangeLog) GetLocation() *Node
- func (x *ChangeLog) GetMTime() int64
- func (x *ChangeLog) GetOwnerUuid() string
- func (x *ChangeLog) GetSize() int64
- func (x *ChangeLog) GetUuid() string
- func (log *ChangeLog) MarshalLogObject(encoder zapcore.ObjectEncoder) error
- func (*ChangeLog) ProtoMessage()
- func (x *ChangeLog) ProtoReflect() protoreflect.Message
- func (x *ChangeLog) Reset()
- func (x *ChangeLog) String() string
- func (this *ChangeLog) Validate() error
- func (log *ChangeLog) Zap() zapcore.Field
- type CloseSessionRequest
- func (*CloseSessionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CloseSessionRequest) GetSession() *IndexationSession
- func (*CloseSessionRequest) ProtoMessage()
- func (x *CloseSessionRequest) ProtoReflect() protoreflect.Message
- func (x *CloseSessionRequest) Reset()
- func (x *CloseSessionRequest) String() string
- func (this *CloseSessionRequest) Validate() error
- type CloseSessionResponse
- func (*CloseSessionResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CloseSessionResponse) GetSession() *IndexationSession
- func (*CloseSessionResponse) ProtoMessage()
- func (x *CloseSessionResponse) ProtoReflect() protoreflect.Message
- func (x *CloseSessionResponse) Reset()
- func (x *CloseSessionResponse) String() string
- func (this *CloseSessionResponse) Validate() error
- type CreateNodeRequest
- func (*CreateNodeRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateNodeRequest) GetIndexationSession() string
- func (x *CreateNodeRequest) GetNode() *Node
- func (x *CreateNodeRequest) GetSilent() bool
- func (x *CreateNodeRequest) GetUpdateIfExists() bool
- func (*CreateNodeRequest) ProtoMessage()
- func (x *CreateNodeRequest) ProtoReflect() protoreflect.Message
- func (x *CreateNodeRequest) Reset()
- func (x *CreateNodeRequest) String() string
- func (this *CreateNodeRequest) Validate() error
- type CreateNodeResponse
- func (*CreateNodeResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CreateNodeResponse) GetNode() *Node
- func (x *CreateNodeResponse) GetSuccess() bool
- func (*CreateNodeResponse) ProtoMessage()
- func (x *CreateNodeResponse) ProtoReflect() protoreflect.Message
- func (x *CreateNodeResponse) Reset()
- func (x *CreateNodeResponse) String() string
- func (this *CreateNodeResponse) Validate() error
- type CreateVersionRequest
- func (*CreateVersionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateVersionRequest) GetNode() *Node
- func (x *CreateVersionRequest) GetTriggerEvent() *NodeChangeEvent
- func (*CreateVersionRequest) ProtoMessage()
- func (x *CreateVersionRequest) ProtoReflect() protoreflect.Message
- func (x *CreateVersionRequest) Reset()
- func (x *CreateVersionRequest) String() string
- func (this *CreateVersionRequest) Validate() error
- type CreateVersionResponse
- func (*CreateVersionResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CreateVersionResponse) GetVersion() *ChangeLog
- func (*CreateVersionResponse) ProtoMessage()
- func (x *CreateVersionResponse) ProtoReflect() protoreflect.Message
- func (x *CreateVersionResponse) Reset()
- func (x *CreateVersionResponse) String() string
- func (this *CreateVersionResponse) Validate() error
- type DeleteNodeRequest
- func (*DeleteNodeRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteNodeRequest) GetIndexationSession() string
- func (x *DeleteNodeRequest) GetNode() *Node
- func (x *DeleteNodeRequest) GetSilent() bool
- func (*DeleteNodeRequest) ProtoMessage()
- func (x *DeleteNodeRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteNodeRequest) Reset()
- func (x *DeleteNodeRequest) String() string
- func (this *DeleteNodeRequest) Validate() error
- type DeleteNodeResponse
- func (*DeleteNodeResponse) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteNodeResponse) GetSuccess() bool
- func (*DeleteNodeResponse) ProtoMessage()
- func (x *DeleteNodeResponse) ProtoReflect() protoreflect.Message
- func (x *DeleteNodeResponse) Reset()
- func (x *DeleteNodeResponse) String() string
- func (this *DeleteNodeResponse) Validate() error
- type ErrorThrower
- type FileKeyManagerClient
- type FileKeyManagerEnhancedServer
- type FileKeyManagerServer
- type FileKeyManagerStub
- type Flags
- type FlushSessionRequest
- func (*FlushSessionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *FlushSessionRequest) GetSession() *IndexationSession
- func (*FlushSessionRequest) ProtoMessage()
- func (x *FlushSessionRequest) ProtoReflect() protoreflect.Message
- func (x *FlushSessionRequest) Reset()
- func (x *FlushSessionRequest) String() string
- func (this *FlushSessionRequest) Validate() error
- type FlushSessionResponse
- func (*FlushSessionResponse) Descriptor() ([]byte, []int)deprecated
- func (x *FlushSessionResponse) GetSession() *IndexationSession
- func (*FlushSessionResponse) ProtoMessage()
- func (x *FlushSessionResponse) ProtoReflect() protoreflect.Message
- func (x *FlushSessionResponse) Reset()
- func (x *FlushSessionResponse) String() string
- func (this *FlushSessionResponse) Validate() error
- type GeoJson
- type GeoPoint
- func (*GeoPoint) Descriptor() ([]byte, []int)deprecated
- func (x *GeoPoint) GetLat() float64
- func (x *GeoPoint) GetLon() float64
- func (*GeoPoint) ProtoMessage()
- func (x *GeoPoint) ProtoReflect() protoreflect.Message
- func (x *GeoPoint) Reset()
- func (x *GeoPoint) String() string
- func (this *GeoPoint) Validate() error
- type GeoQuery
- func (*GeoQuery) Descriptor() ([]byte, []int)deprecated
- func (x *GeoQuery) GetBottomRight() *GeoPoint
- func (x *GeoQuery) GetCenter() *GeoPoint
- func (x *GeoQuery) GetDistance() string
- func (x *GeoQuery) GetTopLeft() *GeoPoint
- func (*GeoQuery) ProtoMessage()
- func (x *GeoQuery) ProtoReflect() protoreflect.Message
- func (x *GeoQuery) Reset()
- func (x *GeoQuery) String() string
- func (this *GeoQuery) Validate() error
- type GetEncryptionKeyRequest
- func (*GetEncryptionKeyRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetEncryptionKeyRequest) GetCreate() bool
- func (x *GetEncryptionKeyRequest) GetNode() *Node
- func (x *GetEncryptionKeyRequest) GetPassword() string
- func (x *GetEncryptionKeyRequest) GetUser() string
- func (*GetEncryptionKeyRequest) ProtoMessage()
- func (x *GetEncryptionKeyRequest) ProtoReflect() protoreflect.Message
- func (x *GetEncryptionKeyRequest) Reset()
- func (x *GetEncryptionKeyRequest) String() string
- func (this *GetEncryptionKeyRequest) Validate() error
- type GetEncryptionKeyResponse
- func (*GetEncryptionKeyResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetEncryptionKeyResponse) GetKey() []byte
- func (*GetEncryptionKeyResponse) ProtoMessage()
- func (x *GetEncryptionKeyResponse) ProtoReflect() protoreflect.Message
- func (x *GetEncryptionKeyResponse) Reset()
- func (x *GetEncryptionKeyResponse) String() string
- func (this *GetEncryptionKeyResponse) Validate() error
- type HeadVersionRequest
- func (*HeadVersionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *HeadVersionRequest) GetNode() *Node
- func (x *HeadVersionRequest) GetVersionId() string
- func (*HeadVersionRequest) ProtoMessage()
- func (x *HeadVersionRequest) ProtoReflect() protoreflect.Message
- func (x *HeadVersionRequest) Reset()
- func (x *HeadVersionRequest) String() string
- func (this *HeadVersionRequest) Validate() error
- type HeadVersionResponse
- func (*HeadVersionResponse) Descriptor() ([]byte, []int)deprecated
- func (x *HeadVersionResponse) GetVersion() *ChangeLog
- func (*HeadVersionResponse) ProtoMessage()
- func (x *HeadVersionResponse) ProtoReflect() protoreflect.Message
- func (x *HeadVersionResponse) Reset()
- func (x *HeadVersionResponse) String() string
- func (this *HeadVersionResponse) Validate() error
- type IndexEvent
- func (*IndexEvent) Descriptor() ([]byte, []int)deprecated
- func (x *IndexEvent) GetDataSourceName() string
- func (x *IndexEvent) GetErrorDetected() bool
- func (x *IndexEvent) GetErrorPath() string
- func (x *IndexEvent) GetSessionForceClose() string
- func (*IndexEvent) ProtoMessage()
- func (x *IndexEvent) ProtoReflect() protoreflect.Message
- func (x *IndexEvent) Reset()
- func (x *IndexEvent) String() string
- func (this *IndexEvent) Validate() error
- type IndexableNode
- type IndexationOperation
- func (*IndexationOperation) Descriptor() ([]byte, []int)deprecated
- func (x *IndexationOperation) GetCursor() int64
- func (x *IndexationOperation) GetDescription() string
- func (x *IndexationOperation) GetSessionUuid() string
- func (*IndexationOperation) ProtoMessage()
- func (x *IndexationOperation) ProtoReflect() protoreflect.Message
- func (x *IndexationOperation) Reset()
- func (x *IndexationOperation) String() string
- func (this *IndexationOperation) Validate() error
- type IndexationSession
- func (*IndexationSession) Descriptor() ([]byte, []int)deprecated
- func (x *IndexationSession) GetCurrentOperationCount() int64
- func (x *IndexationSession) GetDescription() string
- func (x *IndexationSession) GetExpectedOperationsCount() int64
- func (x *IndexationSession) GetRootNode() *Node
- func (x *IndexationSession) GetSilent() bool
- func (x *IndexationSession) GetUuid() string
- func (*IndexationSession) ProtoMessage()
- func (x *IndexationSession) ProtoReflect() protoreflect.Message
- func (x *IndexationSession) Reset()
- func (x *IndexationSession) String() string
- func (this *IndexationSession) Validate() error
- type ListNodesRequest
- func (*ListNodesRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListNodesRequest) GetAncestors() bool
- func (x *ListNodesRequest) GetFilterType() NodeType
- func (x *ListNodesRequest) GetLimit() int64
- func (x *ListNodesRequest) GetNode() *Node
- func (x *ListNodesRequest) GetOffset() int64
- func (x *ListNodesRequest) GetRecursive() bool
- func (x *ListNodesRequest) GetStatFlags() []uint32
- func (x *ListNodesRequest) GetWithCommits() bool
- func (x *ListNodesRequest) GetWithVersions() bool
- func (*ListNodesRequest) ProtoMessage()
- func (x *ListNodesRequest) ProtoReflect() protoreflect.Message
- func (x *ListNodesRequest) Reset()
- func (x *ListNodesRequest) String() string
- func (this *ListNodesRequest) Validate() error
- type ListNodesResponse
- func (*ListNodesResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListNodesResponse) GetNode() *Node
- func (*ListNodesResponse) ProtoMessage()
- func (x *ListNodesResponse) ProtoReflect() protoreflect.Message
- func (x *ListNodesResponse) Reset()
- func (x *ListNodesResponse) String() string
- func (this *ListNodesResponse) Validate() error
- type ListVersionsRequest
- func (*ListVersionsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListVersionsRequest) GetNode() *Node
- func (*ListVersionsRequest) ProtoMessage()
- func (x *ListVersionsRequest) ProtoReflect() protoreflect.Message
- func (x *ListVersionsRequest) Reset()
- func (x *ListVersionsRequest) String() string
- func (this *ListVersionsRequest) Validate() error
- type ListVersionsResponse
- func (*ListVersionsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListVersionsResponse) GetVersion() *ChangeLog
- func (*ListVersionsResponse) ProtoMessage()
- func (x *ListVersionsResponse) ProtoReflect() protoreflect.Message
- func (x *ListVersionsResponse) Reset()
- func (x *ListVersionsResponse) String() string
- func (this *ListVersionsResponse) Validate() error
- type MetaFilter
- func (m *MetaFilter) HasSQLFilters() bool
- func (m *MetaFilter) LimitDepth() int
- func (m *MetaFilter) Match(name string, n *Node) bool
- func (m *MetaFilter) MatchForceGrep(name string) bool
- func (m *MetaFilter) Parse() bool
- func (m *MetaFilter) ParseType(t NodeType)
- func (m *MetaFilter) Where() (where string, args []interface{})
- type NamedFileKeyManagerServer
- type NamedNodeChangesStreamerServer
- type NamedNodeContentReaderServer
- type NamedNodeContentWriterServer
- type NamedNodeEventsProviderServer
- type NamedNodeProviderServer
- type NamedNodeProviderStreamerServer
- type NamedNodeReceiverServer
- type NamedNodeReceiverStreamServer
- type NamedNodeVersionerServer
- type NamedSearcherServer
- type NamedSessionIndexerServer
- type NamedSyncChangesServer
- type Node
- func (node *Node) AllMetaDeserialized(excludes map[string]struct{}) map[string]interface{}
- func (node *Node) Clone() *Node
- func (*Node) Descriptor() ([]byte, []int)deprecated
- func (x *Node) GetAppearsIn() []*WorkspaceRelativePath
- func (x *Node) GetCommits() []*ChangeLog
- func (x *Node) GetEtag() string
- func (x *Node) GetMTime() int64
- func (node *Node) GetMeta(namespace string, jsonStruc interface{}) error
- func (node *Node) GetMetaBool(namespace string) bool
- func (x *Node) GetMetaStore() map[string]string
- func (node *Node) GetModTime() time.Time
- func (x *Node) GetMode() int32
- func (x *Node) GetPath() string
- func (x *Node) GetSize() int64
- func (node *Node) GetStringMeta(namespace string) string
- func (x *Node) GetType() NodeType
- func (x *Node) GetUuid() string
- func (node *Node) HasMetaKey(keyName string) bool
- func (node *Node) HasSource() bool
- func (node *Node) IsLeaf() bool
- func (node *Node) IsLeafInt() int
- func (node *Node) LegacyMeta(meta map[string]interface{})
- func (node *Node) MarshalLogObject(encoder zapcore.ObjectEncoder) error
- func (node *Node) MustSetMeta(namespace string, jsonMeta interface{})
- func (*Node) ProtoMessage()
- func (x *Node) ProtoReflect() protoreflect.Message
- func (node *Node) RenewUuidIfEmpty(force bool)
- func (x *Node) Reset()
- func (x *Node) String() string
- func (this *Node) Validate() error
- func (node *Node) WithoutReservedMetas() *Node
- func (node *Node) Zap(key ...string) zapcore.Field
- func (node *Node) ZapPath() zapcore.Field
- func (node *Node) ZapUuid() zapcore.Field
- func (node *Node) Zaps(key ...string) []zapcore.Field
- type NodeChangeEvent
- func (*NodeChangeEvent) Descriptor() ([]byte, []int)deprecated
- func (x *NodeChangeEvent) GetMetadata() map[string]string
- func (x *NodeChangeEvent) GetOptimistic() bool
- func (x *NodeChangeEvent) GetSilent() bool
- func (x *NodeChangeEvent) GetSource() *Node
- func (x *NodeChangeEvent) GetTarget() *Node
- func (x *NodeChangeEvent) GetType() NodeChangeEvent_EventType
- func (*NodeChangeEvent) ProtoMessage()
- func (x *NodeChangeEvent) ProtoReflect() protoreflect.Message
- func (x *NodeChangeEvent) Reset()
- func (x *NodeChangeEvent) String() string
- func (this *NodeChangeEvent) Validate() error
- func (msg *NodeChangeEvent) Zap() zapcore.Field
- type NodeChangeEvent_EventType
- func (NodeChangeEvent_EventType) Descriptor() protoreflect.EnumDescriptor
- func (x NodeChangeEvent_EventType) Enum() *NodeChangeEvent_EventType
- func (NodeChangeEvent_EventType) EnumDescriptor() ([]byte, []int)deprecated
- func (x NodeChangeEvent_EventType) Number() protoreflect.EnumNumber
- func (x NodeChangeEvent_EventType) String() string
- func (NodeChangeEvent_EventType) Type() protoreflect.EnumType
- type NodeChangesStreamerClient
- type NodeChangesStreamerEnhancedServer
- type NodeChangesStreamerServer
- type NodeChangesStreamerStub
- type NodeChangesStreamerStub_StreamChangesStreamer
- type NodeChangesStreamer_StreamChangesClient
- type NodeChangesStreamer_StreamChangesServer
- type NodeContentReaderClient
- type NodeContentReaderEnhancedServer
- type NodeContentReaderServer
- type NodeContentReaderStub
- type NodeContentWriterClient
- type NodeContentWriterEnhancedServer
- type NodeContentWriterServer
- type NodeContentWriterStub
- type NodeEventsProviderClient
- type NodeEventsProviderEnhancedServer
- type NodeEventsProviderServer
- type NodeEventsProviderStub
- type NodeEventsProviderStub_WatchNodeStreamer
- type NodeEventsProvider_WatchNodeClient
- type NodeEventsProvider_WatchNodeServer
- type NodeProviderClient
- type NodeProviderEnhancedServer
- type NodeProviderMock
- type NodeProviderServer
- type NodeProviderStreamerClient
- type NodeProviderStreamerEnhancedServer
- type NodeProviderStreamerServer
- type NodeProviderStreamerStub
- type NodeProviderStreamerStub_ReadNodeStreamStreamer
- type NodeProviderStreamer_ReadNodeStreamClient
- type NodeProviderStreamer_ReadNodeStreamServer
- type NodeProviderStub
- type NodeProviderStub_ListNodesStreamer
- type NodeProvider_ListNodesClient
- type NodeProvider_ListNodesServer
- type NodeReceiverClient
- type NodeReceiverEnhancedServer
- func (m NodeReceiverEnhancedServer) CreateNode(ctx context.Context, r *CreateNodeRequest) (*CreateNodeResponse, error)
- func (m NodeReceiverEnhancedServer) DeleteNode(ctx context.Context, r *DeleteNodeRequest) (*DeleteNodeResponse, error)
- func (m NodeReceiverEnhancedServer) UpdateNode(ctx context.Context, r *UpdateNodeRequest) (*UpdateNodeResponse, error)
- type NodeReceiverMock
- func (m *NodeReceiverMock) CreateNode(ctx context.Context, in *CreateNodeRequest, opts ...grpc.CallOption) (*CreateNodeResponse, error)
- func (m *NodeReceiverMock) DeleteNode(ctx context.Context, in *DeleteNodeRequest, opts ...grpc.CallOption) (*DeleteNodeResponse, error)
- func (m *NodeReceiverMock) UpdateNode(ctx context.Context, in *UpdateNodeRequest, opts ...grpc.CallOption) (*UpdateNodeResponse, error)
- type NodeReceiverServer
- type NodeReceiverStreamClient
- type NodeReceiverStreamEnhancedServer
- func (m NodeReceiverStreamEnhancedServer) CreateNodeStream(s NodeReceiverStream_CreateNodeStreamServer) error
- func (m NodeReceiverStreamEnhancedServer) DeleteNodeStream(s NodeReceiverStream_DeleteNodeStreamServer) error
- func (m NodeReceiverStreamEnhancedServer) UpdateNodeStream(s NodeReceiverStream_UpdateNodeStreamServer) error
- type NodeReceiverStreamServer
- type NodeReceiverStreamStub
- type NodeReceiverStreamStub_CreateNodeStreamStreamer
- type NodeReceiverStreamStub_DeleteNodeStreamStreamer
- type NodeReceiverStreamStub_UpdateNodeStreamStreamer
- type NodeReceiverStream_CreateNodeStreamClient
- type NodeReceiverStream_CreateNodeStreamServer
- type NodeReceiverStream_DeleteNodeStreamClient
- type NodeReceiverStream_DeleteNodeStreamServer
- type NodeReceiverStream_UpdateNodeStreamClient
- type NodeReceiverStream_UpdateNodeStreamServer
- type NodeReceiverStub
- type NodeType
- type NodeVersionerClient
- type NodeVersionerEnhancedServer
- func (m NodeVersionerEnhancedServer) CreateVersion(ctx context.Context, r *CreateVersionRequest) (*CreateVersionResponse, error)
- func (m NodeVersionerEnhancedServer) HeadVersion(ctx context.Context, r *HeadVersionRequest) (*HeadVersionResponse, error)
- func (m NodeVersionerEnhancedServer) ListVersions(r *ListVersionsRequest, s NodeVersioner_ListVersionsServer) error
- func (m NodeVersionerEnhancedServer) PruneVersions(ctx context.Context, r *PruneVersionsRequest) (*PruneVersionsResponse, error)
- func (m NodeVersionerEnhancedServer) StoreVersion(ctx context.Context, r *StoreVersionRequest) (*StoreVersionResponse, error)
- type NodeVersionerServer
- type NodeVersionerStub
- type NodeVersionerStub_ListVersionsStreamer
- type NodeVersioner_ListVersionsClient
- type NodeVersioner_ListVersionsServer
- type OpenSessionRequest
- func (*OpenSessionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *OpenSessionRequest) GetSession() *IndexationSession
- func (*OpenSessionRequest) ProtoMessage()
- func (x *OpenSessionRequest) ProtoReflect() protoreflect.Message
- func (x *OpenSessionRequest) Reset()
- func (x *OpenSessionRequest) String() string
- func (this *OpenSessionRequest) Validate() error
- type OpenSessionResponse
- func (*OpenSessionResponse) Descriptor() ([]byte, []int)deprecated
- func (x *OpenSessionResponse) GetSession() *IndexationSession
- func (*OpenSessionResponse) ProtoMessage()
- func (x *OpenSessionResponse) ProtoReflect() protoreflect.Message
- func (x *OpenSessionResponse) Reset()
- func (x *OpenSessionResponse) String() string
- func (this *OpenSessionResponse) Validate() error
- type PruneVersionsRequest
- func (*PruneVersionsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *PruneVersionsRequest) GetAllDeletedNodes() bool
- func (x *PruneVersionsRequest) GetUniqueNode() *Node
- func (*PruneVersionsRequest) ProtoMessage()
- func (x *PruneVersionsRequest) ProtoReflect() protoreflect.Message
- func (x *PruneVersionsRequest) Reset()
- func (x *PruneVersionsRequest) String() string
- func (this *PruneVersionsRequest) Validate() error
- type PruneVersionsResponse
- func (*PruneVersionsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *PruneVersionsResponse) GetDeletedVersions() []*ChangeLog
- func (*PruneVersionsResponse) ProtoMessage()
- func (x *PruneVersionsResponse) ProtoReflect() protoreflect.Message
- func (x *PruneVersionsResponse) Reset()
- func (x *PruneVersionsResponse) String() string
- func (this *PruneVersionsResponse) Validate() error
- type PutSyncChangeResponse
- func (*PutSyncChangeResponse) Descriptor() ([]byte, []int)deprecated
- func (x *PutSyncChangeResponse) GetMsg() string
- func (x *PutSyncChangeResponse) GetSuccess() bool
- func (*PutSyncChangeResponse) ProtoMessage()
- func (x *PutSyncChangeResponse) ProtoReflect() protoreflect.Message
- func (x *PutSyncChangeResponse) Reset()
- func (x *PutSyncChangeResponse) String() string
- func (this *PutSyncChangeResponse) Validate() error
- type Query
- func (*Query) Descriptor() ([]byte, []int)deprecated
- func (x *Query) GetContent() string
- func (x *Query) GetDurationDate() string
- func (x *Query) GetExtension() string
- func (x *Query) GetFileName() string
- func (x *Query) GetFileNameOrContent() string
- func (x *Query) GetFreeString() string
- func (x *Query) GetGeoQuery() *GeoQuery
- func (x *Query) GetMaxDate() int64
- func (x *Query) GetMaxSize() int64
- func (x *Query) GetMinDate() int64
- func (x *Query) GetMinSize() int64
- func (x *Query) GetNot() bool
- func (x *Query) GetPathDepth() int32
- func (x *Query) GetPathPrefix() []string
- func (x *Query) GetPaths() []string
- func (x *Query) GetType() NodeType
- func (x *Query) GetUUIDs() []string
- func (m *Query) ParseDurationDate(ref ...time.Time) error
- func (*Query) ProtoMessage()
- func (x *Query) ProtoReflect() protoreflect.Message
- func (x *Query) Reset()
- func (x *Query) String() string
- func (this *Query) Validate() error
- type ReadNodeRequest
- func (*ReadNodeRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ReadNodeRequest) GetNode() *Node
- func (x *ReadNodeRequest) GetObjectStats() bool
- func (x *ReadNodeRequest) GetStatFlags() []uint32
- func (x *ReadNodeRequest) GetWithCommits() bool
- func (x *ReadNodeRequest) GetWithExtendedStats() bool
- func (*ReadNodeRequest) ProtoMessage()
- func (x *ReadNodeRequest) ProtoReflect() protoreflect.Message
- func (x *ReadNodeRequest) Reset()
- func (x *ReadNodeRequest) String() string
- func (this *ReadNodeRequest) Validate() error
- type ReadNodeResponse
- func (*ReadNodeResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ReadNodeResponse) GetNode() *Node
- func (x *ReadNodeResponse) GetSuccess() bool
- func (*ReadNodeResponse) ProtoMessage()
- func (x *ReadNodeResponse) ProtoReflect() protoreflect.Message
- func (x *ReadNodeResponse) Reset()
- func (x *ReadNodeResponse) String() string
- func (this *ReadNodeResponse) Validate() error
- type SearchFacet
- func (*SearchFacet) Descriptor() ([]byte, []int)deprecated
- func (x *SearchFacet) GetCount() int32
- func (x *SearchFacet) GetEnd() int32
- func (x *SearchFacet) GetFieldName() string
- func (x *SearchFacet) GetLabel() string
- func (x *SearchFacet) GetMax() int64
- func (x *SearchFacet) GetMin() int64
- func (x *SearchFacet) GetStart() int32
- func (x *SearchFacet) GetTerm() string
- func (*SearchFacet) ProtoMessage()
- func (x *SearchFacet) ProtoReflect() protoreflect.Message
- func (x *SearchFacet) Reset()
- func (x *SearchFacet) String() string
- func (this *SearchFacet) Validate() error
- type SearchRequest
- func (*SearchRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SearchRequest) GetDetails() bool
- func (x *SearchRequest) GetFrom() int32
- func (x *SearchRequest) GetQuery() *Query
- func (x *SearchRequest) GetSize() int32
- func (x *SearchRequest) GetStatFlags() []uint32
- func (*SearchRequest) ProtoMessage()
- func (x *SearchRequest) ProtoReflect() protoreflect.Message
- func (x *SearchRequest) Reset()
- func (x *SearchRequest) String() string
- func (this *SearchRequest) Validate() error
- type SearchResponse
- func (*SearchResponse) Descriptor() ([]byte, []int)deprecated
- func (x *SearchResponse) GetFacet() *SearchFacet
- func (x *SearchResponse) GetNode() *Node
- func (*SearchResponse) ProtoMessage()
- func (x *SearchResponse) ProtoReflect() protoreflect.Message
- func (x *SearchResponse) Reset()
- func (x *SearchResponse) String() string
- func (this *SearchResponse) Validate() error
- type SearchSyncChangeRequest
- func (*SearchSyncChangeRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SearchSyncChangeRequest) GetFlatten() bool
- func (x *SearchSyncChangeRequest) GetLastSeqOnly() bool
- func (x *SearchSyncChangeRequest) GetPrefix() string
- func (x *SearchSyncChangeRequest) GetSeq() uint64
- func (*SearchSyncChangeRequest) ProtoMessage()
- func (x *SearchSyncChangeRequest) ProtoReflect() protoreflect.Message
- func (x *SearchSyncChangeRequest) Reset()
- func (x *SearchSyncChangeRequest) String() string
- func (this *SearchSyncChangeRequest) Validate() error
- type SearcherClient
- type SearcherEnhancedServer
- type SearcherServer
- type SearcherStub
- type SearcherStub_SearchStreamer
- type Searcher_SearchClient
- type Searcher_SearchServer
- type SessionIndexerClient
- type SessionIndexerEnhancedServer
- func (m SessionIndexerEnhancedServer) CloseSession(ctx context.Context, r *CloseSessionRequest) (*CloseSessionResponse, error)
- func (m SessionIndexerEnhancedServer) FlushSession(ctx context.Context, r *FlushSessionRequest) (*FlushSessionResponse, error)
- func (m SessionIndexerEnhancedServer) OpenSession(ctx context.Context, r *OpenSessionRequest) (*OpenSessionResponse, error)
- type SessionIndexerMock
- func (s *SessionIndexerMock) CloseSession(ctx context.Context, in *CloseSessionRequest, opts ...grpc.CallOption) (*CloseSessionResponse, error)
- func (s *SessionIndexerMock) FlushSession(ctx context.Context, in *FlushSessionRequest, opts ...grpc.CallOption) (*FlushSessionResponse, error)
- func (s *SessionIndexerMock) OpenSession(ctx context.Context, in *OpenSessionRequest, opts ...grpc.CallOption) (*OpenSessionResponse, error)
- type SessionIndexerServer
- type SessionIndexerStub
- type StoreVersionRequest
- func (*StoreVersionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StoreVersionRequest) GetNode() *Node
- func (x *StoreVersionRequest) GetVersion() *ChangeLog
- func (*StoreVersionRequest) ProtoMessage()
- func (x *StoreVersionRequest) ProtoReflect() protoreflect.Message
- func (x *StoreVersionRequest) Reset()
- func (x *StoreVersionRequest) String() string
- func (this *StoreVersionRequest) Validate() error
- type StoreVersionResponse
- func (*StoreVersionResponse) Descriptor() ([]byte, []int)deprecated
- func (x *StoreVersionResponse) GetPruneVersions() []*ChangeLog
- func (x *StoreVersionResponse) GetSuccess() bool
- func (*StoreVersionResponse) ProtoMessage()
- func (x *StoreVersionResponse) ProtoReflect() protoreflect.Message
- func (x *StoreVersionResponse) Reset()
- func (x *StoreVersionResponse) String() string
- func (this *StoreVersionResponse) Validate() error
- type StreamChangesRequest
- func (*StreamChangesRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StreamChangesRequest) GetRootPath() string
- func (*StreamChangesRequest) ProtoMessage()
- func (x *StreamChangesRequest) ProtoReflect() protoreflect.Message
- func (x *StreamChangesRequest) Reset()
- func (x *StreamChangesRequest) String() string
- func (this *StreamChangesRequest) Validate() error
- type StreamerMock
- func (m *StreamerMock) Close() error
- func (m *StreamerMock) CloseSend() error
- func (m *StreamerMock) Context() context.Context
- func (m *StreamerMock) Error() error
- func (m *StreamerMock) Header() (metadata.MD, error)
- func (m *StreamerMock) Recv(v interface{}) error
- func (m *StreamerMock) RecvMsg(msg interface{}) error
- func (m *StreamerMock) Send(v interface{}) error
- func (m *StreamerMock) SendMsg(msg interface{}) error
- func (m *StreamerMock) Trailer() metadata.MD
- type SyncChange
- func (*SyncChange) Descriptor() ([]byte, []int)deprecated
- func (x *SyncChange) GetNode() *SyncChangeNode
- func (x *SyncChange) GetNodeId() string
- func (x *SyncChange) GetSeq() uint64
- func (x *SyncChange) GetSource() string
- func (x *SyncChange) GetTarget() string
- func (x *SyncChange) GetType() SyncChange_Type
- func (*SyncChange) ProtoMessage()
- func (x *SyncChange) ProtoReflect() protoreflect.Message
- func (x *SyncChange) Reset()
- func (x *SyncChange) String() string
- func (this *SyncChange) Validate() error
- type SyncChangeNode
- func (*SyncChangeNode) Descriptor() ([]byte, []int)deprecated
- func (x *SyncChangeNode) GetBytesize() int64
- func (x *SyncChangeNode) GetMd5() string
- func (x *SyncChangeNode) GetMtime() int64
- func (x *SyncChangeNode) GetNodePath() string
- func (x *SyncChangeNode) GetRepositoryIdentifier() string
- func (*SyncChangeNode) ProtoMessage()
- func (x *SyncChangeNode) ProtoReflect() protoreflect.Message
- func (x *SyncChangeNode) Reset()
- func (x *SyncChangeNode) String() string
- func (this *SyncChangeNode) Validate() error
- type SyncChange_Type
- func (SyncChange_Type) Descriptor() protoreflect.EnumDescriptor
- func (x SyncChange_Type) Enum() *SyncChange_Type
- func (SyncChange_Type) EnumDescriptor() ([]byte, []int)deprecated
- func (x SyncChange_Type) Number() protoreflect.EnumNumber
- func (x SyncChange_Type) String() string
- func (SyncChange_Type) Type() protoreflect.EnumType
- type SyncChangesClient
- type SyncChangesEnhancedServer
- type SyncChangesServer
- type SyncChangesStub
- type SyncChangesStub_PutStreamer
- type SyncChangesStub_SearchStreamer
- type SyncChanges_PutClient
- type SyncChanges_PutServer
- type SyncChanges_SearchClient
- type SyncChanges_SearchServer
- type UnimplementedFileKeyManagerServer
- type UnimplementedNodeChangesStreamerServer
- type UnimplementedNodeContentReaderServer
- type UnimplementedNodeContentWriterServer
- type UnimplementedNodeEventsProviderServer
- type UnimplementedNodeProviderServer
- type UnimplementedNodeProviderStreamerServer
- type UnimplementedNodeReceiverServer
- func (UnimplementedNodeReceiverServer) CreateNode(context.Context, *CreateNodeRequest) (*CreateNodeResponse, error)
- func (UnimplementedNodeReceiverServer) DeleteNode(context.Context, *DeleteNodeRequest) (*DeleteNodeResponse, error)
- func (UnimplementedNodeReceiverServer) UpdateNode(context.Context, *UpdateNodeRequest) (*UpdateNodeResponse, error)
- type UnimplementedNodeReceiverStreamServer
- func (UnimplementedNodeReceiverStreamServer) CreateNodeStream(NodeReceiverStream_CreateNodeStreamServer) error
- func (UnimplementedNodeReceiverStreamServer) DeleteNodeStream(NodeReceiverStream_DeleteNodeStreamServer) error
- func (UnimplementedNodeReceiverStreamServer) UpdateNodeStream(NodeReceiverStream_UpdateNodeStreamServer) error
- type UnimplementedNodeVersionerServer
- func (UnimplementedNodeVersionerServer) CreateVersion(context.Context, *CreateVersionRequest) (*CreateVersionResponse, error)
- func (UnimplementedNodeVersionerServer) HeadVersion(context.Context, *HeadVersionRequest) (*HeadVersionResponse, error)
- func (UnimplementedNodeVersionerServer) ListVersions(*ListVersionsRequest, NodeVersioner_ListVersionsServer) error
- func (UnimplementedNodeVersionerServer) PruneVersions(context.Context, *PruneVersionsRequest) (*PruneVersionsResponse, error)
- func (UnimplementedNodeVersionerServer) StoreVersion(context.Context, *StoreVersionRequest) (*StoreVersionResponse, error)
- type UnimplementedSearcherServer
- type UnimplementedSessionIndexerServer
- func (UnimplementedSessionIndexerServer) CloseSession(context.Context, *CloseSessionRequest) (*CloseSessionResponse, error)
- func (UnimplementedSessionIndexerServer) FlushSession(context.Context, *FlushSessionRequest) (*FlushSessionResponse, error)
- func (UnimplementedSessionIndexerServer) OpenSession(context.Context, *OpenSessionRequest) (*OpenSessionResponse, error)
- type UnimplementedSyncChangesServer
- type UnsafeFileKeyManagerServer
- type UnsafeNodeChangesStreamerServer
- type UnsafeNodeContentReaderServer
- type UnsafeNodeContentWriterServer
- type UnsafeNodeEventsProviderServer
- type UnsafeNodeProviderServer
- type UnsafeNodeProviderStreamerServer
- type UnsafeNodeReceiverServer
- type UnsafeNodeReceiverStreamServer
- type UnsafeNodeVersionerServer
- type UnsafeSearcherServer
- type UnsafeSessionIndexerServer
- type UnsafeSyncChangesServer
- type UpdateNodeRequest
- func (*UpdateNodeRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateNodeRequest) GetFrom() *Node
- func (x *UpdateNodeRequest) GetIndexationSession() string
- func (x *UpdateNodeRequest) GetSilent() bool
- func (x *UpdateNodeRequest) GetTo() *Node
- func (*UpdateNodeRequest) ProtoMessage()
- func (x *UpdateNodeRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateNodeRequest) Reset()
- func (x *UpdateNodeRequest) String() string
- func (this *UpdateNodeRequest) Validate() error
- type UpdateNodeResponse
- func (*UpdateNodeResponse) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateNodeResponse) GetNode() *Node
- func (x *UpdateNodeResponse) GetSuccess() bool
- func (*UpdateNodeResponse) ProtoMessage()
- func (x *UpdateNodeResponse) ProtoReflect() protoreflect.Message
- func (x *UpdateNodeResponse) Reset()
- func (x *UpdateNodeResponse) String() string
- func (this *UpdateNodeResponse) Validate() error
- type VersioningKeepPeriod
- func (*VersioningKeepPeriod) Descriptor() ([]byte, []int)deprecated
- func (x *VersioningKeepPeriod) GetIntervalStart() string
- func (x *VersioningKeepPeriod) GetMaxNumber() int32
- func (*VersioningKeepPeriod) ProtoMessage()
- func (x *VersioningKeepPeriod) ProtoReflect() protoreflect.Message
- func (x *VersioningKeepPeriod) Reset()
- func (x *VersioningKeepPeriod) String() string
- func (this *VersioningKeepPeriod) Validate() error
- type VersioningNodeDeletedStrategy
- func (VersioningNodeDeletedStrategy) Descriptor() protoreflect.EnumDescriptor
- func (x VersioningNodeDeletedStrategy) Enum() *VersioningNodeDeletedStrategy
- func (VersioningNodeDeletedStrategy) EnumDescriptor() ([]byte, []int)deprecated
- func (x VersioningNodeDeletedStrategy) Number() protoreflect.EnumNumber
- func (x VersioningNodeDeletedStrategy) String() string
- func (VersioningNodeDeletedStrategy) Type() protoreflect.EnumType
- type VersioningPolicy
- func (*VersioningPolicy) Descriptor() ([]byte, []int)deprecated
- func (x *VersioningPolicy) GetDescription() string
- func (x *VersioningPolicy) GetIgnoreFilesGreaterThan() int64
- func (x *VersioningPolicy) GetKeepPeriods() []*VersioningKeepPeriod
- func (x *VersioningPolicy) GetMaxSizePerFile() int64
- func (x *VersioningPolicy) GetMaxTotalSize() int64
- func (x *VersioningPolicy) GetName() string
- func (x *VersioningPolicy) GetNodeDeletedStrategy() VersioningNodeDeletedStrategy
- func (x *VersioningPolicy) GetUuid() string
- func (x *VersioningPolicy) GetVersionsDataSourceBucket() string
- func (x *VersioningPolicy) GetVersionsDataSourceName() string
- func (policy *VersioningPolicy) MarshalLogObject(encoder zapcore.ObjectEncoder) error
- func (*VersioningPolicy) ProtoMessage()
- func (x *VersioningPolicy) ProtoReflect() protoreflect.Message
- func (x *VersioningPolicy) Reset()
- func (x *VersioningPolicy) String() string
- func (this *VersioningPolicy) Validate() error
- func (policy *VersioningPolicy) Zap() zapcore.Field
- type WatchNodeRequest
- func (*WatchNodeRequest) Descriptor() ([]byte, []int)deprecated
- func (x *WatchNodeRequest) GetNode() *Node
- func (*WatchNodeRequest) ProtoMessage()
- func (x *WatchNodeRequest) ProtoReflect() protoreflect.Message
- func (x *WatchNodeRequest) Reset()
- func (x *WatchNodeRequest) String() string
- func (this *WatchNodeRequest) Validate() error
- type WatchNodeResponse
- func (*WatchNodeResponse) Descriptor() ([]byte, []int)deprecated
- func (x *WatchNodeResponse) GetNode() *Node
- func (*WatchNodeResponse) ProtoMessage()
- func (x *WatchNodeResponse) ProtoReflect() protoreflect.Message
- func (x *WatchNodeResponse) Reset()
- func (x *WatchNodeResponse) String() string
- func (this *WatchNodeResponse) Validate() error
- type WorkspaceRelativePath
- func (*WorkspaceRelativePath) Descriptor() ([]byte, []int)deprecated
- func (x *WorkspaceRelativePath) GetPath() string
- func (x *WorkspaceRelativePath) GetWsLabel() string
- func (x *WorkspaceRelativePath) GetWsScope() string
- func (x *WorkspaceRelativePath) GetWsSlug() string
- func (x *WorkspaceRelativePath) GetWsUuid() string
- func (*WorkspaceRelativePath) ProtoMessage()
- func (x *WorkspaceRelativePath) ProtoReflect() protoreflect.Message
- func (x *WorkspaceRelativePath) Reset()
- func (x *WorkspaceRelativePath) String() string
- func (this *WorkspaceRelativePath) Validate() error
- type WrappingStreamerResponse
- func (*WrappingStreamerResponse) Descriptor() ([]byte, []int)deprecated
- func (m *WrappingStreamerResponse) GetData() isWrappingStreamerResponse_Data
- func (x *WrappingStreamerResponse) GetError() string
- func (x *WrappingStreamerResponse) GetListNodesResponse() *ListNodesResponse
- func (x *WrappingStreamerResponse) GetNodeChangeEvent() *NodeChangeEvent
- func (*WrappingStreamerResponse) ProtoMessage()
- func (x *WrappingStreamerResponse) ProtoReflect() protoreflect.Message
- func (x *WrappingStreamerResponse) Reset()
- func (x *WrappingStreamerResponse) String() string
- func (this *WrappingStreamerResponse) Validate() error
- type WrappingStreamerResponse_ListNodesResponse
- type WrappingStreamerResponse_NodeChangeEvent
Constants ¶
const ( MetaFilterGrep = "grep" MetaFilterNoGrep = "no-grep" MetaFilterForceGrep = "force-grep" MetaFilterTime = "time" MetaFilterSize = "size" MetaFilterDepth = "depth" )
const ( StatFlagDefault uint32 = iota StatFlagNone StatFlagFolderSize StatFlagFolderCounts )
Variables ¶
var ( VersioningNodeDeletedStrategy_name = map[int32]string{ 0: "KeepAll", 1: "KeepLast", 2: "KeepNone", } VersioningNodeDeletedStrategy_value = map[string]int32{ "KeepAll": 0, "KeepLast": 1, "KeepNone": 2, } )
Enum value maps for VersioningNodeDeletedStrategy.
var ( NodeType_name = map[int32]string{ 0: "UNKNOWN", 1: "LEAF", 2: "COLLECTION", } NodeType_value = map[string]int32{ "UNKNOWN": 0, "LEAF": 1, "COLLECTION": 2, } )
Enum value maps for NodeType.
var ( NodeChangeEvent_EventType_name = map[int32]string{ 0: "CREATE", 1: "READ", 2: "UPDATE_PATH", 3: "UPDATE_CONTENT", 4: "UPDATE_META", 6: "UPDATE_USER_META", 5: "DELETE", } NodeChangeEvent_EventType_value = map[string]int32{ "CREATE": 0, "READ": 1, "UPDATE_PATH": 2, "UPDATE_CONTENT": 3, "UPDATE_META": 4, "UPDATE_USER_META": 6, "DELETE": 5, } )
Enum value maps for NodeChangeEvent_EventType.
var ( SyncChange_Type_name = map[int32]string{ 0: "unknown", 1: "create", 2: "delete", 3: "path", 4: "content", } SyncChange_Type_value = map[string]int32{ "unknown": 0, "create": 1, "delete": 2, "path": 3, "content": 4, } )
Enum value maps for SyncChange_Type.
var FileKeyManager_ServiceDesc = grpc.ServiceDesc{ ServiceName: "tree.FileKeyManager", HandlerType: (*FileKeyManagerServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "GetEncryptionKey", Handler: _FileKeyManager_GetEncryptionKey_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "cells-tree.proto", }
FileKeyManager_ServiceDesc is the grpc.ServiceDesc for FileKeyManager service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_cells_tree_proto protoreflect.FileDescriptor
var NodeChangesStreamer_ServiceDesc = grpc.ServiceDesc{ ServiceName: "tree.NodeChangesStreamer", HandlerType: (*NodeChangesStreamerServer)(nil), Methods: []grpc.MethodDesc{}, Streams: []grpc.StreamDesc{ { StreamName: "StreamChanges", Handler: _NodeChangesStreamer_StreamChanges_Handler, ServerStreams: true, }, }, Metadata: "cells-tree.proto", }
NodeChangesStreamer_ServiceDesc is the grpc.ServiceDesc for NodeChangesStreamer service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var NodeContentReader_ServiceDesc = grpc.ServiceDesc{ ServiceName: "tree.NodeContentReader", HandlerType: (*NodeContentReaderServer)(nil), Methods: []grpc.MethodDesc{}, Streams: []grpc.StreamDesc{}, Metadata: "cells-tree.proto", }
NodeContentReader_ServiceDesc is the grpc.ServiceDesc for NodeContentReader service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var NodeContentWriter_ServiceDesc = grpc.ServiceDesc{ ServiceName: "tree.NodeContentWriter", HandlerType: (*NodeContentWriterServer)(nil), Methods: []grpc.MethodDesc{}, Streams: []grpc.StreamDesc{}, Metadata: "cells-tree.proto", }
NodeContentWriter_ServiceDesc is the grpc.ServiceDesc for NodeContentWriter service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var NodeEventsProvider_ServiceDesc = grpc.ServiceDesc{ ServiceName: "tree.NodeEventsProvider", HandlerType: (*NodeEventsProviderServer)(nil), Methods: []grpc.MethodDesc{}, Streams: []grpc.StreamDesc{ { StreamName: "WatchNode", Handler: _NodeEventsProvider_WatchNode_Handler, ServerStreams: true, }, }, Metadata: "cells-tree.proto", }
NodeEventsProvider_ServiceDesc is the grpc.ServiceDesc for NodeEventsProvider service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var NodeProviderStreamer_ServiceDesc = grpc.ServiceDesc{ ServiceName: "tree.NodeProviderStreamer", HandlerType: (*NodeProviderStreamerServer)(nil), Methods: []grpc.MethodDesc{}, Streams: []grpc.StreamDesc{ { StreamName: "ReadNodeStream", Handler: _NodeProviderStreamer_ReadNodeStream_Handler, ServerStreams: true, ClientStreams: true, }, }, Metadata: "cells-tree.proto", }
NodeProviderStreamer_ServiceDesc is the grpc.ServiceDesc for NodeProviderStreamer service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var NodeProvider_ServiceDesc = grpc.ServiceDesc{ ServiceName: "tree.NodeProvider", HandlerType: (*NodeProviderServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "ReadNode", Handler: _NodeProvider_ReadNode_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "ListNodes", Handler: _NodeProvider_ListNodes_Handler, ServerStreams: true, }, }, Metadata: "cells-tree.proto", }
NodeProvider_ServiceDesc is the grpc.ServiceDesc for NodeProvider service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var NodeReceiverStream_ServiceDesc = grpc.ServiceDesc{ ServiceName: "tree.NodeReceiverStream", HandlerType: (*NodeReceiverStreamServer)(nil), Methods: []grpc.MethodDesc{}, Streams: []grpc.StreamDesc{ { StreamName: "CreateNodeStream", Handler: _NodeReceiverStream_CreateNodeStream_Handler, ServerStreams: true, ClientStreams: true, }, { StreamName: "UpdateNodeStream", Handler: _NodeReceiverStream_UpdateNodeStream_Handler, ServerStreams: true, ClientStreams: true, }, { StreamName: "DeleteNodeStream", Handler: _NodeReceiverStream_DeleteNodeStream_Handler, ServerStreams: true, ClientStreams: true, }, }, Metadata: "cells-tree.proto", }
NodeReceiverStream_ServiceDesc is the grpc.ServiceDesc for NodeReceiverStream service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var NodeReceiver_ServiceDesc = grpc.ServiceDesc{ ServiceName: "tree.NodeReceiver", HandlerType: (*NodeReceiverServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "CreateNode", Handler: _NodeReceiver_CreateNode_Handler, }, { MethodName: "UpdateNode", Handler: _NodeReceiver_UpdateNode_Handler, }, { MethodName: "DeleteNode", Handler: _NodeReceiver_DeleteNode_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "cells-tree.proto", }
NodeReceiver_ServiceDesc is the grpc.ServiceDesc for NodeReceiver service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var NodeVersioner_ServiceDesc = grpc.ServiceDesc{ ServiceName: "tree.NodeVersioner", HandlerType: (*NodeVersionerServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "CreateVersion", Handler: _NodeVersioner_CreateVersion_Handler, }, { MethodName: "StoreVersion", Handler: _NodeVersioner_StoreVersion_Handler, }, { MethodName: "HeadVersion", Handler: _NodeVersioner_HeadVersion_Handler, }, { MethodName: "PruneVersions", Handler: _NodeVersioner_PruneVersions_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "ListVersions", Handler: _NodeVersioner_ListVersions_Handler, ServerStreams: true, }, }, Metadata: "cells-tree.proto", }
NodeVersioner_ServiceDesc is the grpc.ServiceDesc for NodeVersioner service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var Searcher_ServiceDesc = grpc.ServiceDesc{ ServiceName: "tree.Searcher", HandlerType: (*SearcherServer)(nil), Methods: []grpc.MethodDesc{}, Streams: []grpc.StreamDesc{ { StreamName: "Search", Handler: _Searcher_Search_Handler, ServerStreams: true, }, }, Metadata: "cells-tree.proto", }
Searcher_ServiceDesc is the grpc.ServiceDesc for Searcher service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var SessionIndexer_ServiceDesc = grpc.ServiceDesc{ ServiceName: "tree.SessionIndexer", HandlerType: (*SessionIndexerServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "OpenSession", Handler: _SessionIndexer_OpenSession_Handler, }, { MethodName: "FlushSession", Handler: _SessionIndexer_FlushSession_Handler, }, { MethodName: "CloseSession", Handler: _SessionIndexer_CloseSession_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "cells-tree.proto", }
SessionIndexer_ServiceDesc is the grpc.ServiceDesc for SessionIndexer service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var SyncChanges_ServiceDesc = grpc.ServiceDesc{ ServiceName: "tree.SyncChanges", HandlerType: (*SyncChangesServer)(nil), Methods: []grpc.MethodDesc{}, Streams: []grpc.StreamDesc{ { StreamName: "Put", Handler: _SyncChanges_Put_Handler, ClientStreams: true, }, { StreamName: "Search", Handler: _SyncChanges_Search_Handler, ServerStreams: true, }, }, Metadata: "cells-tree.proto", }
SyncChanges_ServiceDesc is the grpc.ServiceDesc for SyncChanges service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func DeregisterFileKeyManagerEnhancedServer ¶
func DeregisterFileKeyManagerEnhancedServer(s grpc.ServiceRegistrar, name string)
func DeregisterNodeChangesStreamerEnhancedServer ¶
func DeregisterNodeChangesStreamerEnhancedServer(s grpc.ServiceRegistrar, name string)
func DeregisterNodeContentReaderEnhancedServer ¶
func DeregisterNodeContentReaderEnhancedServer(s grpc.ServiceRegistrar, name string)
func DeregisterNodeContentWriterEnhancedServer ¶
func DeregisterNodeContentWriterEnhancedServer(s grpc.ServiceRegistrar, name string)
func DeregisterNodeEventsProviderEnhancedServer ¶
func DeregisterNodeEventsProviderEnhancedServer(s grpc.ServiceRegistrar, name string)
func DeregisterNodeProviderEnhancedServer ¶
func DeregisterNodeProviderEnhancedServer(s grpc.ServiceRegistrar, name string)
func DeregisterNodeProviderStreamerEnhancedServer ¶
func DeregisterNodeProviderStreamerEnhancedServer(s grpc.ServiceRegistrar, name string)
func DeregisterNodeReceiverEnhancedServer ¶
func DeregisterNodeReceiverEnhancedServer(s grpc.ServiceRegistrar, name string)
func DeregisterNodeReceiverStreamEnhancedServer ¶
func DeregisterNodeReceiverStreamEnhancedServer(s grpc.ServiceRegistrar, name string)
func DeregisterNodeVersionerEnhancedServer ¶
func DeregisterNodeVersionerEnhancedServer(s grpc.ServiceRegistrar, name string)
func DeregisterSearcherEnhancedServer ¶
func DeregisterSearcherEnhancedServer(s grpc.ServiceRegistrar, name string)
func DeregisterSessionIndexerEnhancedServer ¶
func DeregisterSessionIndexerEnhancedServer(s grpc.ServiceRegistrar, name string)
func DeregisterSyncChangesEnhancedServer ¶
func DeregisterSyncChangesEnhancedServer(s grpc.ServiceRegistrar, name string)
func IgnoreNodeForOutput ¶
IgnoreNodeForOutput checks wether a node shall be ignored for outputs sent to end user (typically websocket events, activities, etc)
func NewStreamerMock ¶
func PredefineError ¶
func PredefineError(f ErrorThrower)
func RegisterFileKeyManagerEnhancedServer ¶
func RegisterFileKeyManagerEnhancedServer(s grpc.ServiceRegistrar, srv NamedFileKeyManagerServer)
func RegisterFileKeyManagerServer ¶
func RegisterFileKeyManagerServer(s grpc.ServiceRegistrar, srv FileKeyManagerServer)
func RegisterNodeChangesStreamerEnhancedServer ¶
func RegisterNodeChangesStreamerEnhancedServer(s grpc.ServiceRegistrar, srv NamedNodeChangesStreamerServer)
func RegisterNodeChangesStreamerServer ¶
func RegisterNodeChangesStreamerServer(s grpc.ServiceRegistrar, srv NodeChangesStreamerServer)
func RegisterNodeContentReaderEnhancedServer ¶
func RegisterNodeContentReaderEnhancedServer(s grpc.ServiceRegistrar, srv NamedNodeContentReaderServer)
func RegisterNodeContentReaderServer ¶
func RegisterNodeContentReaderServer(s grpc.ServiceRegistrar, srv NodeContentReaderServer)
func RegisterNodeContentWriterEnhancedServer ¶
func RegisterNodeContentWriterEnhancedServer(s grpc.ServiceRegistrar, srv NamedNodeContentWriterServer)
func RegisterNodeContentWriterServer ¶
func RegisterNodeContentWriterServer(s grpc.ServiceRegistrar, srv NodeContentWriterServer)
func RegisterNodeEventsProviderEnhancedServer ¶
func RegisterNodeEventsProviderEnhancedServer(s grpc.ServiceRegistrar, srv NamedNodeEventsProviderServer)
func RegisterNodeEventsProviderServer ¶
func RegisterNodeEventsProviderServer(s grpc.ServiceRegistrar, srv NodeEventsProviderServer)
func RegisterNodeProviderEnhancedServer ¶
func RegisterNodeProviderEnhancedServer(s grpc.ServiceRegistrar, srv NamedNodeProviderServer)
func RegisterNodeProviderServer ¶
func RegisterNodeProviderServer(s grpc.ServiceRegistrar, srv NodeProviderServer)
func RegisterNodeProviderStreamerEnhancedServer ¶
func RegisterNodeProviderStreamerEnhancedServer(s grpc.ServiceRegistrar, srv NamedNodeProviderStreamerServer)
func RegisterNodeProviderStreamerServer ¶
func RegisterNodeProviderStreamerServer(s grpc.ServiceRegistrar, srv NodeProviderStreamerServer)
func RegisterNodeReceiverEnhancedServer ¶
func RegisterNodeReceiverEnhancedServer(s grpc.ServiceRegistrar, srv NamedNodeReceiverServer)
func RegisterNodeReceiverServer ¶
func RegisterNodeReceiverServer(s grpc.ServiceRegistrar, srv NodeReceiverServer)
func RegisterNodeReceiverStreamEnhancedServer ¶
func RegisterNodeReceiverStreamEnhancedServer(s grpc.ServiceRegistrar, srv NamedNodeReceiverStreamServer)
func RegisterNodeReceiverStreamServer ¶
func RegisterNodeReceiverStreamServer(s grpc.ServiceRegistrar, srv NodeReceiverStreamServer)
func RegisterNodeVersionerEnhancedServer ¶
func RegisterNodeVersionerEnhancedServer(s grpc.ServiceRegistrar, srv NamedNodeVersionerServer)
func RegisterNodeVersionerServer ¶
func RegisterNodeVersionerServer(s grpc.ServiceRegistrar, srv NodeVersionerServer)
func RegisterSearcherEnhancedServer ¶
func RegisterSearcherEnhancedServer(s grpc.ServiceRegistrar, srv NamedSearcherServer)
func RegisterSearcherServer ¶
func RegisterSearcherServer(s grpc.ServiceRegistrar, srv SearcherServer)
func RegisterSessionIndexerEnhancedServer ¶
func RegisterSessionIndexerEnhancedServer(s grpc.ServiceRegistrar, srv NamedSessionIndexerServer)
func RegisterSessionIndexerServer ¶
func RegisterSessionIndexerServer(s grpc.ServiceRegistrar, srv SessionIndexerServer)
func RegisterSyncChangesEnhancedServer ¶
func RegisterSyncChangesEnhancedServer(s grpc.ServiceRegistrar, srv NamedSyncChangesServer)
func RegisterSyncChangesServer ¶
func RegisterSyncChangesServer(s grpc.ServiceRegistrar, srv SyncChangesServer)
func ShouldError ¶
Types ¶
type ChangeLog ¶
type ChangeLog struct { // Unique commit ID Uuid string `protobuf:"bytes,1,opt,name=Uuid,proto3" json:"Uuid,omitempty"` // Human-readable description of what happened Description string `protobuf:"bytes,2,opt,name=Description,proto3" json:"Description,omitempty"` // Unix Timestamp MTime int64 `protobuf:"varint,3,opt,name=MTime,proto3" json:"MTime,omitempty"` // Content Size at that moment Size int64 `protobuf:"varint,4,opt,name=Size,proto3" json:"Size,omitempty"` // Arbitrary additional data Data []byte `protobuf:"bytes,5,opt,name=Data,proto3" json:"Data,omitempty"` // Who performed this action OwnerUuid string `protobuf:"bytes,6,opt,name=OwnerUuid,proto3" json:"OwnerUuid,omitempty"` // Event that triggered this change Event *NodeChangeEvent `protobuf:"bytes,7,opt,name=Event,proto3" json:"Event,omitempty"` // Actual location of the stored version Location *Node `protobuf:"bytes,8,opt,name=Location,proto3" json:"Location,omitempty"` // contains filtered or unexported fields }
func (*ChangeLog) Descriptor
deprecated
func (*ChangeLog) GetDescription ¶
func (*ChangeLog) GetEvent ¶
func (x *ChangeLog) GetEvent() *NodeChangeEvent
func (*ChangeLog) GetLocation ¶
func (*ChangeLog) GetOwnerUuid ¶
func (*ChangeLog) MarshalLogObject ¶
func (log *ChangeLog) MarshalLogObject(encoder zapcore.ObjectEncoder) error
MarshalLogObject implements custom marshalling for logs
func (*ChangeLog) ProtoMessage ¶
func (*ChangeLog) ProtoMessage()
func (*ChangeLog) ProtoReflect ¶
func (x *ChangeLog) ProtoReflect() protoreflect.Message
type CloseSessionRequest ¶
type CloseSessionRequest struct { Session *IndexationSession `protobuf:"bytes,1,opt,name=Session,proto3" json:"Session,omitempty"` // contains filtered or unexported fields }
func (*CloseSessionRequest) Descriptor
deprecated
func (*CloseSessionRequest) Descriptor() ([]byte, []int)
Deprecated: Use CloseSessionRequest.ProtoReflect.Descriptor instead.
func (*CloseSessionRequest) GetSession ¶
func (x *CloseSessionRequest) GetSession() *IndexationSession
func (*CloseSessionRequest) ProtoMessage ¶
func (*CloseSessionRequest) ProtoMessage()
func (*CloseSessionRequest) ProtoReflect ¶
func (x *CloseSessionRequest) ProtoReflect() protoreflect.Message
func (*CloseSessionRequest) Reset ¶
func (x *CloseSessionRequest) Reset()
func (*CloseSessionRequest) String ¶
func (x *CloseSessionRequest) String() string
func (*CloseSessionRequest) Validate ¶
func (this *CloseSessionRequest) Validate() error
type CloseSessionResponse ¶
type CloseSessionResponse struct { Session *IndexationSession `protobuf:"bytes,1,opt,name=Session,proto3" json:"Session,omitempty"` // contains filtered or unexported fields }
func (*CloseSessionResponse) Descriptor
deprecated
func (*CloseSessionResponse) Descriptor() ([]byte, []int)
Deprecated: Use CloseSessionResponse.ProtoReflect.Descriptor instead.
func (*CloseSessionResponse) GetSession ¶
func (x *CloseSessionResponse) GetSession() *IndexationSession
func (*CloseSessionResponse) ProtoMessage ¶
func (*CloseSessionResponse) ProtoMessage()
func (*CloseSessionResponse) ProtoReflect ¶
func (x *CloseSessionResponse) ProtoReflect() protoreflect.Message
func (*CloseSessionResponse) Reset ¶
func (x *CloseSessionResponse) Reset()
func (*CloseSessionResponse) String ¶
func (x *CloseSessionResponse) String() string
func (*CloseSessionResponse) Validate ¶
func (this *CloseSessionResponse) Validate() error
type CreateNodeRequest ¶
type CreateNodeRequest struct { Node *Node `protobuf:"bytes,1,opt,name=Node,proto3" json:"Node,omitempty"` UpdateIfExists bool `protobuf:"varint,2,opt,name=UpdateIfExists,proto3" json:"UpdateIfExists,omitempty"` IndexationSession string `protobuf:"bytes,3,opt,name=IndexationSession,proto3" json:"IndexationSession,omitempty"` Silent bool `protobuf:"varint,4,opt,name=Silent,proto3" json:"Silent,omitempty"` // contains filtered or unexported fields }
Request / Responses Messages
func (*CreateNodeRequest) Descriptor
deprecated
func (*CreateNodeRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateNodeRequest.ProtoReflect.Descriptor instead.
func (*CreateNodeRequest) GetIndexationSession ¶
func (x *CreateNodeRequest) GetIndexationSession() string
func (*CreateNodeRequest) GetNode ¶
func (x *CreateNodeRequest) GetNode() *Node
func (*CreateNodeRequest) GetSilent ¶
func (x *CreateNodeRequest) GetSilent() bool
func (*CreateNodeRequest) GetUpdateIfExists ¶
func (x *CreateNodeRequest) GetUpdateIfExists() bool
func (*CreateNodeRequest) ProtoMessage ¶
func (*CreateNodeRequest) ProtoMessage()
func (*CreateNodeRequest) ProtoReflect ¶
func (x *CreateNodeRequest) ProtoReflect() protoreflect.Message
func (*CreateNodeRequest) Reset ¶
func (x *CreateNodeRequest) Reset()
func (*CreateNodeRequest) String ¶
func (x *CreateNodeRequest) String() string
func (*CreateNodeRequest) Validate ¶
func (this *CreateNodeRequest) Validate() error
type CreateNodeResponse ¶
type CreateNodeResponse struct { Success bool `protobuf:"varint,1,opt,name=Success,proto3" json:"Success,omitempty"` Node *Node `protobuf:"bytes,2,opt,name=Node,proto3" json:"Node,omitempty"` // contains filtered or unexported fields }
func (*CreateNodeResponse) Descriptor
deprecated
func (*CreateNodeResponse) Descriptor() ([]byte, []int)
Deprecated: Use CreateNodeResponse.ProtoReflect.Descriptor instead.
func (*CreateNodeResponse) GetNode ¶
func (x *CreateNodeResponse) GetNode() *Node
func (*CreateNodeResponse) GetSuccess ¶
func (x *CreateNodeResponse) GetSuccess() bool
func (*CreateNodeResponse) ProtoMessage ¶
func (*CreateNodeResponse) ProtoMessage()
func (*CreateNodeResponse) ProtoReflect ¶
func (x *CreateNodeResponse) ProtoReflect() protoreflect.Message
func (*CreateNodeResponse) Reset ¶
func (x *CreateNodeResponse) Reset()
func (*CreateNodeResponse) String ¶
func (x *CreateNodeResponse) String() string
func (*CreateNodeResponse) Validate ¶
func (this *CreateNodeResponse) Validate() error
type CreateVersionRequest ¶
type CreateVersionRequest struct { Node *Node `protobuf:"bytes,1,opt,name=Node,proto3" json:"Node,omitempty"` TriggerEvent *NodeChangeEvent `protobuf:"bytes,2,opt,name=TriggerEvent,proto3" json:"TriggerEvent,omitempty"` // contains filtered or unexported fields }
func (*CreateVersionRequest) Descriptor
deprecated
func (*CreateVersionRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateVersionRequest.ProtoReflect.Descriptor instead.
func (*CreateVersionRequest) GetNode ¶
func (x *CreateVersionRequest) GetNode() *Node
func (*CreateVersionRequest) GetTriggerEvent ¶
func (x *CreateVersionRequest) GetTriggerEvent() *NodeChangeEvent
func (*CreateVersionRequest) ProtoMessage ¶
func (*CreateVersionRequest) ProtoMessage()
func (*CreateVersionRequest) ProtoReflect ¶
func (x *CreateVersionRequest) ProtoReflect() protoreflect.Message
func (*CreateVersionRequest) Reset ¶
func (x *CreateVersionRequest) Reset()
func (*CreateVersionRequest) String ¶
func (x *CreateVersionRequest) String() string
func (*CreateVersionRequest) Validate ¶
func (this *CreateVersionRequest) Validate() error
type CreateVersionResponse ¶
type CreateVersionResponse struct { Version *ChangeLog `protobuf:"bytes,1,opt,name=Version,proto3" json:"Version,omitempty"` // contains filtered or unexported fields }
func (*CreateVersionResponse) Descriptor
deprecated
func (*CreateVersionResponse) Descriptor() ([]byte, []int)
Deprecated: Use CreateVersionResponse.ProtoReflect.Descriptor instead.
func (*CreateVersionResponse) GetVersion ¶
func (x *CreateVersionResponse) GetVersion() *ChangeLog
func (*CreateVersionResponse) ProtoMessage ¶
func (*CreateVersionResponse) ProtoMessage()
func (*CreateVersionResponse) ProtoReflect ¶
func (x *CreateVersionResponse) ProtoReflect() protoreflect.Message
func (*CreateVersionResponse) Reset ¶
func (x *CreateVersionResponse) Reset()
func (*CreateVersionResponse) String ¶
func (x *CreateVersionResponse) String() string
func (*CreateVersionResponse) Validate ¶
func (this *CreateVersionResponse) Validate() error
type DeleteNodeRequest ¶
type DeleteNodeRequest struct { Node *Node `protobuf:"bytes,1,opt,name=Node,proto3" json:"Node,omitempty"` IndexationSession string `protobuf:"bytes,2,opt,name=IndexationSession,proto3" json:"IndexationSession,omitempty"` Silent bool `protobuf:"varint,3,opt,name=Silent,proto3" json:"Silent,omitempty"` // contains filtered or unexported fields }
func (*DeleteNodeRequest) Descriptor
deprecated
func (*DeleteNodeRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteNodeRequest.ProtoReflect.Descriptor instead.
func (*DeleteNodeRequest) GetIndexationSession ¶
func (x *DeleteNodeRequest) GetIndexationSession() string
func (*DeleteNodeRequest) GetNode ¶
func (x *DeleteNodeRequest) GetNode() *Node
func (*DeleteNodeRequest) GetSilent ¶
func (x *DeleteNodeRequest) GetSilent() bool
func (*DeleteNodeRequest) ProtoMessage ¶
func (*DeleteNodeRequest) ProtoMessage()
func (*DeleteNodeRequest) ProtoReflect ¶
func (x *DeleteNodeRequest) ProtoReflect() protoreflect.Message
func (*DeleteNodeRequest) Reset ¶
func (x *DeleteNodeRequest) Reset()
func (*DeleteNodeRequest) String ¶
func (x *DeleteNodeRequest) String() string
func (*DeleteNodeRequest) Validate ¶
func (this *DeleteNodeRequest) Validate() error
type DeleteNodeResponse ¶
type DeleteNodeResponse struct { Success bool `protobuf:"varint,1,opt,name=Success,proto3" json:"Success,omitempty"` // contains filtered or unexported fields }
func (*DeleteNodeResponse) Descriptor
deprecated
func (*DeleteNodeResponse) Descriptor() ([]byte, []int)
Deprecated: Use DeleteNodeResponse.ProtoReflect.Descriptor instead.
func (*DeleteNodeResponse) GetSuccess ¶
func (x *DeleteNodeResponse) GetSuccess() bool
func (*DeleteNodeResponse) ProtoMessage ¶
func (*DeleteNodeResponse) ProtoMessage()
func (*DeleteNodeResponse) ProtoReflect ¶
func (x *DeleteNodeResponse) ProtoReflect() protoreflect.Message
func (*DeleteNodeResponse) Reset ¶
func (x *DeleteNodeResponse) Reset()
func (*DeleteNodeResponse) String ¶
func (x *DeleteNodeResponse) String() string
func (*DeleteNodeResponse) Validate ¶
func (this *DeleteNodeResponse) Validate() error
type ErrorThrower ¶
type FileKeyManagerClient ¶
type FileKeyManagerClient interface {
GetEncryptionKey(ctx context.Context, in *GetEncryptionKeyRequest, opts ...grpc.CallOption) (*GetEncryptionKeyResponse, error)
}
FileKeyManagerClient is the client API for FileKeyManager 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 NewFileKeyManagerClient ¶
func NewFileKeyManagerClient(cc grpc.ClientConnInterface) FileKeyManagerClient
type FileKeyManagerEnhancedServer ¶
type FileKeyManagerEnhancedServer map[string]NamedFileKeyManagerServer
func (FileKeyManagerEnhancedServer) GetEncryptionKey ¶
func (m FileKeyManagerEnhancedServer) GetEncryptionKey(ctx context.Context, r *GetEncryptionKeyRequest) (*GetEncryptionKeyResponse, error)
type FileKeyManagerServer ¶
type FileKeyManagerServer interface { GetEncryptionKey(context.Context, *GetEncryptionKeyRequest) (*GetEncryptionKeyResponse, error) // contains filtered or unexported methods }
FileKeyManagerServer is the server API for FileKeyManager service. All implementations must embed UnimplementedFileKeyManagerServer for forward compatibility
type FileKeyManagerStub ¶
type FileKeyManagerStub struct {
FileKeyManagerServer
}
func (*FileKeyManagerStub) Invoke ¶
func (s *FileKeyManagerStub) Invoke(ctx context.Context, method string, args interface{}, reply interface{}, opts ...grpc.CallOption) error
func (*FileKeyManagerStub) NewStream ¶
func (s *FileKeyManagerStub) NewStream(ctx context.Context, desc *grpc.StreamDesc, method string, opts ...grpc.CallOption) (grpc.ClientStream, error)
type FlushSessionRequest ¶
type FlushSessionRequest struct { Session *IndexationSession `protobuf:"bytes,1,opt,name=Session,proto3" json:"Session,omitempty"` // contains filtered or unexported fields }
func (*FlushSessionRequest) Descriptor
deprecated
func (*FlushSessionRequest) Descriptor() ([]byte, []int)
Deprecated: Use FlushSessionRequest.ProtoReflect.Descriptor instead.
func (*FlushSessionRequest) GetSession ¶
func (x *FlushSessionRequest) GetSession() *IndexationSession
func (*FlushSessionRequest) ProtoMessage ¶
func (*FlushSessionRequest) ProtoMessage()
func (*FlushSessionRequest) ProtoReflect ¶
func (x *FlushSessionRequest) ProtoReflect() protoreflect.Message
func (*FlushSessionRequest) Reset ¶
func (x *FlushSessionRequest) Reset()
func (*FlushSessionRequest) String ¶
func (x *FlushSessionRequest) String() string
func (*FlushSessionRequest) Validate ¶
func (this *FlushSessionRequest) Validate() error
type FlushSessionResponse ¶
type FlushSessionResponse struct { Session *IndexationSession `protobuf:"bytes,1,opt,name=Session,proto3" json:"Session,omitempty"` // contains filtered or unexported fields }
func (*FlushSessionResponse) Descriptor
deprecated
func (*FlushSessionResponse) Descriptor() ([]byte, []int)
Deprecated: Use FlushSessionResponse.ProtoReflect.Descriptor instead.
func (*FlushSessionResponse) GetSession ¶
func (x *FlushSessionResponse) GetSession() *IndexationSession
func (*FlushSessionResponse) ProtoMessage ¶
func (*FlushSessionResponse) ProtoMessage()
func (*FlushSessionResponse) ProtoReflect ¶
func (x *FlushSessionResponse) ProtoReflect() protoreflect.Message
func (*FlushSessionResponse) Reset ¶
func (x *FlushSessionResponse) Reset()
func (*FlushSessionResponse) String ¶
func (x *FlushSessionResponse) String() string
func (*FlushSessionResponse) Validate ¶
func (this *FlushSessionResponse) Validate() error
type GeoPoint ¶
type GeoPoint struct { Lat float64 `protobuf:"fixed64,1,opt,name=Lat,proto3" json:"Lat,omitempty"` Lon float64 `protobuf:"fixed64,2,opt,name=Lon,proto3" json:"Lon,omitempty"` // contains filtered or unexported fields }
func (*GeoPoint) Descriptor
deprecated
func (*GeoPoint) ProtoMessage ¶
func (*GeoPoint) ProtoMessage()
func (*GeoPoint) ProtoReflect ¶
func (x *GeoPoint) ProtoReflect() protoreflect.Message
type GeoQuery ¶
type GeoQuery struct { // Either use a center point and a distance Center *GeoPoint `protobuf:"bytes,1,opt,name=Center,proto3" json:"Center,omitempty"` // Example formats supported: // "5in" "5inch" "7yd" "7yards" "9ft" "9feet" "11km" "11kilometers" // "3nm" "3nauticalmiles" "13mm" "13millimeters" "15cm" "15centimeters" // "17mi" "17miles" "19m" "19meters" // If the unit cannot be determined, the entire string is parsed and the // unit of meters is assumed. Distance string `protobuf:"bytes,2,opt,name=Distance,proto3" json:"Distance,omitempty"` // Or use a bounding box with TopLeft and BottomRight points TopLeft *GeoPoint `protobuf:"bytes,3,opt,name=TopLeft,proto3" json:"TopLeft,omitempty"` BottomRight *GeoPoint `protobuf:"bytes,4,opt,name=BottomRight,proto3" json:"BottomRight,omitempty"` // contains filtered or unexported fields }
func (*GeoQuery) Descriptor
deprecated
func (*GeoQuery) GetBottomRight ¶
func (*GeoQuery) GetDistance ¶
func (*GeoQuery) GetTopLeft ¶
func (*GeoQuery) ProtoMessage ¶
func (*GeoQuery) ProtoMessage()
func (*GeoQuery) ProtoReflect ¶
func (x *GeoQuery) ProtoReflect() protoreflect.Message
type GetEncryptionKeyRequest ¶
type GetEncryptionKeyRequest struct { User string `protobuf:"bytes,1,opt,name=User,proto3" json:"User,omitempty"` Password string `protobuf:"bytes,2,opt,name=Password,proto3" json:"Password,omitempty"` Node *Node `protobuf:"bytes,3,opt,name=Node,proto3" json:"Node,omitempty"` Create bool `protobuf:"varint,5,opt,name=Create,proto3" json:"Create,omitempty"` // contains filtered or unexported fields }
func (*GetEncryptionKeyRequest) Descriptor
deprecated
func (*GetEncryptionKeyRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetEncryptionKeyRequest.ProtoReflect.Descriptor instead.
func (*GetEncryptionKeyRequest) GetCreate ¶
func (x *GetEncryptionKeyRequest) GetCreate() bool
func (*GetEncryptionKeyRequest) GetNode ¶
func (x *GetEncryptionKeyRequest) GetNode() *Node
func (*GetEncryptionKeyRequest) GetPassword ¶
func (x *GetEncryptionKeyRequest) GetPassword() string
func (*GetEncryptionKeyRequest) GetUser ¶
func (x *GetEncryptionKeyRequest) GetUser() string
func (*GetEncryptionKeyRequest) ProtoMessage ¶
func (*GetEncryptionKeyRequest) ProtoMessage()
func (*GetEncryptionKeyRequest) ProtoReflect ¶
func (x *GetEncryptionKeyRequest) ProtoReflect() protoreflect.Message
func (*GetEncryptionKeyRequest) Reset ¶
func (x *GetEncryptionKeyRequest) Reset()
func (*GetEncryptionKeyRequest) String ¶
func (x *GetEncryptionKeyRequest) String() string
func (*GetEncryptionKeyRequest) Validate ¶
func (this *GetEncryptionKeyRequest) Validate() error
type GetEncryptionKeyResponse ¶
type GetEncryptionKeyResponse struct { Key []byte `protobuf:"bytes,1,opt,name=Key,proto3" json:"Key,omitempty"` // contains filtered or unexported fields }
func (*GetEncryptionKeyResponse) Descriptor
deprecated
func (*GetEncryptionKeyResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetEncryptionKeyResponse.ProtoReflect.Descriptor instead.
func (*GetEncryptionKeyResponse) GetKey ¶
func (x *GetEncryptionKeyResponse) GetKey() []byte
func (*GetEncryptionKeyResponse) ProtoMessage ¶
func (*GetEncryptionKeyResponse) ProtoMessage()
func (*GetEncryptionKeyResponse) ProtoReflect ¶
func (x *GetEncryptionKeyResponse) ProtoReflect() protoreflect.Message
func (*GetEncryptionKeyResponse) Reset ¶
func (x *GetEncryptionKeyResponse) Reset()
func (*GetEncryptionKeyResponse) String ¶
func (x *GetEncryptionKeyResponse) String() string
func (*GetEncryptionKeyResponse) Validate ¶
func (this *GetEncryptionKeyResponse) Validate() error
type HeadVersionRequest ¶
type HeadVersionRequest struct { Node *Node `protobuf:"bytes,1,opt,name=Node,proto3" json:"Node,omitempty"` VersionId string `protobuf:"bytes,2,opt,name=VersionId,proto3" json:"VersionId,omitempty"` // contains filtered or unexported fields }
func (*HeadVersionRequest) Descriptor
deprecated
func (*HeadVersionRequest) Descriptor() ([]byte, []int)
Deprecated: Use HeadVersionRequest.ProtoReflect.Descriptor instead.
func (*HeadVersionRequest) GetNode ¶
func (x *HeadVersionRequest) GetNode() *Node
func (*HeadVersionRequest) GetVersionId ¶
func (x *HeadVersionRequest) GetVersionId() string
func (*HeadVersionRequest) ProtoMessage ¶
func (*HeadVersionRequest) ProtoMessage()
func (*HeadVersionRequest) ProtoReflect ¶
func (x *HeadVersionRequest) ProtoReflect() protoreflect.Message
func (*HeadVersionRequest) Reset ¶
func (x *HeadVersionRequest) Reset()
func (*HeadVersionRequest) String ¶
func (x *HeadVersionRequest) String() string
func (*HeadVersionRequest) Validate ¶
func (this *HeadVersionRequest) Validate() error
type HeadVersionResponse ¶
type HeadVersionResponse struct { Version *ChangeLog `protobuf:"bytes,1,opt,name=Version,proto3" json:"Version,omitempty"` // contains filtered or unexported fields }
func (*HeadVersionResponse) Descriptor
deprecated
func (*HeadVersionResponse) Descriptor() ([]byte, []int)
Deprecated: Use HeadVersionResponse.ProtoReflect.Descriptor instead.
func (*HeadVersionResponse) GetVersion ¶
func (x *HeadVersionResponse) GetVersion() *ChangeLog
func (*HeadVersionResponse) ProtoMessage ¶
func (*HeadVersionResponse) ProtoMessage()
func (*HeadVersionResponse) ProtoReflect ¶
func (x *HeadVersionResponse) ProtoReflect() protoreflect.Message
func (*HeadVersionResponse) Reset ¶
func (x *HeadVersionResponse) Reset()
func (*HeadVersionResponse) String ¶
func (x *HeadVersionResponse) String() string
func (*HeadVersionResponse) Validate ¶
func (this *HeadVersionResponse) Validate() error
type IndexEvent ¶
type IndexEvent struct { ErrorDetected bool `protobuf:"varint,1,opt,name=ErrorDetected,proto3" json:"ErrorDetected,omitempty"` DataSourceName string `protobuf:"bytes,2,opt,name=DataSourceName,proto3" json:"DataSourceName,omitempty"` ErrorPath string `protobuf:"bytes,3,opt,name=ErrorPath,proto3" json:"ErrorPath,omitempty"` SessionForceClose string `protobuf:"bytes,4,opt,name=SessionForceClose,proto3" json:"SessionForceClose,omitempty"` // contains filtered or unexported fields }
func (*IndexEvent) Descriptor
deprecated
func (*IndexEvent) Descriptor() ([]byte, []int)
Deprecated: Use IndexEvent.ProtoReflect.Descriptor instead.
func (*IndexEvent) GetDataSourceName ¶
func (x *IndexEvent) GetDataSourceName() string
func (*IndexEvent) GetErrorDetected ¶
func (x *IndexEvent) GetErrorDetected() bool
func (*IndexEvent) GetErrorPath ¶
func (x *IndexEvent) GetErrorPath() string
func (*IndexEvent) GetSessionForceClose ¶
func (x *IndexEvent) GetSessionForceClose() string
func (*IndexEvent) ProtoMessage ¶
func (*IndexEvent) ProtoMessage()
func (*IndexEvent) ProtoReflect ¶
func (x *IndexEvent) ProtoReflect() protoreflect.Message
func (*IndexEvent) Reset ¶
func (x *IndexEvent) Reset()
func (*IndexEvent) String ¶
func (x *IndexEvent) String() string
func (*IndexEvent) Validate ¶
func (this *IndexEvent) Validate() error
type IndexableNode ¶
type IndexableNode struct { Node `bson:"inline"` ReloadCore bool `bson:"-"` ReloadNs bool `bson:"-"` ModifTime time.Time `bson:"modif_time"` Basename string `bson:"basename"` NodeType string `bson:"node_type"` Extension string `bson:"extension"` TextContent string `bson:"text_content,omitempty"` GeoPoint map[string]interface{} `bson:"-"` // Used by Bleve GeoJson *GeoJson `bson:"geo_json,omitempty"` // Used by Mongo Meta map[string]interface{} `bson:"meta"` }
func NewMemIndexableNode ¶
func NewMemIndexableNode(n *Node) *IndexableNode
func (*IndexableNode) BleveType ¶
func (i *IndexableNode) BleveType() string
func (*IndexableNode) IndexID ¶
func (i *IndexableNode) IndexID() string
IndexID implements IndexIDProvider interface
func (*IndexableNode) MemLoad ¶
func (i *IndexableNode) MemLoad()
type IndexationOperation ¶
type IndexationOperation struct { SessionUuid string `protobuf:"bytes,1,opt,name=SessionUuid,proto3" json:"SessionUuid,omitempty"` Description string `protobuf:"bytes,2,opt,name=Description,proto3" json:"Description,omitempty"` Cursor int64 `protobuf:"varint,3,opt,name=Cursor,proto3" json:"Cursor,omitempty"` // contains filtered or unexported fields }
func (*IndexationOperation) Descriptor
deprecated
func (*IndexationOperation) Descriptor() ([]byte, []int)
Deprecated: Use IndexationOperation.ProtoReflect.Descriptor instead.
func (*IndexationOperation) GetCursor ¶
func (x *IndexationOperation) GetCursor() int64
func (*IndexationOperation) GetDescription ¶
func (x *IndexationOperation) GetDescription() string
func (*IndexationOperation) GetSessionUuid ¶
func (x *IndexationOperation) GetSessionUuid() string
func (*IndexationOperation) ProtoMessage ¶
func (*IndexationOperation) ProtoMessage()
func (*IndexationOperation) ProtoReflect ¶
func (x *IndexationOperation) ProtoReflect() protoreflect.Message
func (*IndexationOperation) Reset ¶
func (x *IndexationOperation) Reset()
func (*IndexationOperation) String ¶
func (x *IndexationOperation) String() string
func (*IndexationOperation) Validate ¶
func (this *IndexationOperation) Validate() error
type IndexationSession ¶
type IndexationSession struct { Uuid string `protobuf:"bytes,1,opt,name=Uuid,proto3" json:"Uuid,omitempty"` Description string `protobuf:"bytes,2,opt,name=Description,proto3" json:"Description,omitempty"` RootNode *Node `protobuf:"bytes,3,opt,name=RootNode,proto3" json:"RootNode,omitempty"` ExpectedOperationsCount int64 `protobuf:"varint,4,opt,name=ExpectedOperationsCount,proto3" json:"ExpectedOperationsCount,omitempty"` CurrentOperationCount int64 `protobuf:"varint,5,opt,name=CurrentOperationCount,proto3" json:"CurrentOperationCount,omitempty"` Silent bool `protobuf:"varint,6,opt,name=Silent,proto3" json:"Silent,omitempty"` // contains filtered or unexported fields }
func (*IndexationSession) Descriptor
deprecated
func (*IndexationSession) Descriptor() ([]byte, []int)
Deprecated: Use IndexationSession.ProtoReflect.Descriptor instead.
func (*IndexationSession) GetCurrentOperationCount ¶
func (x *IndexationSession) GetCurrentOperationCount() int64
func (*IndexationSession) GetDescription ¶
func (x *IndexationSession) GetDescription() string
func (*IndexationSession) GetExpectedOperationsCount ¶
func (x *IndexationSession) GetExpectedOperationsCount() int64
func (*IndexationSession) GetRootNode ¶
func (x *IndexationSession) GetRootNode() *Node
func (*IndexationSession) GetSilent ¶
func (x *IndexationSession) GetSilent() bool
func (*IndexationSession) GetUuid ¶
func (x *IndexationSession) GetUuid() string
func (*IndexationSession) ProtoMessage ¶
func (*IndexationSession) ProtoMessage()
func (*IndexationSession) ProtoReflect ¶
func (x *IndexationSession) ProtoReflect() protoreflect.Message
func (*IndexationSession) Reset ¶
func (x *IndexationSession) Reset()
func (*IndexationSession) String ¶
func (x *IndexationSession) String() string
func (*IndexationSession) Validate ¶
func (this *IndexationSession) Validate() error
type ListNodesRequest ¶
type ListNodesRequest struct { // Main node used as a parent Node *Node `protobuf:"bytes,1,opt,name=Node,proto3" json:"Node,omitempty"` // Send back all children of the node Recursive bool `protobuf:"varint,2,opt,name=Recursive,proto3" json:"Recursive,omitempty"` // Send back a list of parent nodes, until the root, including the original node Ancestors bool `protobuf:"varint,3,opt,name=Ancestors,proto3" json:"Ancestors,omitempty"` // Sends the list of versions for a given node WithVersions bool `protobuf:"varint,7,opt,name=WithVersions,proto3" json:"WithVersions,omitempty"` // Limit the number of results Limit int64 `protobuf:"varint,4,opt,name=Limit,proto3" json:"Limit,omitempty"` // Start listing at a given position Offset int64 `protobuf:"varint,5,opt,name=Offset,proto3" json:"Offset,omitempty"` // Filter by node type (LEAF / COLLECTION) FilterType NodeType `protobuf:"varint,6,opt,name=FilterType,proto3,enum=tree.NodeType" json:"FilterType,omitempty"` // Generic Details Flags StatFlags []uint32 `protobuf:"varint,9,rep,packed,name=StatFlags,proto3" json:"StatFlags,omitempty"` // Sends the list of commits for a given node (Deprecated) WithCommits bool `protobuf:"varint,8,opt,name=WithCommits,proto3" json:"WithCommits,omitempty"` // contains filtered or unexported fields }
func (*ListNodesRequest) Descriptor
deprecated
func (*ListNodesRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListNodesRequest.ProtoReflect.Descriptor instead.
func (*ListNodesRequest) GetAncestors ¶
func (x *ListNodesRequest) GetAncestors() bool
func (*ListNodesRequest) GetFilterType ¶
func (x *ListNodesRequest) GetFilterType() NodeType
func (*ListNodesRequest) GetLimit ¶
func (x *ListNodesRequest) GetLimit() int64
func (*ListNodesRequest) GetNode ¶
func (x *ListNodesRequest) GetNode() *Node
func (*ListNodesRequest) GetOffset ¶
func (x *ListNodesRequest) GetOffset() int64
func (*ListNodesRequest) GetRecursive ¶
func (x *ListNodesRequest) GetRecursive() bool
func (*ListNodesRequest) GetStatFlags ¶ added in v4.0.1
func (x *ListNodesRequest) GetStatFlags() []uint32
func (*ListNodesRequest) GetWithCommits ¶
func (x *ListNodesRequest) GetWithCommits() bool
func (*ListNodesRequest) GetWithVersions ¶
func (x *ListNodesRequest) GetWithVersions() bool
func (*ListNodesRequest) ProtoMessage ¶
func (*ListNodesRequest) ProtoMessage()
func (*ListNodesRequest) ProtoReflect ¶
func (x *ListNodesRequest) ProtoReflect() protoreflect.Message
func (*ListNodesRequest) Reset ¶
func (x *ListNodesRequest) Reset()
func (*ListNodesRequest) String ¶
func (x *ListNodesRequest) String() string
func (*ListNodesRequest) Validate ¶
func (this *ListNodesRequest) Validate() error
type ListNodesResponse ¶
type ListNodesResponse struct { Node *Node `protobuf:"bytes,1,opt,name=Node,proto3" json:"Node,omitempty"` // contains filtered or unexported fields }
func (*ListNodesResponse) Descriptor
deprecated
func (*ListNodesResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListNodesResponse.ProtoReflect.Descriptor instead.
func (*ListNodesResponse) GetNode ¶
func (x *ListNodesResponse) GetNode() *Node
func (*ListNodesResponse) ProtoMessage ¶
func (*ListNodesResponse) ProtoMessage()
func (*ListNodesResponse) ProtoReflect ¶
func (x *ListNodesResponse) ProtoReflect() protoreflect.Message
func (*ListNodesResponse) Reset ¶
func (x *ListNodesResponse) Reset()
func (*ListNodesResponse) String ¶
func (x *ListNodesResponse) String() string
func (*ListNodesResponse) Validate ¶
func (this *ListNodesResponse) Validate() error
type ListVersionsRequest ¶
type ListVersionsRequest struct { Node *Node `protobuf:"bytes,1,opt,name=Node,proto3" json:"Node,omitempty"` // contains filtered or unexported fields }
func (*ListVersionsRequest) Descriptor
deprecated
func (*ListVersionsRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListVersionsRequest.ProtoReflect.Descriptor instead.
func (*ListVersionsRequest) GetNode ¶
func (x *ListVersionsRequest) GetNode() *Node
func (*ListVersionsRequest) ProtoMessage ¶
func (*ListVersionsRequest) ProtoMessage()
func (*ListVersionsRequest) ProtoReflect ¶
func (x *ListVersionsRequest) ProtoReflect() protoreflect.Message
func (*ListVersionsRequest) Reset ¶
func (x *ListVersionsRequest) Reset()
func (*ListVersionsRequest) String ¶
func (x *ListVersionsRequest) String() string
func (*ListVersionsRequest) Validate ¶
func (this *ListVersionsRequest) Validate() error
type ListVersionsResponse ¶
type ListVersionsResponse struct { Version *ChangeLog `protobuf:"bytes,1,opt,name=Version,proto3" json:"Version,omitempty"` // contains filtered or unexported fields }
func (*ListVersionsResponse) Descriptor
deprecated
func (*ListVersionsResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListVersionsResponse.ProtoReflect.Descriptor instead.
func (*ListVersionsResponse) GetVersion ¶
func (x *ListVersionsResponse) GetVersion() *ChangeLog
func (*ListVersionsResponse) ProtoMessage ¶
func (*ListVersionsResponse) ProtoMessage()
func (*ListVersionsResponse) ProtoReflect ¶
func (x *ListVersionsResponse) ProtoReflect() protoreflect.Message
func (*ListVersionsResponse) Reset ¶
func (x *ListVersionsResponse) Reset()
func (*ListVersionsResponse) String ¶
func (x *ListVersionsResponse) String() string
func (*ListVersionsResponse) Validate ¶
func (this *ListVersionsResponse) Validate() error
type MetaFilter ¶
type MetaFilter struct {
// contains filtered or unexported fields
}
MetaFilter holds specific filtering conditions, generally transformed from standard search queries to basic Listing options.
func NewMetaFilter ¶
func NewMetaFilter(node *Node) *MetaFilter
NewMetaFilter creates a meta filter looking for request node metadata specific keys.
func (*MetaFilter) HasSQLFilters ¶ added in v4.0.1
func (m *MetaFilter) HasSQLFilters() bool
HasSQLFilters returns true if MetaFilter has one of grep (unless forced), negativeGrep, filterType or int comparators set.
func (*MetaFilter) LimitDepth ¶
func (m *MetaFilter) LimitDepth() int
LimitDepth returns an optional depth limitation.
func (*MetaFilter) Match ¶
func (m *MetaFilter) Match(name string, n *Node) bool
Match checks node results against conditions.
func (*MetaFilter) MatchForceGrep ¶ added in v4.0.1
func (m *MetaFilter) MatchForceGrep(name string) bool
MatchForceGrep applies if a meta specifically told to use grep filtering instead of SQL.
func (*MetaFilter) ParseType ¶ added in v4.0.1
func (m *MetaFilter) ParseType(t NodeType)
ParseType register a node filter type
func (*MetaFilter) Where ¶ added in v4.0.1
func (m *MetaFilter) Where() (where string, args []interface{})
Where transforms registered conditions into a set of SQL statement (joined by AND).
type NamedFileKeyManagerServer ¶
type NamedFileKeyManagerServer interface { FileKeyManagerServer Name() string }
type NamedNodeChangesStreamerServer ¶
type NamedNodeChangesStreamerServer interface { NodeChangesStreamerServer Name() string }
type NamedNodeContentReaderServer ¶
type NamedNodeContentReaderServer interface { NodeContentReaderServer Name() string }
type NamedNodeContentWriterServer ¶
type NamedNodeContentWriterServer interface { NodeContentWriterServer Name() string }
type NamedNodeEventsProviderServer ¶
type NamedNodeEventsProviderServer interface { NodeEventsProviderServer Name() string }
type NamedNodeProviderServer ¶
type NamedNodeProviderServer interface { NodeProviderServer Name() string }
type NamedNodeProviderStreamerServer ¶
type NamedNodeProviderStreamerServer interface { NodeProviderStreamerServer Name() string }
type NamedNodeReceiverServer ¶
type NamedNodeReceiverServer interface { NodeReceiverServer Name() string }
type NamedNodeReceiverStreamServer ¶
type NamedNodeReceiverStreamServer interface { NodeReceiverStreamServer Name() string }
type NamedNodeVersionerServer ¶
type NamedNodeVersionerServer interface { NodeVersionerServer Name() string }
type NamedSearcherServer ¶
type NamedSearcherServer interface { SearcherServer Name() string }
type NamedSessionIndexerServer ¶
type NamedSessionIndexerServer interface { SessionIndexerServer Name() string }
type NamedSyncChangesServer ¶
type NamedSyncChangesServer interface { SyncChangesServer Name() string }
type Node ¶
type Node struct { // ------------------------------------ // Core identification of the node // ------------------------------------ Uuid string `protobuf:"bytes,1,opt,name=Uuid,proto3" json:"Uuid,omitempty"` Path string `protobuf:"bytes,2,opt,name=Path,proto3" json:"Path,omitempty"` Type NodeType `protobuf:"varint,3,opt,name=Type,proto3,enum=tree.NodeType" json:"Type,omitempty"` // Size of the file, or cumulated size of folder Size int64 `protobuf:"varint,4,opt,name=Size,proto3" json:"Size,omitempty"` // Last modification Timestamp MTime int64 `protobuf:"varint,5,opt,name=MTime,proto3" json:"MTime,omitempty"` // Permission mode, like 0777 Mode int32 `protobuf:"varint,6,opt,name=Mode,proto3" json:"Mode,omitempty"` // Hash of the content if node is a LEAF, Uuid or Etag string `protobuf:"bytes,7,opt,name=Etag,proto3" json:"Etag,omitempty"` // List of successive commits Commits []*ChangeLog `protobuf:"bytes,9,rep,name=Commits,proto3" json:"Commits,omitempty"` // ------------------------------------ // Then a free K => V representation of any kind of metadata // ------------------------------------ MetaStore map[string]string `` /* 159-byte string literal not displayed */ // Can be used for output when node is appearing in multiple workspaces AppearsIn []*WorkspaceRelativePath `protobuf:"bytes,10,rep,name=AppearsIn,proto3" json:"AppearsIn,omitempty"` // contains filtered or unexported fields }
func (*Node) AllMetaDeserialized ¶
AllMetaDeserialized unmarshall all defined metadata to JSON objects, skipping reserved meta (e.g. meta that have a key prefixed by "pydio:")
func (*Node) Descriptor
deprecated
func (*Node) GetAppearsIn ¶
func (x *Node) GetAppearsIn() []*WorkspaceRelativePath
func (*Node) GetCommits ¶
func (*Node) GetMetaBool ¶
GetMetaBool looks for a meta to be present and bool value. Returns false is meta is not set.
func (*Node) GetMetaStore ¶
func (*Node) GetModTime ¶
GetModTime returns the last modification timestamp
func (*Node) GetStringMeta ¶
GetStringMeta easily returns the string value of the MetaData for this key or an empty string if the MetaData for this key is not defined
func (*Node) HasMetaKey ¶
HasMetaKey checks if a metaData with this key has been defined
func (*Node) IsLeafInt ¶
IsLeafInt checks if node is of type NodeType_LEAF or NodeType_COLLECTION, return as 0/1 integer (for storing)
func (*Node) LegacyMeta ¶
LegacyMeta enrich metadata store for this node adding info for some legacy keys
func (*Node) MarshalLogObject ¶
func (node *Node) MarshalLogObject(encoder zapcore.ObjectEncoder) error
LOGGING SUPPORT
MarshalLogObject implements custom marshalling for logs
func (*Node) MustSetMeta ¶
MustSetMeta sets a metadata by marshalling to JSON. It does not return error but panics instead.
func (*Node) ProtoMessage ¶
func (*Node) ProtoMessage()
func (*Node) ProtoReflect ¶
func (x *Node) ProtoReflect() protoreflect.Message
func (*Node) RenewUuidIfEmpty ¶
RenewUuidIfEmpty generates a new UUID if it is currently empty or force is set to true
func (*Node) WithoutReservedMetas ¶
WithoutReservedMetas returns a copy of this node, after removing all reserved meta
func (*Node) Zap ¶
Zap simply returns a zapcore.Field object populated with this node and with a standard key
func (*Node) ZapPath ¶
ZapPath simply calls zap.String() with NodePath standard key and this node path
type NodeChangeEvent ¶
type NodeChangeEvent struct { Type NodeChangeEvent_EventType `protobuf:"varint,1,opt,name=Type,proto3,enum=tree.NodeChangeEvent_EventType" json:"Type,omitempty"` Source *Node `protobuf:"bytes,2,opt,name=Source,proto3" json:"Source,omitempty"` Target *Node `protobuf:"bytes,3,opt,name=Target,proto3" json:"Target,omitempty"` Metadata map[string]string `` /* 157-byte string literal not displayed */ Silent bool `protobuf:"varint,4,opt,name=Silent,proto3" json:"Silent,omitempty"` Optimistic bool `protobuf:"varint,5,opt,name=Optimistic,proto3" json:"Optimistic,omitempty"` // contains filtered or unexported fields }
func (*NodeChangeEvent) Descriptor
deprecated
func (*NodeChangeEvent) Descriptor() ([]byte, []int)
Deprecated: Use NodeChangeEvent.ProtoReflect.Descriptor instead.
func (*NodeChangeEvent) GetMetadata ¶
func (x *NodeChangeEvent) GetMetadata() map[string]string
func (*NodeChangeEvent) GetOptimistic ¶
func (x *NodeChangeEvent) GetOptimistic() bool
func (*NodeChangeEvent) GetSilent ¶
func (x *NodeChangeEvent) GetSilent() bool
func (*NodeChangeEvent) GetSource ¶
func (x *NodeChangeEvent) GetSource() *Node
func (*NodeChangeEvent) GetTarget ¶
func (x *NodeChangeEvent) GetTarget() *Node
func (*NodeChangeEvent) GetType ¶
func (x *NodeChangeEvent) GetType() NodeChangeEvent_EventType
func (*NodeChangeEvent) ProtoMessage ¶
func (*NodeChangeEvent) ProtoMessage()
func (*NodeChangeEvent) ProtoReflect ¶
func (x *NodeChangeEvent) ProtoReflect() protoreflect.Message
func (*NodeChangeEvent) Reset ¶
func (x *NodeChangeEvent) Reset()
func (*NodeChangeEvent) String ¶
func (x *NodeChangeEvent) String() string
func (*NodeChangeEvent) Validate ¶
func (this *NodeChangeEvent) Validate() error
func (*NodeChangeEvent) Zap ¶
func (msg *NodeChangeEvent) Zap() zapcore.Field
Zap simply returns a zapcore.Field object populated with this NodeChangeEvent under a standard key
type NodeChangeEvent_EventType ¶
type NodeChangeEvent_EventType int32
const ( NodeChangeEvent_CREATE NodeChangeEvent_EventType = 0 NodeChangeEvent_READ NodeChangeEvent_EventType = 1 NodeChangeEvent_UPDATE_PATH NodeChangeEvent_EventType = 2 NodeChangeEvent_UPDATE_CONTENT NodeChangeEvent_EventType = 3 NodeChangeEvent_UPDATE_META NodeChangeEvent_EventType = 4 NodeChangeEvent_UPDATE_USER_META NodeChangeEvent_EventType = 6 NodeChangeEvent_DELETE NodeChangeEvent_EventType = 5 )
func (NodeChangeEvent_EventType) Descriptor ¶
func (NodeChangeEvent_EventType) Descriptor() protoreflect.EnumDescriptor
func (NodeChangeEvent_EventType) Enum ¶
func (x NodeChangeEvent_EventType) Enum() *NodeChangeEvent_EventType
func (NodeChangeEvent_EventType) EnumDescriptor
deprecated
func (NodeChangeEvent_EventType) EnumDescriptor() ([]byte, []int)
Deprecated: Use NodeChangeEvent_EventType.Descriptor instead.
func (NodeChangeEvent_EventType) Number ¶
func (x NodeChangeEvent_EventType) Number() protoreflect.EnumNumber
func (NodeChangeEvent_EventType) String ¶
func (x NodeChangeEvent_EventType) String() string
func (NodeChangeEvent_EventType) Type ¶
func (NodeChangeEvent_EventType) Type() protoreflect.EnumType
type NodeChangesStreamerClient ¶
type NodeChangesStreamerClient interface {
StreamChanges(ctx context.Context, in *StreamChangesRequest, opts ...grpc.CallOption) (NodeChangesStreamer_StreamChangesClient, error)
}
NodeChangesStreamerClient is the client API for NodeChangesStreamer 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 NewNodeChangesStreamerClient ¶
func NewNodeChangesStreamerClient(cc grpc.ClientConnInterface) NodeChangesStreamerClient
type NodeChangesStreamerEnhancedServer ¶
type NodeChangesStreamerEnhancedServer map[string]NamedNodeChangesStreamerServer
func (NodeChangesStreamerEnhancedServer) StreamChanges ¶
func (m NodeChangesStreamerEnhancedServer) StreamChanges(r *StreamChangesRequest, s NodeChangesStreamer_StreamChangesServer) error
type NodeChangesStreamerServer ¶
type NodeChangesStreamerServer interface { StreamChanges(*StreamChangesRequest, NodeChangesStreamer_StreamChangesServer) error // contains filtered or unexported methods }
NodeChangesStreamerServer is the server API for NodeChangesStreamer service. All implementations must embed UnimplementedNodeChangesStreamerServer for forward compatibility
type NodeChangesStreamerStub ¶
type NodeChangesStreamerStub struct {
NodeChangesStreamerServer
}
func (*NodeChangesStreamerStub) Invoke ¶
func (s *NodeChangesStreamerStub) Invoke(ctx context.Context, method string, args interface{}, reply interface{}, opts ...grpc.CallOption) error
func (*NodeChangesStreamerStub) NewStream ¶
func (s *NodeChangesStreamerStub) NewStream(ctx context.Context, desc *grpc.StreamDesc, method string, opts ...grpc.CallOption) (grpc.ClientStream, error)
type NodeChangesStreamerStub_StreamChangesStreamer ¶
type NodeChangesStreamerStub_StreamChangesStreamer struct {
stubs.ClientServerStreamerCore
}
func (*NodeChangesStreamerStub_StreamChangesStreamer) Send ¶
func (s *NodeChangesStreamerStub_StreamChangesStreamer) Send(response *NodeChangeEvent) error
type NodeChangesStreamer_StreamChangesClient ¶
type NodeChangesStreamer_StreamChangesClient interface { Recv() (*NodeChangeEvent, error) grpc.ClientStream }
type NodeChangesStreamer_StreamChangesServer ¶
type NodeChangesStreamer_StreamChangesServer interface { Send(*NodeChangeEvent) error grpc.ServerStream }
type NodeContentReaderClient ¶
type NodeContentReaderClient interface { }
NodeContentReaderClient is the client API for NodeContentReader 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 NewNodeContentReaderClient ¶
func NewNodeContentReaderClient(cc grpc.ClientConnInterface) NodeContentReaderClient
type NodeContentReaderEnhancedServer ¶
type NodeContentReaderEnhancedServer map[string]NamedNodeContentReaderServer
type NodeContentReaderServer ¶
type NodeContentReaderServer interface {
// contains filtered or unexported methods
}
NodeContentReaderServer is the server API for NodeContentReader service. All implementations must embed UnimplementedNodeContentReaderServer for forward compatibility
type NodeContentReaderStub ¶
type NodeContentReaderStub struct {
NodeContentReaderServer
}
func (*NodeContentReaderStub) Invoke ¶
func (s *NodeContentReaderStub) Invoke(ctx context.Context, method string, args interface{}, reply interface{}, opts ...grpc.CallOption) error
func (*NodeContentReaderStub) NewStream ¶
func (s *NodeContentReaderStub) NewStream(ctx context.Context, desc *grpc.StreamDesc, method string, opts ...grpc.CallOption) (grpc.ClientStream, error)
type NodeContentWriterClient ¶
type NodeContentWriterClient interface { }
NodeContentWriterClient is the client API for NodeContentWriter 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 NewNodeContentWriterClient ¶
func NewNodeContentWriterClient(cc grpc.ClientConnInterface) NodeContentWriterClient
type NodeContentWriterEnhancedServer ¶
type NodeContentWriterEnhancedServer map[string]NamedNodeContentWriterServer
type NodeContentWriterServer ¶
type NodeContentWriterServer interface {
// contains filtered or unexported methods
}
NodeContentWriterServer is the server API for NodeContentWriter service. All implementations must embed UnimplementedNodeContentWriterServer for forward compatibility
type NodeContentWriterStub ¶
type NodeContentWriterStub struct {
NodeContentWriterServer
}
func (*NodeContentWriterStub) Invoke ¶
func (s *NodeContentWriterStub) Invoke(ctx context.Context, method string, args interface{}, reply interface{}, opts ...grpc.CallOption) error
func (*NodeContentWriterStub) NewStream ¶
func (s *NodeContentWriterStub) NewStream(ctx context.Context, desc *grpc.StreamDesc, method string, opts ...grpc.CallOption) (grpc.ClientStream, error)
type NodeEventsProviderClient ¶
type NodeEventsProviderClient interface {
WatchNode(ctx context.Context, in *WatchNodeRequest, opts ...grpc.CallOption) (NodeEventsProvider_WatchNodeClient, error)
}
NodeEventsProviderClient is the client API for NodeEventsProvider 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 NewNodeEventsProviderClient ¶
func NewNodeEventsProviderClient(cc grpc.ClientConnInterface) NodeEventsProviderClient
type NodeEventsProviderEnhancedServer ¶
type NodeEventsProviderEnhancedServer map[string]NamedNodeEventsProviderServer
func (NodeEventsProviderEnhancedServer) WatchNode ¶
func (m NodeEventsProviderEnhancedServer) WatchNode(r *WatchNodeRequest, s NodeEventsProvider_WatchNodeServer) error
type NodeEventsProviderServer ¶
type NodeEventsProviderServer interface { WatchNode(*WatchNodeRequest, NodeEventsProvider_WatchNodeServer) error // contains filtered or unexported methods }
NodeEventsProviderServer is the server API for NodeEventsProvider service. All implementations must embed UnimplementedNodeEventsProviderServer for forward compatibility
type NodeEventsProviderStub ¶
type NodeEventsProviderStub struct {
NodeEventsProviderServer
}
func (*NodeEventsProviderStub) Invoke ¶
func (s *NodeEventsProviderStub) Invoke(ctx context.Context, method string, args interface{}, reply interface{}, opts ...grpc.CallOption) error
func (*NodeEventsProviderStub) NewStream ¶
func (s *NodeEventsProviderStub) NewStream(ctx context.Context, desc *grpc.StreamDesc, method string, opts ...grpc.CallOption) (grpc.ClientStream, error)
type NodeEventsProviderStub_WatchNodeStreamer ¶
type NodeEventsProviderStub_WatchNodeStreamer struct {
stubs.ClientServerStreamerCore
}
func (*NodeEventsProviderStub_WatchNodeStreamer) Send ¶
func (s *NodeEventsProviderStub_WatchNodeStreamer) Send(response *WatchNodeResponse) error
type NodeEventsProvider_WatchNodeClient ¶
type NodeEventsProvider_WatchNodeClient interface { Recv() (*WatchNodeResponse, error) grpc.ClientStream }
type NodeEventsProvider_WatchNodeServer ¶
type NodeEventsProvider_WatchNodeServer interface { Send(*WatchNodeResponse) error grpc.ServerStream }
type NodeProviderClient ¶
type NodeProviderClient interface { ReadNode(ctx context.Context, in *ReadNodeRequest, opts ...grpc.CallOption) (*ReadNodeResponse, error) ListNodes(ctx context.Context, in *ListNodesRequest, opts ...grpc.CallOption) (NodeProvider_ListNodesClient, error) }
NodeProviderClient is the client API for NodeProvider 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 NewNodeProviderClient ¶
func NewNodeProviderClient(cc grpc.ClientConnInterface) NodeProviderClient
type NodeProviderEnhancedServer ¶
type NodeProviderEnhancedServer map[string]NamedNodeProviderServer
func (NodeProviderEnhancedServer) ListNodes ¶
func (m NodeProviderEnhancedServer) ListNodes(r *ListNodesRequest, s NodeProvider_ListNodesServer) error
func (NodeProviderEnhancedServer) ReadNode ¶
func (m NodeProviderEnhancedServer) ReadNode(ctx context.Context, r *ReadNodeRequest) (*ReadNodeResponse, error)
type NodeProviderMock ¶
func NewNodeProviderMock ¶
func NewNodeProviderMock(n map[string]Node) *NodeProviderMock
func (*NodeProviderMock) ListNodes ¶
func (m *NodeProviderMock) ListNodes(ctx context.Context, in *ListNodesRequest, opts ...grpc.CallOption) (NodeProvider_ListNodesClient, error)
func (*NodeProviderMock) ReadNode ¶
func (m *NodeProviderMock) ReadNode(ctx context.Context, in *ReadNodeRequest, opts ...grpc.CallOption) (*ReadNodeResponse, error)
type NodeProviderServer ¶
type NodeProviderServer interface { ReadNode(context.Context, *ReadNodeRequest) (*ReadNodeResponse, error) ListNodes(*ListNodesRequest, NodeProvider_ListNodesServer) error // contains filtered or unexported methods }
NodeProviderServer is the server API for NodeProvider service. All implementations must embed UnimplementedNodeProviderServer for forward compatibility
type NodeProviderStreamerClient ¶
type NodeProviderStreamerClient interface {
ReadNodeStream(ctx context.Context, opts ...grpc.CallOption) (NodeProviderStreamer_ReadNodeStreamClient, error)
}
NodeProviderStreamerClient is the client API for NodeProviderStreamer 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 NewNodeProviderStreamerClient ¶
func NewNodeProviderStreamerClient(cc grpc.ClientConnInterface) NodeProviderStreamerClient
type NodeProviderStreamerEnhancedServer ¶
type NodeProviderStreamerEnhancedServer map[string]NamedNodeProviderStreamerServer
func (NodeProviderStreamerEnhancedServer) ReadNodeStream ¶
func (m NodeProviderStreamerEnhancedServer) ReadNodeStream(s NodeProviderStreamer_ReadNodeStreamServer) error
type NodeProviderStreamerServer ¶
type NodeProviderStreamerServer interface { ReadNodeStream(NodeProviderStreamer_ReadNodeStreamServer) error // contains filtered or unexported methods }
NodeProviderStreamerServer is the server API for NodeProviderStreamer service. All implementations must embed UnimplementedNodeProviderStreamerServer for forward compatibility
type NodeProviderStreamerStub ¶
type NodeProviderStreamerStub struct {
NodeProviderStreamerServer
}
func (*NodeProviderStreamerStub) Invoke ¶
func (s *NodeProviderStreamerStub) Invoke(ctx context.Context, method string, args interface{}, reply interface{}, opts ...grpc.CallOption) error
func (*NodeProviderStreamerStub) NewStream ¶
func (s *NodeProviderStreamerStub) NewStream(ctx context.Context, desc *grpc.StreamDesc, method string, opts ...grpc.CallOption) (grpc.ClientStream, error)
type NodeProviderStreamerStub_ReadNodeStreamStreamer ¶
type NodeProviderStreamerStub_ReadNodeStreamStreamer struct {
stubs.BidirServerStreamerCore
}
func (*NodeProviderStreamerStub_ReadNodeStreamStreamer) Recv ¶
func (s *NodeProviderStreamerStub_ReadNodeStreamStreamer) Recv() (*ReadNodeRequest, error)
func (*NodeProviderStreamerStub_ReadNodeStreamStreamer) Send ¶
func (s *NodeProviderStreamerStub_ReadNodeStreamStreamer) Send(response *ReadNodeResponse) error
type NodeProviderStreamer_ReadNodeStreamClient ¶
type NodeProviderStreamer_ReadNodeStreamClient interface { Send(*ReadNodeRequest) error Recv() (*ReadNodeResponse, error) grpc.ClientStream }
type NodeProviderStreamer_ReadNodeStreamServer ¶
type NodeProviderStreamer_ReadNodeStreamServer interface { Send(*ReadNodeResponse) error Recv() (*ReadNodeRequest, error) grpc.ServerStream }
type NodeProviderStub ¶
type NodeProviderStub struct {
NodeProviderServer
}
func (*NodeProviderStub) Invoke ¶
func (s *NodeProviderStub) Invoke(ctx context.Context, method string, args interface{}, reply interface{}, opts ...grpc.CallOption) error
func (*NodeProviderStub) NewStream ¶
func (s *NodeProviderStub) NewStream(ctx context.Context, desc *grpc.StreamDesc, method string, opts ...grpc.CallOption) (grpc.ClientStream, error)
type NodeProviderStub_ListNodesStreamer ¶
type NodeProviderStub_ListNodesStreamer struct {
stubs.ClientServerStreamerCore
}
func (*NodeProviderStub_ListNodesStreamer) Send ¶
func (s *NodeProviderStub_ListNodesStreamer) Send(response *ListNodesResponse) error
type NodeProvider_ListNodesClient ¶
type NodeProvider_ListNodesClient interface { Recv() (*ListNodesResponse, error) grpc.ClientStream }
type NodeProvider_ListNodesServer ¶
type NodeProvider_ListNodesServer interface { Send(*ListNodesResponse) error grpc.ServerStream }
type NodeReceiverClient ¶
type NodeReceiverClient interface { CreateNode(ctx context.Context, in *CreateNodeRequest, opts ...grpc.CallOption) (*CreateNodeResponse, error) UpdateNode(ctx context.Context, in *UpdateNodeRequest, opts ...grpc.CallOption) (*UpdateNodeResponse, error) DeleteNode(ctx context.Context, in *DeleteNodeRequest, opts ...grpc.CallOption) (*DeleteNodeResponse, error) }
NodeReceiverClient is the client API for NodeReceiver 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 NewNodeReceiverClient ¶
func NewNodeReceiverClient(cc grpc.ClientConnInterface) NodeReceiverClient
type NodeReceiverEnhancedServer ¶
type NodeReceiverEnhancedServer map[string]NamedNodeReceiverServer
func (NodeReceiverEnhancedServer) CreateNode ¶
func (m NodeReceiverEnhancedServer) CreateNode(ctx context.Context, r *CreateNodeRequest) (*CreateNodeResponse, error)
func (NodeReceiverEnhancedServer) DeleteNode ¶
func (m NodeReceiverEnhancedServer) DeleteNode(ctx context.Context, r *DeleteNodeRequest) (*DeleteNodeResponse, error)
func (NodeReceiverEnhancedServer) UpdateNode ¶
func (m NodeReceiverEnhancedServer) UpdateNode(ctx context.Context, r *UpdateNodeRequest) (*UpdateNodeResponse, error)
type NodeReceiverMock ¶
func (*NodeReceiverMock) CreateNode ¶
func (m *NodeReceiverMock) CreateNode(ctx context.Context, in *CreateNodeRequest, opts ...grpc.CallOption) (*CreateNodeResponse, error)
func (*NodeReceiverMock) DeleteNode ¶
func (m *NodeReceiverMock) DeleteNode(ctx context.Context, in *DeleteNodeRequest, opts ...grpc.CallOption) (*DeleteNodeResponse, error)
func (*NodeReceiverMock) UpdateNode ¶
func (m *NodeReceiverMock) UpdateNode(ctx context.Context, in *UpdateNodeRequest, opts ...grpc.CallOption) (*UpdateNodeResponse, error)
type NodeReceiverServer ¶
type NodeReceiverServer interface { CreateNode(context.Context, *CreateNodeRequest) (*CreateNodeResponse, error) UpdateNode(context.Context, *UpdateNodeRequest) (*UpdateNodeResponse, error) DeleteNode(context.Context, *DeleteNodeRequest) (*DeleteNodeResponse, error) // contains filtered or unexported methods }
NodeReceiverServer is the server API for NodeReceiver service. All implementations must embed UnimplementedNodeReceiverServer for forward compatibility
type NodeReceiverStreamClient ¶
type NodeReceiverStreamClient interface { CreateNodeStream(ctx context.Context, opts ...grpc.CallOption) (NodeReceiverStream_CreateNodeStreamClient, error) UpdateNodeStream(ctx context.Context, opts ...grpc.CallOption) (NodeReceiverStream_UpdateNodeStreamClient, error) DeleteNodeStream(ctx context.Context, opts ...grpc.CallOption) (NodeReceiverStream_DeleteNodeStreamClient, error) }
NodeReceiverStreamClient is the client API for NodeReceiverStream 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 NewNodeReceiverStreamClient ¶
func NewNodeReceiverStreamClient(cc grpc.ClientConnInterface) NodeReceiverStreamClient
type NodeReceiverStreamEnhancedServer ¶
type NodeReceiverStreamEnhancedServer map[string]NamedNodeReceiverStreamServer
func (NodeReceiverStreamEnhancedServer) CreateNodeStream ¶
func (m NodeReceiverStreamEnhancedServer) CreateNodeStream(s NodeReceiverStream_CreateNodeStreamServer) error
func (NodeReceiverStreamEnhancedServer) DeleteNodeStream ¶
func (m NodeReceiverStreamEnhancedServer) DeleteNodeStream(s NodeReceiverStream_DeleteNodeStreamServer) error
func (NodeReceiverStreamEnhancedServer) UpdateNodeStream ¶
func (m NodeReceiverStreamEnhancedServer) UpdateNodeStream(s NodeReceiverStream_UpdateNodeStreamServer) error
type NodeReceiverStreamServer ¶
type NodeReceiverStreamServer interface { CreateNodeStream(NodeReceiverStream_CreateNodeStreamServer) error UpdateNodeStream(NodeReceiverStream_UpdateNodeStreamServer) error DeleteNodeStream(NodeReceiverStream_DeleteNodeStreamServer) error // contains filtered or unexported methods }
NodeReceiverStreamServer is the server API for NodeReceiverStream service. All implementations must embed UnimplementedNodeReceiverStreamServer for forward compatibility
type NodeReceiverStreamStub ¶
type NodeReceiverStreamStub struct {
NodeReceiverStreamServer
}
func (*NodeReceiverStreamStub) Invoke ¶
func (s *NodeReceiverStreamStub) Invoke(ctx context.Context, method string, args interface{}, reply interface{}, opts ...grpc.CallOption) error
func (*NodeReceiverStreamStub) NewStream ¶
func (s *NodeReceiverStreamStub) NewStream(ctx context.Context, desc *grpc.StreamDesc, method string, opts ...grpc.CallOption) (grpc.ClientStream, error)
type NodeReceiverStreamStub_CreateNodeStreamStreamer ¶
type NodeReceiverStreamStub_CreateNodeStreamStreamer struct {
stubs.BidirServerStreamerCore
}
func (*NodeReceiverStreamStub_CreateNodeStreamStreamer) Recv ¶
func (s *NodeReceiverStreamStub_CreateNodeStreamStreamer) Recv() (*CreateNodeRequest, error)
func (*NodeReceiverStreamStub_CreateNodeStreamStreamer) Send ¶
func (s *NodeReceiverStreamStub_CreateNodeStreamStreamer) Send(response *CreateNodeResponse) error
type NodeReceiverStreamStub_DeleteNodeStreamStreamer ¶
type NodeReceiverStreamStub_DeleteNodeStreamStreamer struct {
stubs.BidirServerStreamerCore
}
func (*NodeReceiverStreamStub_DeleteNodeStreamStreamer) Recv ¶
func (s *NodeReceiverStreamStub_DeleteNodeStreamStreamer) Recv() (*DeleteNodeRequest, error)
func (*NodeReceiverStreamStub_DeleteNodeStreamStreamer) Send ¶
func (s *NodeReceiverStreamStub_DeleteNodeStreamStreamer) Send(response *DeleteNodeResponse) error
type NodeReceiverStreamStub_UpdateNodeStreamStreamer ¶
type NodeReceiverStreamStub_UpdateNodeStreamStreamer struct {
stubs.BidirServerStreamerCore
}
func (*NodeReceiverStreamStub_UpdateNodeStreamStreamer) Recv ¶
func (s *NodeReceiverStreamStub_UpdateNodeStreamStreamer) Recv() (*UpdateNodeRequest, error)
func (*NodeReceiverStreamStub_UpdateNodeStreamStreamer) Send ¶
func (s *NodeReceiverStreamStub_UpdateNodeStreamStreamer) Send(response *UpdateNodeResponse) error
type NodeReceiverStream_CreateNodeStreamClient ¶
type NodeReceiverStream_CreateNodeStreamClient interface { Send(*CreateNodeRequest) error Recv() (*CreateNodeResponse, error) grpc.ClientStream }
type NodeReceiverStream_CreateNodeStreamServer ¶
type NodeReceiverStream_CreateNodeStreamServer interface { Send(*CreateNodeResponse) error Recv() (*CreateNodeRequest, error) grpc.ServerStream }
type NodeReceiverStream_DeleteNodeStreamClient ¶
type NodeReceiverStream_DeleteNodeStreamClient interface { Send(*DeleteNodeRequest) error Recv() (*DeleteNodeResponse, error) grpc.ClientStream }
type NodeReceiverStream_DeleteNodeStreamServer ¶
type NodeReceiverStream_DeleteNodeStreamServer interface { Send(*DeleteNodeResponse) error Recv() (*DeleteNodeRequest, error) grpc.ServerStream }
type NodeReceiverStream_UpdateNodeStreamClient ¶
type NodeReceiverStream_UpdateNodeStreamClient interface { Send(*UpdateNodeRequest) error Recv() (*UpdateNodeResponse, error) grpc.ClientStream }
type NodeReceiverStream_UpdateNodeStreamServer ¶
type NodeReceiverStream_UpdateNodeStreamServer interface { Send(*UpdateNodeResponse) error Recv() (*UpdateNodeRequest, error) grpc.ServerStream }
type NodeReceiverStub ¶
type NodeReceiverStub struct {
NodeReceiverServer
}
func (*NodeReceiverStub) Invoke ¶
func (s *NodeReceiverStub) Invoke(ctx context.Context, method string, args interface{}, reply interface{}, opts ...grpc.CallOption) error
func (*NodeReceiverStub) NewStream ¶
func (s *NodeReceiverStub) NewStream(ctx context.Context, desc *grpc.StreamDesc, method string, opts ...grpc.CallOption) (grpc.ClientStream, error)
type NodeType ¶
type NodeType int32
========================================================== * Standard Messages ==========================================================
func (NodeType) Descriptor ¶
func (NodeType) Descriptor() protoreflect.EnumDescriptor
func (NodeType) EnumDescriptor
deprecated
func (NodeType) Number ¶
func (x NodeType) Number() protoreflect.EnumNumber
func (NodeType) Type ¶
func (NodeType) Type() protoreflect.EnumType
type NodeVersionerClient ¶
type NodeVersionerClient interface { CreateVersion(ctx context.Context, in *CreateVersionRequest, opts ...grpc.CallOption) (*CreateVersionResponse, error) StoreVersion(ctx context.Context, in *StoreVersionRequest, opts ...grpc.CallOption) (*StoreVersionResponse, error) ListVersions(ctx context.Context, in *ListVersionsRequest, opts ...grpc.CallOption) (NodeVersioner_ListVersionsClient, error) HeadVersion(ctx context.Context, in *HeadVersionRequest, opts ...grpc.CallOption) (*HeadVersionResponse, error) PruneVersions(ctx context.Context, in *PruneVersionsRequest, opts ...grpc.CallOption) (*PruneVersionsResponse, error) }
NodeVersionerClient is the client API for NodeVersioner 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 NewNodeVersionerClient ¶
func NewNodeVersionerClient(cc grpc.ClientConnInterface) NodeVersionerClient
type NodeVersionerEnhancedServer ¶
type NodeVersionerEnhancedServer map[string]NamedNodeVersionerServer
func (NodeVersionerEnhancedServer) CreateVersion ¶
func (m NodeVersionerEnhancedServer) CreateVersion(ctx context.Context, r *CreateVersionRequest) (*CreateVersionResponse, error)
func (NodeVersionerEnhancedServer) HeadVersion ¶
func (m NodeVersionerEnhancedServer) HeadVersion(ctx context.Context, r *HeadVersionRequest) (*HeadVersionResponse, error)
func (NodeVersionerEnhancedServer) ListVersions ¶
func (m NodeVersionerEnhancedServer) ListVersions(r *ListVersionsRequest, s NodeVersioner_ListVersionsServer) error
func (NodeVersionerEnhancedServer) PruneVersions ¶
func (m NodeVersionerEnhancedServer) PruneVersions(ctx context.Context, r *PruneVersionsRequest) (*PruneVersionsResponse, error)
func (NodeVersionerEnhancedServer) StoreVersion ¶
func (m NodeVersionerEnhancedServer) StoreVersion(ctx context.Context, r *StoreVersionRequest) (*StoreVersionResponse, error)
type NodeVersionerServer ¶
type NodeVersionerServer interface { CreateVersion(context.Context, *CreateVersionRequest) (*CreateVersionResponse, error) StoreVersion(context.Context, *StoreVersionRequest) (*StoreVersionResponse, error) ListVersions(*ListVersionsRequest, NodeVersioner_ListVersionsServer) error HeadVersion(context.Context, *HeadVersionRequest) (*HeadVersionResponse, error) PruneVersions(context.Context, *PruneVersionsRequest) (*PruneVersionsResponse, error) // contains filtered or unexported methods }
NodeVersionerServer is the server API for NodeVersioner service. All implementations must embed UnimplementedNodeVersionerServer for forward compatibility
type NodeVersionerStub ¶
type NodeVersionerStub struct {
NodeVersionerServer
}
func (*NodeVersionerStub) Invoke ¶
func (s *NodeVersionerStub) Invoke(ctx context.Context, method string, args interface{}, reply interface{}, opts ...grpc.CallOption) error
func (*NodeVersionerStub) NewStream ¶
func (s *NodeVersionerStub) NewStream(ctx context.Context, desc *grpc.StreamDesc, method string, opts ...grpc.CallOption) (grpc.ClientStream, error)
type NodeVersionerStub_ListVersionsStreamer ¶
type NodeVersionerStub_ListVersionsStreamer struct {
stubs.ClientServerStreamerCore
}
func (*NodeVersionerStub_ListVersionsStreamer) Send ¶
func (s *NodeVersionerStub_ListVersionsStreamer) Send(response *ListVersionsResponse) error
type NodeVersioner_ListVersionsClient ¶
type NodeVersioner_ListVersionsClient interface { Recv() (*ListVersionsResponse, error) grpc.ClientStream }
type NodeVersioner_ListVersionsServer ¶
type NodeVersioner_ListVersionsServer interface { Send(*ListVersionsResponse) error grpc.ServerStream }
type OpenSessionRequest ¶
type OpenSessionRequest struct { Session *IndexationSession `protobuf:"bytes,1,opt,name=Session,proto3" json:"Session,omitempty"` // contains filtered or unexported fields }
func (*OpenSessionRequest) Descriptor
deprecated
func (*OpenSessionRequest) Descriptor() ([]byte, []int)
Deprecated: Use OpenSessionRequest.ProtoReflect.Descriptor instead.
func (*OpenSessionRequest) GetSession ¶
func (x *OpenSessionRequest) GetSession() *IndexationSession
func (*OpenSessionRequest) ProtoMessage ¶
func (*OpenSessionRequest) ProtoMessage()
func (*OpenSessionRequest) ProtoReflect ¶
func (x *OpenSessionRequest) ProtoReflect() protoreflect.Message
func (*OpenSessionRequest) Reset ¶
func (x *OpenSessionRequest) Reset()
func (*OpenSessionRequest) String ¶
func (x *OpenSessionRequest) String() string
func (*OpenSessionRequest) Validate ¶
func (this *OpenSessionRequest) Validate() error
type OpenSessionResponse ¶
type OpenSessionResponse struct { Session *IndexationSession `protobuf:"bytes,1,opt,name=Session,proto3" json:"Session,omitempty"` // contains filtered or unexported fields }
func (*OpenSessionResponse) Descriptor
deprecated
func (*OpenSessionResponse) Descriptor() ([]byte, []int)
Deprecated: Use OpenSessionResponse.ProtoReflect.Descriptor instead.
func (*OpenSessionResponse) GetSession ¶
func (x *OpenSessionResponse) GetSession() *IndexationSession
func (*OpenSessionResponse) ProtoMessage ¶
func (*OpenSessionResponse) ProtoMessage()
func (*OpenSessionResponse) ProtoReflect ¶
func (x *OpenSessionResponse) ProtoReflect() protoreflect.Message
func (*OpenSessionResponse) Reset ¶
func (x *OpenSessionResponse) Reset()
func (*OpenSessionResponse) String ¶
func (x *OpenSessionResponse) String() string
func (*OpenSessionResponse) Validate ¶
func (this *OpenSessionResponse) Validate() error
type PruneVersionsRequest ¶
type PruneVersionsRequest struct { UniqueNode *Node `protobuf:"bytes,1,opt,name=UniqueNode,proto3" json:"UniqueNode,omitempty"` AllDeletedNodes bool `protobuf:"varint,2,opt,name=AllDeletedNodes,proto3" json:"AllDeletedNodes,omitempty"` // contains filtered or unexported fields }
func (*PruneVersionsRequest) Descriptor
deprecated
func (*PruneVersionsRequest) Descriptor() ([]byte, []int)
Deprecated: Use PruneVersionsRequest.ProtoReflect.Descriptor instead.
func (*PruneVersionsRequest) GetAllDeletedNodes ¶
func (x *PruneVersionsRequest) GetAllDeletedNodes() bool
func (*PruneVersionsRequest) GetUniqueNode ¶
func (x *PruneVersionsRequest) GetUniqueNode() *Node
func (*PruneVersionsRequest) ProtoMessage ¶
func (*PruneVersionsRequest) ProtoMessage()
func (*PruneVersionsRequest) ProtoReflect ¶
func (x *PruneVersionsRequest) ProtoReflect() protoreflect.Message
func (*PruneVersionsRequest) Reset ¶
func (x *PruneVersionsRequest) Reset()
func (*PruneVersionsRequest) String ¶
func (x *PruneVersionsRequest) String() string
func (*PruneVersionsRequest) Validate ¶
func (this *PruneVersionsRequest) Validate() error
type PruneVersionsResponse ¶
type PruneVersionsResponse struct { DeletedVersions []*ChangeLog `protobuf:"bytes,1,rep,name=DeletedVersions,proto3" json:"DeletedVersions,omitempty"` // contains filtered or unexported fields }
func (*PruneVersionsResponse) Descriptor
deprecated
func (*PruneVersionsResponse) Descriptor() ([]byte, []int)
Deprecated: Use PruneVersionsResponse.ProtoReflect.Descriptor instead.
func (*PruneVersionsResponse) GetDeletedVersions ¶
func (x *PruneVersionsResponse) GetDeletedVersions() []*ChangeLog
func (*PruneVersionsResponse) ProtoMessage ¶
func (*PruneVersionsResponse) ProtoMessage()
func (*PruneVersionsResponse) ProtoReflect ¶
func (x *PruneVersionsResponse) ProtoReflect() protoreflect.Message
func (*PruneVersionsResponse) Reset ¶
func (x *PruneVersionsResponse) Reset()
func (*PruneVersionsResponse) String ¶
func (x *PruneVersionsResponse) String() string
func (*PruneVersionsResponse) Validate ¶
func (this *PruneVersionsResponse) Validate() error
type PutSyncChangeResponse ¶
type PutSyncChangeResponse struct { Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"` Msg string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"` // contains filtered or unexported fields }
func (*PutSyncChangeResponse) Descriptor
deprecated
func (*PutSyncChangeResponse) Descriptor() ([]byte, []int)
Deprecated: Use PutSyncChangeResponse.ProtoReflect.Descriptor instead.
func (*PutSyncChangeResponse) GetMsg ¶
func (x *PutSyncChangeResponse) GetMsg() string
func (*PutSyncChangeResponse) GetSuccess ¶
func (x *PutSyncChangeResponse) GetSuccess() bool
func (*PutSyncChangeResponse) ProtoMessage ¶
func (*PutSyncChangeResponse) ProtoMessage()
func (*PutSyncChangeResponse) ProtoReflect ¶
func (x *PutSyncChangeResponse) ProtoReflect() protoreflect.Message
func (*PutSyncChangeResponse) Reset ¶
func (x *PutSyncChangeResponse) Reset()
func (*PutSyncChangeResponse) String ¶
func (x *PutSyncChangeResponse) String() string
func (*PutSyncChangeResponse) Validate ¶
func (this *PutSyncChangeResponse) Validate() error
type Query ¶
type Query struct { // Preset list of nodes by Path Paths []string `protobuf:"bytes,13,rep,name=Paths,proto3" json:"Paths,omitempty"` // Limit to a given subtree PathPrefix []string `protobuf:"bytes,1,rep,name=PathPrefix,proto3" json:"PathPrefix,omitempty"` // Range for size MinSize int64 `protobuf:"varint,2,opt,name=MinSize,proto3" json:"MinSize,omitempty"` MaxSize int64 `protobuf:"varint,3,opt,name=MaxSize,proto3" json:"MaxSize,omitempty"` // Range for date MinDate int64 `protobuf:"varint,4,opt,name=MinDate,proto3" json:"MinDate,omitempty"` MaxDate int64 `protobuf:"varint,5,opt,name=MaxDate,proto3" json:"MaxDate,omitempty"` // Pass a duration with > or < to compute MinDate / MaxDate DurationDate string `protobuf:"bytes,16,opt,name=DurationDate,proto3" json:"DurationDate,omitempty"` // Limit to a given node type Type NodeType `protobuf:"varint,6,opt,name=Type,proto3,enum=tree.NodeType" json:"Type,omitempty"` // Search in filename FileName string `protobuf:"bytes,7,opt,name=FileName,proto3" json:"FileName,omitempty"` // Search in content Content string `protobuf:"bytes,8,opt,name=Content,proto3" json:"Content,omitempty"` // Search in either filename or content (but at least one of them) FileNameOrContent string `protobuf:"bytes,17,opt,name=FileNameOrContent,proto3" json:"FileNameOrContent,omitempty"` // Free Query String (for metadata) FreeString string `protobuf:"bytes,9,opt,name=FreeString,proto3" json:"FreeString,omitempty"` // Search files by extension Extension string `protobuf:"bytes,10,opt,name=Extension,proto3" json:"Extension,omitempty"` // Search geographically GeoQuery *GeoQuery `protobuf:"bytes,11,opt,name=GeoQuery,proto3" json:"GeoQuery,omitempty"` // Limit to a given level of the tree - can be used in filters PathDepth int32 `protobuf:"varint,12,opt,name=PathDepth,proto3" json:"PathDepth,omitempty"` // Preset list of Node by UUIDs UUIDs []string `protobuf:"bytes,15,rep,name=UUIDs,proto3" json:"UUIDs,omitempty"` // Negate this query Not bool `protobuf:"varint,14,opt,name=Not,proto3" json:"Not,omitempty"` // contains filtered or unexported fields }
Search Queries
func (*Query) Descriptor
deprecated
func (*Query) GetContent ¶
func (*Query) GetDurationDate ¶
func (*Query) GetExtension ¶
func (*Query) GetFileName ¶
func (*Query) GetFileNameOrContent ¶
func (*Query) GetFreeString ¶
func (*Query) GetGeoQuery ¶
func (*Query) GetMaxDate ¶
func (*Query) GetMaxSize ¶
func (*Query) GetMinDate ¶
func (*Query) GetMinSize ¶
func (*Query) GetPathDepth ¶
func (*Query) GetPathPrefix ¶
func (*Query) ParseDurationDate ¶
ParseDurationDate transforms DurationDate field to proper MinDate/MaxDate values variadic ref is passed mostly for test, should normally use NOW for reference time
func (*Query) ProtoMessage ¶
func (*Query) ProtoMessage()
func (*Query) ProtoReflect ¶
func (x *Query) ProtoReflect() protoreflect.Message
type ReadNodeRequest ¶
type ReadNodeRequest struct { // Input node Node *Node `protobuf:"bytes,1,opt,name=Node,proto3" json:"Node,omitempty"` // Used internally for the router ReadNode request, stat the datasource instead of index ObjectStats bool `protobuf:"varint,4,opt,name=ObjectStats,proto3" json:"ObjectStats,omitempty"` // Generic Details Flags StatFlags []uint32 `protobuf:"varint,5,rep,packed,name=StatFlags,proto3" json:"StatFlags,omitempty"` // Get extended stats - For folders, computes ChildrenCount - Depreacted, use StatFlags instead WithExtendedStats bool `protobuf:"varint,3,opt,name=WithExtendedStats,proto3" json:"WithExtendedStats,omitempty"` // Gather commit information - This is Deprecated WithCommits bool `protobuf:"varint,2,opt,name=WithCommits,proto3" json:"WithCommits,omitempty"` // contains filtered or unexported fields }
Request / Responses Messages
func (*ReadNodeRequest) Descriptor
deprecated
func (*ReadNodeRequest) Descriptor() ([]byte, []int)
Deprecated: Use ReadNodeRequest.ProtoReflect.Descriptor instead.
func (*ReadNodeRequest) GetNode ¶
func (x *ReadNodeRequest) GetNode() *Node
func (*ReadNodeRequest) GetObjectStats ¶
func (x *ReadNodeRequest) GetObjectStats() bool
func (*ReadNodeRequest) GetStatFlags ¶ added in v4.0.1
func (x *ReadNodeRequest) GetStatFlags() []uint32
func (*ReadNodeRequest) GetWithCommits ¶
func (x *ReadNodeRequest) GetWithCommits() bool
func (*ReadNodeRequest) GetWithExtendedStats ¶
func (x *ReadNodeRequest) GetWithExtendedStats() bool
func (*ReadNodeRequest) ProtoMessage ¶
func (*ReadNodeRequest) ProtoMessage()
func (*ReadNodeRequest) ProtoReflect ¶
func (x *ReadNodeRequest) ProtoReflect() protoreflect.Message
func (*ReadNodeRequest) Reset ¶
func (x *ReadNodeRequest) Reset()
func (*ReadNodeRequest) String ¶
func (x *ReadNodeRequest) String() string
func (*ReadNodeRequest) Validate ¶
func (this *ReadNodeRequest) Validate() error
type ReadNodeResponse ¶
type ReadNodeResponse struct { Success bool `protobuf:"varint,1,opt,name=Success,proto3" json:"Success,omitempty"` Node *Node `protobuf:"bytes,2,opt,name=Node,proto3" json:"Node,omitempty"` // contains filtered or unexported fields }
func (*ReadNodeResponse) Descriptor
deprecated
func (*ReadNodeResponse) Descriptor() ([]byte, []int)
Deprecated: Use ReadNodeResponse.ProtoReflect.Descriptor instead.
func (*ReadNodeResponse) GetNode ¶
func (x *ReadNodeResponse) GetNode() *Node
func (*ReadNodeResponse) GetSuccess ¶
func (x *ReadNodeResponse) GetSuccess() bool
func (*ReadNodeResponse) ProtoMessage ¶
func (*ReadNodeResponse) ProtoMessage()
func (*ReadNodeResponse) ProtoReflect ¶
func (x *ReadNodeResponse) ProtoReflect() protoreflect.Message
func (*ReadNodeResponse) Reset ¶
func (x *ReadNodeResponse) Reset()
func (*ReadNodeResponse) String ¶
func (x *ReadNodeResponse) String() string
func (*ReadNodeResponse) Validate ¶
func (this *ReadNodeResponse) Validate() error
type SearchFacet ¶
type SearchFacet struct { // Facet field name FieldName string `protobuf:"bytes,1,opt,name=FieldName,proto3" json:"FieldName,omitempty"` // Segment Label Label string `protobuf:"bytes,2,opt,name=Label,proto3" json:"Label,omitempty"` // Segment results count Count int32 `protobuf:"varint,3,opt,name=Count,proto3" json:"Count,omitempty"` // For string facets, term value Term string `protobuf:"bytes,4,opt,name=Term,proto3" json:"Term,omitempty"` // For NumericRange facets, min/max values Min int64 `protobuf:"varint,5,opt,name=Min,proto3" json:"Min,omitempty"` Max int64 `protobuf:"varint,6,opt,name=Max,proto3" json:"Max,omitempty"` // For DateRange facets, start/end values Start int32 `protobuf:"varint,7,opt,name=Start,proto3" json:"Start,omitempty"` End int32 `protobuf:"varint,8,opt,name=End,proto3" json:"End,omitempty"` // contains filtered or unexported fields }
func (*SearchFacet) Descriptor
deprecated
func (*SearchFacet) Descriptor() ([]byte, []int)
Deprecated: Use SearchFacet.ProtoReflect.Descriptor instead.
func (*SearchFacet) GetCount ¶
func (x *SearchFacet) GetCount() int32
func (*SearchFacet) GetEnd ¶
func (x *SearchFacet) GetEnd() int32
func (*SearchFacet) GetFieldName ¶
func (x *SearchFacet) GetFieldName() string
func (*SearchFacet) GetLabel ¶
func (x *SearchFacet) GetLabel() string
func (*SearchFacet) GetMax ¶
func (x *SearchFacet) GetMax() int64
func (*SearchFacet) GetMin ¶
func (x *SearchFacet) GetMin() int64
func (*SearchFacet) GetStart ¶
func (x *SearchFacet) GetStart() int32
func (*SearchFacet) GetTerm ¶
func (x *SearchFacet) GetTerm() string
func (*SearchFacet) ProtoMessage ¶
func (*SearchFacet) ProtoMessage()
func (*SearchFacet) ProtoReflect ¶
func (x *SearchFacet) ProtoReflect() protoreflect.Message
func (*SearchFacet) Reset ¶
func (x *SearchFacet) Reset()
func (*SearchFacet) String ¶
func (x *SearchFacet) String() string
func (*SearchFacet) Validate ¶
func (this *SearchFacet) Validate() error
type SearchRequest ¶
type SearchRequest struct { // The query object Query *Query `protobuf:"bytes,1,opt,name=Query,proto3" json:"Query,omitempty"` // Limit the number of results Size int32 `protobuf:"varint,2,opt,name=Size,proto3" json:"Size,omitempty"` // Start at given position From int32 `protobuf:"varint,3,opt,name=From,proto3" json:"From,omitempty"` // Load node details Details bool `protobuf:"varint,4,opt,name=Details,proto3" json:"Details,omitempty"` // Generic Details Flags StatFlags []uint32 `protobuf:"varint,5,rep,packed,name=StatFlags,proto3" json:"StatFlags,omitempty"` // contains filtered or unexported fields }
func (*SearchRequest) Descriptor
deprecated
func (*SearchRequest) Descriptor() ([]byte, []int)
Deprecated: Use SearchRequest.ProtoReflect.Descriptor instead.
func (*SearchRequest) GetDetails ¶
func (x *SearchRequest) GetDetails() bool
func (*SearchRequest) GetFrom ¶
func (x *SearchRequest) GetFrom() int32
func (*SearchRequest) GetQuery ¶
func (x *SearchRequest) GetQuery() *Query
func (*SearchRequest) GetSize ¶
func (x *SearchRequest) GetSize() int32
func (*SearchRequest) GetStatFlags ¶ added in v4.0.1
func (x *SearchRequest) GetStatFlags() []uint32
func (*SearchRequest) ProtoMessage ¶
func (*SearchRequest) ProtoMessage()
func (*SearchRequest) ProtoReflect ¶
func (x *SearchRequest) ProtoReflect() protoreflect.Message
func (*SearchRequest) Reset ¶
func (x *SearchRequest) Reset()
func (*SearchRequest) String ¶
func (x *SearchRequest) String() string
func (*SearchRequest) Validate ¶
func (this *SearchRequest) Validate() error
type SearchResponse ¶
type SearchResponse struct { Node *Node `protobuf:"bytes,1,opt,name=Node,proto3" json:"Node,omitempty"` Facet *SearchFacet `protobuf:"bytes,2,opt,name=Facet,proto3" json:"Facet,omitempty"` // contains filtered or unexported fields }
func (*SearchResponse) Descriptor
deprecated
func (*SearchResponse) Descriptor() ([]byte, []int)
Deprecated: Use SearchResponse.ProtoReflect.Descriptor instead.
func (*SearchResponse) GetFacet ¶
func (x *SearchResponse) GetFacet() *SearchFacet
func (*SearchResponse) GetNode ¶
func (x *SearchResponse) GetNode() *Node
func (*SearchResponse) ProtoMessage ¶
func (*SearchResponse) ProtoMessage()
func (*SearchResponse) ProtoReflect ¶
func (x *SearchResponse) ProtoReflect() protoreflect.Message
func (*SearchResponse) Reset ¶
func (x *SearchResponse) Reset()
func (*SearchResponse) String ¶
func (x *SearchResponse) String() string
func (*SearchResponse) Validate ¶
func (this *SearchResponse) Validate() error
type SearchSyncChangeRequest ¶
type SearchSyncChangeRequest struct { Seq uint64 `protobuf:"varint,1,opt,name=seq,proto3" json:"seq,omitempty"` Flatten bool `protobuf:"varint,2,opt,name=flatten,proto3" json:"flatten,omitempty"` Prefix string `protobuf:"bytes,3,opt,name=prefix,proto3" json:"prefix,omitempty"` LastSeqOnly bool `protobuf:"varint,4,opt,name=lastSeqOnly,proto3" json:"lastSeqOnly,omitempty"` // contains filtered or unexported fields }
func (*SearchSyncChangeRequest) Descriptor
deprecated
func (*SearchSyncChangeRequest) Descriptor() ([]byte, []int)
Deprecated: Use SearchSyncChangeRequest.ProtoReflect.Descriptor instead.
func (*SearchSyncChangeRequest) GetFlatten ¶
func (x *SearchSyncChangeRequest) GetFlatten() bool
func (*SearchSyncChangeRequest) GetLastSeqOnly ¶
func (x *SearchSyncChangeRequest) GetLastSeqOnly() bool
func (*SearchSyncChangeRequest) GetPrefix ¶
func (x *SearchSyncChangeRequest) GetPrefix() string
func (*SearchSyncChangeRequest) GetSeq ¶
func (x *SearchSyncChangeRequest) GetSeq() uint64
func (*SearchSyncChangeRequest) ProtoMessage ¶
func (*SearchSyncChangeRequest) ProtoMessage()
func (*SearchSyncChangeRequest) ProtoReflect ¶
func (x *SearchSyncChangeRequest) ProtoReflect() protoreflect.Message
func (*SearchSyncChangeRequest) Reset ¶
func (x *SearchSyncChangeRequest) Reset()
func (*SearchSyncChangeRequest) String ¶
func (x *SearchSyncChangeRequest) String() string
func (*SearchSyncChangeRequest) Validate ¶
func (this *SearchSyncChangeRequest) Validate() error
type SearcherClient ¶
type SearcherClient interface {
Search(ctx context.Context, in *SearchRequest, opts ...grpc.CallOption) (Searcher_SearchClient, error)
}
SearcherClient is the client API for Searcher 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 NewSearcherClient ¶
func NewSearcherClient(cc grpc.ClientConnInterface) SearcherClient
type SearcherEnhancedServer ¶
type SearcherEnhancedServer map[string]NamedSearcherServer
func (SearcherEnhancedServer) Search ¶
func (m SearcherEnhancedServer) Search(r *SearchRequest, s Searcher_SearchServer) error
type SearcherServer ¶
type SearcherServer interface { Search(*SearchRequest, Searcher_SearchServer) error // contains filtered or unexported methods }
SearcherServer is the server API for Searcher service. All implementations must embed UnimplementedSearcherServer for forward compatibility
type SearcherStub ¶
type SearcherStub struct {
SearcherServer
}
func (*SearcherStub) Invoke ¶
func (s *SearcherStub) Invoke(ctx context.Context, method string, args interface{}, reply interface{}, opts ...grpc.CallOption) error
func (*SearcherStub) NewStream ¶
func (s *SearcherStub) NewStream(ctx context.Context, desc *grpc.StreamDesc, method string, opts ...grpc.CallOption) (grpc.ClientStream, error)
type SearcherStub_SearchStreamer ¶
type SearcherStub_SearchStreamer struct {
stubs.ClientServerStreamerCore
}
func (*SearcherStub_SearchStreamer) Send ¶
func (s *SearcherStub_SearchStreamer) Send(response *SearchResponse) error
type Searcher_SearchClient ¶
type Searcher_SearchClient interface { Recv() (*SearchResponse, error) grpc.ClientStream }
type Searcher_SearchServer ¶
type Searcher_SearchServer interface { Send(*SearchResponse) error grpc.ServerStream }
type SessionIndexerClient ¶
type SessionIndexerClient interface { OpenSession(ctx context.Context, in *OpenSessionRequest, opts ...grpc.CallOption) (*OpenSessionResponse, error) FlushSession(ctx context.Context, in *FlushSessionRequest, opts ...grpc.CallOption) (*FlushSessionResponse, error) CloseSession(ctx context.Context, in *CloseSessionRequest, opts ...grpc.CallOption) (*CloseSessionResponse, error) }
SessionIndexerClient is the client API for SessionIndexer 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 NewSessionIndexerClient ¶
func NewSessionIndexerClient(cc grpc.ClientConnInterface) SessionIndexerClient
type SessionIndexerEnhancedServer ¶
type SessionIndexerEnhancedServer map[string]NamedSessionIndexerServer
func (SessionIndexerEnhancedServer) CloseSession ¶
func (m SessionIndexerEnhancedServer) CloseSession(ctx context.Context, r *CloseSessionRequest) (*CloseSessionResponse, error)
func (SessionIndexerEnhancedServer) FlushSession ¶
func (m SessionIndexerEnhancedServer) FlushSession(ctx context.Context, r *FlushSessionRequest) (*FlushSessionResponse, error)
func (SessionIndexerEnhancedServer) OpenSession ¶
func (m SessionIndexerEnhancedServer) OpenSession(ctx context.Context, r *OpenSessionRequest) (*OpenSessionResponse, error)
type SessionIndexerMock ¶
type SessionIndexerMock struct { }
func (*SessionIndexerMock) CloseSession ¶
func (s *SessionIndexerMock) CloseSession(ctx context.Context, in *CloseSessionRequest, opts ...grpc.CallOption) (*CloseSessionResponse, error)
func (*SessionIndexerMock) FlushSession ¶
func (s *SessionIndexerMock) FlushSession(ctx context.Context, in *FlushSessionRequest, opts ...grpc.CallOption) (*FlushSessionResponse, error)
func (*SessionIndexerMock) OpenSession ¶
func (s *SessionIndexerMock) OpenSession(ctx context.Context, in *OpenSessionRequest, opts ...grpc.CallOption) (*OpenSessionResponse, error)
type SessionIndexerServer ¶
type SessionIndexerServer interface { OpenSession(context.Context, *OpenSessionRequest) (*OpenSessionResponse, error) FlushSession(context.Context, *FlushSessionRequest) (*FlushSessionResponse, error) CloseSession(context.Context, *CloseSessionRequest) (*CloseSessionResponse, error) // contains filtered or unexported methods }
SessionIndexerServer is the server API for SessionIndexer service. All implementations must embed UnimplementedSessionIndexerServer for forward compatibility
type SessionIndexerStub ¶
type SessionIndexerStub struct {
SessionIndexerServer
}
func (*SessionIndexerStub) Invoke ¶
func (s *SessionIndexerStub) Invoke(ctx context.Context, method string, args interface{}, reply interface{}, opts ...grpc.CallOption) error
func (*SessionIndexerStub) NewStream ¶
func (s *SessionIndexerStub) NewStream(ctx context.Context, desc *grpc.StreamDesc, method string, opts ...grpc.CallOption) (grpc.ClientStream, error)
type StoreVersionRequest ¶
type StoreVersionRequest struct { Node *Node `protobuf:"bytes,1,opt,name=Node,proto3" json:"Node,omitempty"` Version *ChangeLog `protobuf:"bytes,2,opt,name=Version,proto3" json:"Version,omitempty"` // contains filtered or unexported fields }
func (*StoreVersionRequest) Descriptor
deprecated
func (*StoreVersionRequest) Descriptor() ([]byte, []int)
Deprecated: Use StoreVersionRequest.ProtoReflect.Descriptor instead.
func (*StoreVersionRequest) GetNode ¶
func (x *StoreVersionRequest) GetNode() *Node
func (*StoreVersionRequest) GetVersion ¶
func (x *StoreVersionRequest) GetVersion() *ChangeLog
func (*StoreVersionRequest) ProtoMessage ¶
func (*StoreVersionRequest) ProtoMessage()
func (*StoreVersionRequest) ProtoReflect ¶
func (x *StoreVersionRequest) ProtoReflect() protoreflect.Message
func (*StoreVersionRequest) Reset ¶
func (x *StoreVersionRequest) Reset()
func (*StoreVersionRequest) String ¶
func (x *StoreVersionRequest) String() string
func (*StoreVersionRequest) Validate ¶
func (this *StoreVersionRequest) Validate() error
type StoreVersionResponse ¶
type StoreVersionResponse struct { Success bool `protobuf:"varint,1,opt,name=Success,proto3" json:"Success,omitempty"` PruneVersions []*ChangeLog `protobuf:"bytes,2,rep,name=PruneVersions,proto3" json:"PruneVersions,omitempty"` // contains filtered or unexported fields }
func (*StoreVersionResponse) Descriptor
deprecated
func (*StoreVersionResponse) Descriptor() ([]byte, []int)
Deprecated: Use StoreVersionResponse.ProtoReflect.Descriptor instead.
func (*StoreVersionResponse) GetPruneVersions ¶
func (x *StoreVersionResponse) GetPruneVersions() []*ChangeLog
func (*StoreVersionResponse) GetSuccess ¶
func (x *StoreVersionResponse) GetSuccess() bool
func (*StoreVersionResponse) ProtoMessage ¶
func (*StoreVersionResponse) ProtoMessage()
func (*StoreVersionResponse) ProtoReflect ¶
func (x *StoreVersionResponse) ProtoReflect() protoreflect.Message
func (*StoreVersionResponse) Reset ¶
func (x *StoreVersionResponse) Reset()
func (*StoreVersionResponse) String ¶
func (x *StoreVersionResponse) String() string
func (*StoreVersionResponse) Validate ¶
func (this *StoreVersionResponse) Validate() error
type StreamChangesRequest ¶
type StreamChangesRequest struct { RootPath string `protobuf:"bytes,1,opt,name=RootPath,proto3" json:"RootPath,omitempty"` // contains filtered or unexported fields }
func (*StreamChangesRequest) Descriptor
deprecated
func (*StreamChangesRequest) Descriptor() ([]byte, []int)
Deprecated: Use StreamChangesRequest.ProtoReflect.Descriptor instead.
func (*StreamChangesRequest) GetRootPath ¶
func (x *StreamChangesRequest) GetRootPath() string
func (*StreamChangesRequest) ProtoMessage ¶
func (*StreamChangesRequest) ProtoMessage()
func (*StreamChangesRequest) ProtoReflect ¶
func (x *StreamChangesRequest) ProtoReflect() protoreflect.Message
func (*StreamChangesRequest) Reset ¶
func (x *StreamChangesRequest) Reset()
func (*StreamChangesRequest) String ¶
func (x *StreamChangesRequest) String() string
func (*StreamChangesRequest) Validate ¶
func (this *StreamChangesRequest) Validate() error
type StreamerMock ¶
type StreamerMock struct {
// contains filtered or unexported fields
}
func (*StreamerMock) Close ¶
func (m *StreamerMock) Close() error
func (*StreamerMock) CloseSend ¶
func (m *StreamerMock) CloseSend() error
func (*StreamerMock) Context ¶
func (m *StreamerMock) Context() context.Context
func (*StreamerMock) Error ¶
func (m *StreamerMock) Error() error
func (*StreamerMock) Recv ¶
func (m *StreamerMock) Recv(v interface{}) error
func (*StreamerMock) RecvMsg ¶
func (m *StreamerMock) RecvMsg(msg interface{}) error
func (*StreamerMock) Send ¶
func (m *StreamerMock) Send(v interface{}) error
func (*StreamerMock) SendMsg ¶
func (m *StreamerMock) SendMsg(msg interface{}) error
func (*StreamerMock) Trailer ¶
func (m *StreamerMock) Trailer() metadata.MD
type SyncChange ¶
type SyncChange struct { Seq uint64 `protobuf:"varint,1,opt,name=seq,proto3" json:"seq,omitempty"` NodeId string `protobuf:"bytes,2,opt,name=nodeId,json=node_id,proto3" json:"nodeId,omitempty"` Type SyncChange_Type `protobuf:"varint,3,opt,name=type,proto3,enum=tree.SyncChange_Type" json:"type,omitempty"` Source string `protobuf:"bytes,4,opt,name=source,proto3" json:"source,omitempty"` Target string `protobuf:"bytes,5,opt,name=target,proto3" json:"target,omitempty"` Node *SyncChangeNode `protobuf:"bytes,6,opt,name=node,proto3" json:"node,omitempty"` // contains filtered or unexported fields }
func (*SyncChange) Descriptor
deprecated
func (*SyncChange) Descriptor() ([]byte, []int)
Deprecated: Use SyncChange.ProtoReflect.Descriptor instead.
func (*SyncChange) GetNode ¶
func (x *SyncChange) GetNode() *SyncChangeNode
func (*SyncChange) GetNodeId ¶
func (x *SyncChange) GetNodeId() string
func (*SyncChange) GetSeq ¶
func (x *SyncChange) GetSeq() uint64
func (*SyncChange) GetSource ¶
func (x *SyncChange) GetSource() string
func (*SyncChange) GetTarget ¶
func (x *SyncChange) GetTarget() string
func (*SyncChange) GetType ¶
func (x *SyncChange) GetType() SyncChange_Type
func (*SyncChange) ProtoMessage ¶
func (*SyncChange) ProtoMessage()
func (*SyncChange) ProtoReflect ¶
func (x *SyncChange) ProtoReflect() protoreflect.Message
func (*SyncChange) Reset ¶
func (x *SyncChange) Reset()
func (*SyncChange) String ¶
func (x *SyncChange) String() string
func (*SyncChange) Validate ¶
func (this *SyncChange) Validate() error
type SyncChangeNode ¶
type SyncChangeNode struct { Bytesize int64 `protobuf:"varint,1,opt,name=bytesize,proto3" json:"bytesize,omitempty"` Md5 string `protobuf:"bytes,2,opt,name=md5,proto3" json:"md5,omitempty"` Mtime int64 `protobuf:"varint,3,opt,name=mtime,proto3" json:"mtime,omitempty"` NodePath string `protobuf:"bytes,4,opt,name=nodePath,json=node_path,proto3" json:"nodePath,omitempty"` RepositoryIdentifier string `protobuf:"bytes,5,opt,name=repositoryIdentifier,json=repository_identifier,proto3" json:"repositoryIdentifier,omitempty"` // contains filtered or unexported fields }
func (*SyncChangeNode) Descriptor
deprecated
func (*SyncChangeNode) Descriptor() ([]byte, []int)
Deprecated: Use SyncChangeNode.ProtoReflect.Descriptor instead.
func (*SyncChangeNode) GetBytesize ¶
func (x *SyncChangeNode) GetBytesize() int64
func (*SyncChangeNode) GetMd5 ¶
func (x *SyncChangeNode) GetMd5() string
func (*SyncChangeNode) GetMtime ¶
func (x *SyncChangeNode) GetMtime() int64
func (*SyncChangeNode) GetNodePath ¶
func (x *SyncChangeNode) GetNodePath() string
func (*SyncChangeNode) GetRepositoryIdentifier ¶
func (x *SyncChangeNode) GetRepositoryIdentifier() string
func (*SyncChangeNode) ProtoMessage ¶
func (*SyncChangeNode) ProtoMessage()
func (*SyncChangeNode) ProtoReflect ¶
func (x *SyncChangeNode) ProtoReflect() protoreflect.Message
func (*SyncChangeNode) Reset ¶
func (x *SyncChangeNode) Reset()
func (*SyncChangeNode) String ¶
func (x *SyncChangeNode) String() string
func (*SyncChangeNode) Validate ¶
func (this *SyncChangeNode) Validate() error
type SyncChange_Type ¶
type SyncChange_Type int32
const ( SyncChange_unknown SyncChange_Type = 0 SyncChange_create SyncChange_Type = 1 SyncChange_delete SyncChange_Type = 2 SyncChange_path SyncChange_Type = 3 SyncChange_content SyncChange_Type = 4 )
func (SyncChange_Type) Descriptor ¶
func (SyncChange_Type) Descriptor() protoreflect.EnumDescriptor
func (SyncChange_Type) Enum ¶
func (x SyncChange_Type) Enum() *SyncChange_Type
func (SyncChange_Type) EnumDescriptor
deprecated
func (SyncChange_Type) EnumDescriptor() ([]byte, []int)
Deprecated: Use SyncChange_Type.Descriptor instead.
func (SyncChange_Type) Number ¶
func (x SyncChange_Type) Number() protoreflect.EnumNumber
func (SyncChange_Type) String ¶
func (x SyncChange_Type) String() string
func (SyncChange_Type) Type ¶
func (SyncChange_Type) Type() protoreflect.EnumType
type SyncChangesClient ¶
type SyncChangesClient interface { Put(ctx context.Context, opts ...grpc.CallOption) (SyncChanges_PutClient, error) Search(ctx context.Context, in *SearchSyncChangeRequest, opts ...grpc.CallOption) (SyncChanges_SearchClient, error) }
SyncChangesClient is the client API for SyncChanges 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 NewSyncChangesClient ¶
func NewSyncChangesClient(cc grpc.ClientConnInterface) SyncChangesClient
type SyncChangesEnhancedServer ¶
type SyncChangesEnhancedServer map[string]NamedSyncChangesServer
func (SyncChangesEnhancedServer) Put ¶
func (m SyncChangesEnhancedServer) Put(s SyncChanges_PutServer) error
func (SyncChangesEnhancedServer) Search ¶
func (m SyncChangesEnhancedServer) Search(r *SearchSyncChangeRequest, s SyncChanges_SearchServer) error
type SyncChangesServer ¶
type SyncChangesServer interface { Put(SyncChanges_PutServer) error Search(*SearchSyncChangeRequest, SyncChanges_SearchServer) error // contains filtered or unexported methods }
SyncChangesServer is the server API for SyncChanges service. All implementations must embed UnimplementedSyncChangesServer for forward compatibility
type SyncChangesStub ¶
type SyncChangesStub struct {
SyncChangesServer
}
func (*SyncChangesStub) Invoke ¶
func (s *SyncChangesStub) Invoke(ctx context.Context, method string, args interface{}, reply interface{}, opts ...grpc.CallOption) error
func (*SyncChangesStub) NewStream ¶
func (s *SyncChangesStub) NewStream(ctx context.Context, desc *grpc.StreamDesc, method string, opts ...grpc.CallOption) (grpc.ClientStream, error)
type SyncChangesStub_PutStreamer ¶
type SyncChangesStub_PutStreamer struct {
stubs.BidirServerStreamerCore
}
func (*SyncChangesStub_PutStreamer) Recv ¶
func (s *SyncChangesStub_PutStreamer) Recv() (*SyncChange, error)
func (*SyncChangesStub_PutStreamer) Send ¶
func (s *SyncChangesStub_PutStreamer) Send(response *PutSyncChangeResponse) error
func (*SyncChangesStub_PutStreamer) SendAndClose ¶
func (s *SyncChangesStub_PutStreamer) SendAndClose(*PutSyncChangeResponse) error
type SyncChangesStub_SearchStreamer ¶
type SyncChangesStub_SearchStreamer struct {
stubs.ClientServerStreamerCore
}
func (*SyncChangesStub_SearchStreamer) Send ¶
func (s *SyncChangesStub_SearchStreamer) Send(response *SyncChange) error
type SyncChanges_PutClient ¶
type SyncChanges_PutClient interface { Send(*SyncChange) error CloseAndRecv() (*PutSyncChangeResponse, error) grpc.ClientStream }
type SyncChanges_PutServer ¶
type SyncChanges_PutServer interface { SendAndClose(*PutSyncChangeResponse) error Recv() (*SyncChange, error) grpc.ServerStream }
type SyncChanges_SearchClient ¶
type SyncChanges_SearchClient interface { Recv() (*SyncChange, error) grpc.ClientStream }
type SyncChanges_SearchServer ¶
type SyncChanges_SearchServer interface { Send(*SyncChange) error grpc.ServerStream }
type UnimplementedFileKeyManagerServer ¶
type UnimplementedFileKeyManagerServer struct { }
UnimplementedFileKeyManagerServer must be embedded to have forward compatible implementations.
func (UnimplementedFileKeyManagerServer) GetEncryptionKey ¶
func (UnimplementedFileKeyManagerServer) GetEncryptionKey(context.Context, *GetEncryptionKeyRequest) (*GetEncryptionKeyResponse, error)
type UnimplementedNodeChangesStreamerServer ¶
type UnimplementedNodeChangesStreamerServer struct { }
UnimplementedNodeChangesStreamerServer must be embedded to have forward compatible implementations.
func (UnimplementedNodeChangesStreamerServer) StreamChanges ¶
func (UnimplementedNodeChangesStreamerServer) StreamChanges(*StreamChangesRequest, NodeChangesStreamer_StreamChangesServer) error
type UnimplementedNodeContentReaderServer ¶
type UnimplementedNodeContentReaderServer struct { }
UnimplementedNodeContentReaderServer must be embedded to have forward compatible implementations.
type UnimplementedNodeContentWriterServer ¶
type UnimplementedNodeContentWriterServer struct { }
UnimplementedNodeContentWriterServer must be embedded to have forward compatible implementations.
type UnimplementedNodeEventsProviderServer ¶
type UnimplementedNodeEventsProviderServer struct { }
UnimplementedNodeEventsProviderServer must be embedded to have forward compatible implementations.
func (UnimplementedNodeEventsProviderServer) WatchNode ¶
func (UnimplementedNodeEventsProviderServer) WatchNode(*WatchNodeRequest, NodeEventsProvider_WatchNodeServer) error
type UnimplementedNodeProviderServer ¶
type UnimplementedNodeProviderServer struct { }
UnimplementedNodeProviderServer must be embedded to have forward compatible implementations.
func (UnimplementedNodeProviderServer) ListNodes ¶
func (UnimplementedNodeProviderServer) ListNodes(*ListNodesRequest, NodeProvider_ListNodesServer) error
func (UnimplementedNodeProviderServer) ReadNode ¶
func (UnimplementedNodeProviderServer) ReadNode(context.Context, *ReadNodeRequest) (*ReadNodeResponse, error)
type UnimplementedNodeProviderStreamerServer ¶
type UnimplementedNodeProviderStreamerServer struct { }
UnimplementedNodeProviderStreamerServer must be embedded to have forward compatible implementations.
func (UnimplementedNodeProviderStreamerServer) ReadNodeStream ¶
func (UnimplementedNodeProviderStreamerServer) ReadNodeStream(NodeProviderStreamer_ReadNodeStreamServer) error
type UnimplementedNodeReceiverServer ¶
type UnimplementedNodeReceiverServer struct { }
UnimplementedNodeReceiverServer must be embedded to have forward compatible implementations.
func (UnimplementedNodeReceiverServer) CreateNode ¶
func (UnimplementedNodeReceiverServer) CreateNode(context.Context, *CreateNodeRequest) (*CreateNodeResponse, error)
func (UnimplementedNodeReceiverServer) DeleteNode ¶
func (UnimplementedNodeReceiverServer) DeleteNode(context.Context, *DeleteNodeRequest) (*DeleteNodeResponse, error)
func (UnimplementedNodeReceiverServer) UpdateNode ¶
func (UnimplementedNodeReceiverServer) UpdateNode(context.Context, *UpdateNodeRequest) (*UpdateNodeResponse, error)
type UnimplementedNodeReceiverStreamServer ¶
type UnimplementedNodeReceiverStreamServer struct { }
UnimplementedNodeReceiverStreamServer must be embedded to have forward compatible implementations.
func (UnimplementedNodeReceiverStreamServer) CreateNodeStream ¶
func (UnimplementedNodeReceiverStreamServer) CreateNodeStream(NodeReceiverStream_CreateNodeStreamServer) error
func (UnimplementedNodeReceiverStreamServer) DeleteNodeStream ¶
func (UnimplementedNodeReceiverStreamServer) DeleteNodeStream(NodeReceiverStream_DeleteNodeStreamServer) error
func (UnimplementedNodeReceiverStreamServer) UpdateNodeStream ¶
func (UnimplementedNodeReceiverStreamServer) UpdateNodeStream(NodeReceiverStream_UpdateNodeStreamServer) error
type UnimplementedNodeVersionerServer ¶
type UnimplementedNodeVersionerServer struct { }
UnimplementedNodeVersionerServer must be embedded to have forward compatible implementations.
func (UnimplementedNodeVersionerServer) CreateVersion ¶
func (UnimplementedNodeVersionerServer) CreateVersion(context.Context, *CreateVersionRequest) (*CreateVersionResponse, error)
func (UnimplementedNodeVersionerServer) HeadVersion ¶
func (UnimplementedNodeVersionerServer) HeadVersion(context.Context, *HeadVersionRequest) (*HeadVersionResponse, error)
func (UnimplementedNodeVersionerServer) ListVersions ¶
func (UnimplementedNodeVersionerServer) ListVersions(*ListVersionsRequest, NodeVersioner_ListVersionsServer) error
func (UnimplementedNodeVersionerServer) PruneVersions ¶
func (UnimplementedNodeVersionerServer) PruneVersions(context.Context, *PruneVersionsRequest) (*PruneVersionsResponse, error)
func (UnimplementedNodeVersionerServer) StoreVersion ¶
func (UnimplementedNodeVersionerServer) StoreVersion(context.Context, *StoreVersionRequest) (*StoreVersionResponse, error)
type UnimplementedSearcherServer ¶
type UnimplementedSearcherServer struct { }
UnimplementedSearcherServer must be embedded to have forward compatible implementations.
func (UnimplementedSearcherServer) Search ¶
func (UnimplementedSearcherServer) Search(*SearchRequest, Searcher_SearchServer) error
type UnimplementedSessionIndexerServer ¶
type UnimplementedSessionIndexerServer struct { }
UnimplementedSessionIndexerServer must be embedded to have forward compatible implementations.
func (UnimplementedSessionIndexerServer) CloseSession ¶
func (UnimplementedSessionIndexerServer) CloseSession(context.Context, *CloseSessionRequest) (*CloseSessionResponse, error)
func (UnimplementedSessionIndexerServer) FlushSession ¶
func (UnimplementedSessionIndexerServer) FlushSession(context.Context, *FlushSessionRequest) (*FlushSessionResponse, error)
func (UnimplementedSessionIndexerServer) OpenSession ¶
func (UnimplementedSessionIndexerServer) OpenSession(context.Context, *OpenSessionRequest) (*OpenSessionResponse, error)
type UnimplementedSyncChangesServer ¶
type UnimplementedSyncChangesServer struct { }
UnimplementedSyncChangesServer must be embedded to have forward compatible implementations.
func (UnimplementedSyncChangesServer) Put ¶
func (UnimplementedSyncChangesServer) Put(SyncChanges_PutServer) error
type UnsafeFileKeyManagerServer ¶
type UnsafeFileKeyManagerServer interface {
// contains filtered or unexported methods
}
UnsafeFileKeyManagerServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to FileKeyManagerServer will result in compilation errors.
type UnsafeNodeChangesStreamerServer ¶
type UnsafeNodeChangesStreamerServer interface {
// contains filtered or unexported methods
}
UnsafeNodeChangesStreamerServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to NodeChangesStreamerServer will result in compilation errors.
type UnsafeNodeContentReaderServer ¶
type UnsafeNodeContentReaderServer interface {
// contains filtered or unexported methods
}
UnsafeNodeContentReaderServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to NodeContentReaderServer will result in compilation errors.
type UnsafeNodeContentWriterServer ¶
type UnsafeNodeContentWriterServer interface {
// contains filtered or unexported methods
}
UnsafeNodeContentWriterServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to NodeContentWriterServer will result in compilation errors.
type UnsafeNodeEventsProviderServer ¶
type UnsafeNodeEventsProviderServer interface {
// contains filtered or unexported methods
}
UnsafeNodeEventsProviderServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to NodeEventsProviderServer will result in compilation errors.
type UnsafeNodeProviderServer ¶
type UnsafeNodeProviderServer interface {
// contains filtered or unexported methods
}
UnsafeNodeProviderServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to NodeProviderServer will result in compilation errors.
type UnsafeNodeProviderStreamerServer ¶
type UnsafeNodeProviderStreamerServer interface {
// contains filtered or unexported methods
}
UnsafeNodeProviderStreamerServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to NodeProviderStreamerServer will result in compilation errors.
type UnsafeNodeReceiverServer ¶
type UnsafeNodeReceiverServer interface {
// contains filtered or unexported methods
}
UnsafeNodeReceiverServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to NodeReceiverServer will result in compilation errors.
type UnsafeNodeReceiverStreamServer ¶
type UnsafeNodeReceiverStreamServer interface {
// contains filtered or unexported methods
}
UnsafeNodeReceiverStreamServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to NodeReceiverStreamServer will result in compilation errors.
type UnsafeNodeVersionerServer ¶
type UnsafeNodeVersionerServer interface {
// contains filtered or unexported methods
}
UnsafeNodeVersionerServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to NodeVersionerServer will result in compilation errors.
type UnsafeSearcherServer ¶
type UnsafeSearcherServer interface {
// contains filtered or unexported methods
}
UnsafeSearcherServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to SearcherServer will result in compilation errors.
type UnsafeSessionIndexerServer ¶
type UnsafeSessionIndexerServer interface {
// contains filtered or unexported methods
}
UnsafeSessionIndexerServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to SessionIndexerServer will result in compilation errors.
type UnsafeSyncChangesServer ¶
type UnsafeSyncChangesServer interface {
// contains filtered or unexported methods
}
UnsafeSyncChangesServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to SyncChangesServer will result in compilation errors.
type UpdateNodeRequest ¶
type UpdateNodeRequest struct { From *Node `protobuf:"bytes,1,opt,name=From,proto3" json:"From,omitempty"` To *Node `protobuf:"bytes,2,opt,name=To,proto3" json:"To,omitempty"` IndexationSession string `protobuf:"bytes,3,opt,name=IndexationSession,proto3" json:"IndexationSession,omitempty"` Silent bool `protobuf:"varint,4,opt,name=Silent,proto3" json:"Silent,omitempty"` // contains filtered or unexported fields }
func (*UpdateNodeRequest) Descriptor
deprecated
func (*UpdateNodeRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateNodeRequest.ProtoReflect.Descriptor instead.
func (*UpdateNodeRequest) GetFrom ¶
func (x *UpdateNodeRequest) GetFrom() *Node
func (*UpdateNodeRequest) GetIndexationSession ¶
func (x *UpdateNodeRequest) GetIndexationSession() string
func (*UpdateNodeRequest) GetSilent ¶
func (x *UpdateNodeRequest) GetSilent() bool
func (*UpdateNodeRequest) GetTo ¶
func (x *UpdateNodeRequest) GetTo() *Node
func (*UpdateNodeRequest) ProtoMessage ¶
func (*UpdateNodeRequest) ProtoMessage()
func (*UpdateNodeRequest) ProtoReflect ¶
func (x *UpdateNodeRequest) ProtoReflect() protoreflect.Message
func (*UpdateNodeRequest) Reset ¶
func (x *UpdateNodeRequest) Reset()
func (*UpdateNodeRequest) String ¶
func (x *UpdateNodeRequest) String() string
func (*UpdateNodeRequest) Validate ¶
func (this *UpdateNodeRequest) Validate() error
type UpdateNodeResponse ¶
type UpdateNodeResponse struct { Success bool `protobuf:"varint,1,opt,name=Success,proto3" json:"Success,omitempty"` Node *Node `protobuf:"bytes,2,opt,name=Node,proto3" json:"Node,omitempty"` // contains filtered or unexported fields }
func (*UpdateNodeResponse) Descriptor
deprecated
func (*UpdateNodeResponse) Descriptor() ([]byte, []int)
Deprecated: Use UpdateNodeResponse.ProtoReflect.Descriptor instead.
func (*UpdateNodeResponse) GetNode ¶
func (x *UpdateNodeResponse) GetNode() *Node
func (*UpdateNodeResponse) GetSuccess ¶
func (x *UpdateNodeResponse) GetSuccess() bool
func (*UpdateNodeResponse) ProtoMessage ¶
func (*UpdateNodeResponse) ProtoMessage()
func (*UpdateNodeResponse) ProtoReflect ¶
func (x *UpdateNodeResponse) ProtoReflect() protoreflect.Message
func (*UpdateNodeResponse) Reset ¶
func (x *UpdateNodeResponse) Reset()
func (*UpdateNodeResponse) String ¶
func (x *UpdateNodeResponse) String() string
func (*UpdateNodeResponse) Validate ¶
func (this *UpdateNodeResponse) Validate() error
type VersioningKeepPeriod ¶
type VersioningKeepPeriod struct { IntervalStart string `protobuf:"bytes,1,opt,name=IntervalStart,proto3" json:"IntervalStart,omitempty"` MaxNumber int32 `protobuf:"varint,3,opt,name=MaxNumber,proto3" json:"MaxNumber,omitempty"` // contains filtered or unexported fields }
func (*VersioningKeepPeriod) Descriptor
deprecated
func (*VersioningKeepPeriod) Descriptor() ([]byte, []int)
Deprecated: Use VersioningKeepPeriod.ProtoReflect.Descriptor instead.
func (*VersioningKeepPeriod) GetIntervalStart ¶
func (x *VersioningKeepPeriod) GetIntervalStart() string
func (*VersioningKeepPeriod) GetMaxNumber ¶
func (x *VersioningKeepPeriod) GetMaxNumber() int32
func (*VersioningKeepPeriod) ProtoMessage ¶
func (*VersioningKeepPeriod) ProtoMessage()
func (*VersioningKeepPeriod) ProtoReflect ¶
func (x *VersioningKeepPeriod) ProtoReflect() protoreflect.Message
func (*VersioningKeepPeriod) Reset ¶
func (x *VersioningKeepPeriod) Reset()
func (*VersioningKeepPeriod) String ¶
func (x *VersioningKeepPeriod) String() string
func (*VersioningKeepPeriod) Validate ¶
func (this *VersioningKeepPeriod) Validate() error
type VersioningNodeDeletedStrategy ¶
type VersioningNodeDeletedStrategy int32
const ( VersioningNodeDeletedStrategy_KeepAll VersioningNodeDeletedStrategy = 0 VersioningNodeDeletedStrategy_KeepLast VersioningNodeDeletedStrategy = 1 VersioningNodeDeletedStrategy_KeepNone VersioningNodeDeletedStrategy = 2 )
func (VersioningNodeDeletedStrategy) Descriptor ¶
func (VersioningNodeDeletedStrategy) Descriptor() protoreflect.EnumDescriptor
func (VersioningNodeDeletedStrategy) Enum ¶
func (x VersioningNodeDeletedStrategy) Enum() *VersioningNodeDeletedStrategy
func (VersioningNodeDeletedStrategy) EnumDescriptor
deprecated
func (VersioningNodeDeletedStrategy) EnumDescriptor() ([]byte, []int)
Deprecated: Use VersioningNodeDeletedStrategy.Descriptor instead.
func (VersioningNodeDeletedStrategy) Number ¶
func (x VersioningNodeDeletedStrategy) Number() protoreflect.EnumNumber
func (VersioningNodeDeletedStrategy) String ¶
func (x VersioningNodeDeletedStrategy) String() string
func (VersioningNodeDeletedStrategy) Type ¶
func (VersioningNodeDeletedStrategy) Type() protoreflect.EnumType
type VersioningPolicy ¶
type VersioningPolicy struct { Uuid string `protobuf:"bytes,1,opt,name=Uuid,proto3" json:"Uuid,omitempty"` Name string `protobuf:"bytes,2,opt,name=Name,proto3" json:"Name,omitempty"` Description string `protobuf:"bytes,3,opt,name=Description,proto3" json:"Description,omitempty"` VersionsDataSourceName string `protobuf:"bytes,4,opt,name=VersionsDataSourceName,proto3" json:"VersionsDataSourceName,omitempty"` VersionsDataSourceBucket string `protobuf:"bytes,5,opt,name=VersionsDataSourceBucket,proto3" json:"VersionsDataSourceBucket,omitempty"` MaxTotalSize int64 `protobuf:"varint,6,opt,name=MaxTotalSize,proto3" json:"MaxTotalSize,omitempty"` MaxSizePerFile int64 `protobuf:"varint,7,opt,name=MaxSizePerFile,proto3" json:"MaxSizePerFile,omitempty"` IgnoreFilesGreaterThan int64 `protobuf:"varint,8,opt,name=IgnoreFilesGreaterThan,proto3" json:"IgnoreFilesGreaterThan,omitempty"` KeepPeriods []*VersioningKeepPeriod `protobuf:"bytes,9,rep,name=KeepPeriods,proto3" json:"KeepPeriods,omitempty"` NodeDeletedStrategy VersioningNodeDeletedStrategy `` /* 133-byte string literal not displayed */ // contains filtered or unexported fields }
func (*VersioningPolicy) Descriptor
deprecated
func (*VersioningPolicy) Descriptor() ([]byte, []int)
Deprecated: Use VersioningPolicy.ProtoReflect.Descriptor instead.
func (*VersioningPolicy) GetDescription ¶
func (x *VersioningPolicy) GetDescription() string
func (*VersioningPolicy) GetIgnoreFilesGreaterThan ¶
func (x *VersioningPolicy) GetIgnoreFilesGreaterThan() int64
func (*VersioningPolicy) GetKeepPeriods ¶
func (x *VersioningPolicy) GetKeepPeriods() []*VersioningKeepPeriod
func (*VersioningPolicy) GetMaxSizePerFile ¶
func (x *VersioningPolicy) GetMaxSizePerFile() int64
func (*VersioningPolicy) GetMaxTotalSize ¶
func (x *VersioningPolicy) GetMaxTotalSize() int64
func (*VersioningPolicy) GetName ¶
func (x *VersioningPolicy) GetName() string
func (*VersioningPolicy) GetNodeDeletedStrategy ¶
func (x *VersioningPolicy) GetNodeDeletedStrategy() VersioningNodeDeletedStrategy
func (*VersioningPolicy) GetUuid ¶
func (x *VersioningPolicy) GetUuid() string
func (*VersioningPolicy) GetVersionsDataSourceBucket ¶
func (x *VersioningPolicy) GetVersionsDataSourceBucket() string
func (*VersioningPolicy) GetVersionsDataSourceName ¶
func (x *VersioningPolicy) GetVersionsDataSourceName() string
func (*VersioningPolicy) MarshalLogObject ¶
func (policy *VersioningPolicy) MarshalLogObject(encoder zapcore.ObjectEncoder) error
MarshalLogObject implements custom marshalling for logs
func (*VersioningPolicy) ProtoMessage ¶
func (*VersioningPolicy) ProtoMessage()
func (*VersioningPolicy) ProtoReflect ¶
func (x *VersioningPolicy) ProtoReflect() protoreflect.Message
func (*VersioningPolicy) Reset ¶
func (x *VersioningPolicy) Reset()
func (*VersioningPolicy) String ¶
func (x *VersioningPolicy) String() string
func (*VersioningPolicy) Validate ¶
func (this *VersioningPolicy) Validate() error
func (*VersioningPolicy) Zap ¶
func (policy *VersioningPolicy) Zap() zapcore.Field
Zap simply returns a zapcore.Field object populated with this VersioningPolicy under a standard key
type WatchNodeRequest ¶
type WatchNodeRequest struct { Node *Node `protobuf:"bytes,1,opt,name=Node,proto3" json:"Node,omitempty"` // contains filtered or unexported fields }
Request / Responses Messages
func (*WatchNodeRequest) Descriptor
deprecated
func (*WatchNodeRequest) Descriptor() ([]byte, []int)
Deprecated: Use WatchNodeRequest.ProtoReflect.Descriptor instead.
func (*WatchNodeRequest) GetNode ¶
func (x *WatchNodeRequest) GetNode() *Node
func (*WatchNodeRequest) ProtoMessage ¶
func (*WatchNodeRequest) ProtoMessage()
func (*WatchNodeRequest) ProtoReflect ¶
func (x *WatchNodeRequest) ProtoReflect() protoreflect.Message
func (*WatchNodeRequest) Reset ¶
func (x *WatchNodeRequest) Reset()
func (*WatchNodeRequest) String ¶
func (x *WatchNodeRequest) String() string
func (*WatchNodeRequest) Validate ¶
func (this *WatchNodeRequest) Validate() error
type WatchNodeResponse ¶
type WatchNodeResponse struct { Node *Node `protobuf:"bytes,1,opt,name=Node,proto3" json:"Node,omitempty"` // contains filtered or unexported fields }
func (*WatchNodeResponse) Descriptor
deprecated
func (*WatchNodeResponse) Descriptor() ([]byte, []int)
Deprecated: Use WatchNodeResponse.ProtoReflect.Descriptor instead.
func (*WatchNodeResponse) GetNode ¶
func (x *WatchNodeResponse) GetNode() *Node
func (*WatchNodeResponse) ProtoMessage ¶
func (*WatchNodeResponse) ProtoMessage()
func (*WatchNodeResponse) ProtoReflect ¶
func (x *WatchNodeResponse) ProtoReflect() protoreflect.Message
func (*WatchNodeResponse) Reset ¶
func (x *WatchNodeResponse) Reset()
func (*WatchNodeResponse) String ¶
func (x *WatchNodeResponse) String() string
func (*WatchNodeResponse) Validate ¶
func (this *WatchNodeResponse) Validate() error
type WorkspaceRelativePath ¶
type WorkspaceRelativePath struct { // Workspace Id WsUuid string `protobuf:"bytes,1,opt,name=WsUuid,proto3" json:"WsUuid,omitempty"` // Workspace Label WsLabel string `protobuf:"bytes,2,opt,name=WsLabel,proto3" json:"WsLabel,omitempty"` // Relative Path inside workspace Path string `protobuf:"bytes,3,opt,name=Path,proto3" json:"Path,omitempty"` // Workspace slug WsSlug string `protobuf:"bytes,4,opt,name=WsSlug,proto3" json:"WsSlug,omitempty"` // Workspace Scope WsScope string `protobuf:"bytes,5,opt,name=WsScope,proto3" json:"WsScope,omitempty"` // contains filtered or unexported fields }
Used in AppearsIn to signal a node is appearing in multiple workspaces in the current context
func (*WorkspaceRelativePath) Descriptor
deprecated
func (*WorkspaceRelativePath) Descriptor() ([]byte, []int)
Deprecated: Use WorkspaceRelativePath.ProtoReflect.Descriptor instead.
func (*WorkspaceRelativePath) GetPath ¶
func (x *WorkspaceRelativePath) GetPath() string
func (*WorkspaceRelativePath) GetWsLabel ¶
func (x *WorkspaceRelativePath) GetWsLabel() string
func (*WorkspaceRelativePath) GetWsScope ¶
func (x *WorkspaceRelativePath) GetWsScope() string
func (*WorkspaceRelativePath) GetWsSlug ¶
func (x *WorkspaceRelativePath) GetWsSlug() string
func (*WorkspaceRelativePath) GetWsUuid ¶
func (x *WorkspaceRelativePath) GetWsUuid() string
func (*WorkspaceRelativePath) ProtoMessage ¶
func (*WorkspaceRelativePath) ProtoMessage()
func (*WorkspaceRelativePath) ProtoReflect ¶
func (x *WorkspaceRelativePath) ProtoReflect() protoreflect.Message
func (*WorkspaceRelativePath) Reset ¶
func (x *WorkspaceRelativePath) Reset()
func (*WorkspaceRelativePath) String ¶
func (x *WorkspaceRelativePath) String() string
func (*WorkspaceRelativePath) Validate ¶
func (this *WorkspaceRelativePath) Validate() error
type WrappingStreamerResponse ¶
type WrappingStreamerResponse struct { // Types that are assignable to Data: // *WrappingStreamerResponse_ListNodesResponse // *WrappingStreamerResponse_NodeChangeEvent Data isWrappingStreamerResponse_Data `protobuf_oneof:"Data"` Error string `protobuf:"bytes,3,opt,name=Error,proto3" json:"Error,omitempty"` // contains filtered or unexported fields }
func (*WrappingStreamerResponse) Descriptor
deprecated
func (*WrappingStreamerResponse) Descriptor() ([]byte, []int)
Deprecated: Use WrappingStreamerResponse.ProtoReflect.Descriptor instead.
func (*WrappingStreamerResponse) GetData ¶
func (m *WrappingStreamerResponse) GetData() isWrappingStreamerResponse_Data
func (*WrappingStreamerResponse) GetError ¶
func (x *WrappingStreamerResponse) GetError() string
func (*WrappingStreamerResponse) GetListNodesResponse ¶
func (x *WrappingStreamerResponse) GetListNodesResponse() *ListNodesResponse
func (*WrappingStreamerResponse) GetNodeChangeEvent ¶
func (x *WrappingStreamerResponse) GetNodeChangeEvent() *NodeChangeEvent
func (*WrappingStreamerResponse) ProtoMessage ¶
func (*WrappingStreamerResponse) ProtoMessage()
func (*WrappingStreamerResponse) ProtoReflect ¶
func (x *WrappingStreamerResponse) ProtoReflect() protoreflect.Message
func (*WrappingStreamerResponse) Reset ¶
func (x *WrappingStreamerResponse) Reset()
func (*WrappingStreamerResponse) String ¶
func (x *WrappingStreamerResponse) String() string
func (*WrappingStreamerResponse) Validate ¶
func (this *WrappingStreamerResponse) Validate() error
type WrappingStreamerResponse_ListNodesResponse ¶
type WrappingStreamerResponse_ListNodesResponse struct {
ListNodesResponse *ListNodesResponse `protobuf:"bytes,1,opt,name=ListNodesResponse,proto3,oneof"`
}
type WrappingStreamerResponse_NodeChangeEvent ¶
type WrappingStreamerResponse_NodeChangeEvent struct {
NodeChangeEvent *NodeChangeEvent `protobuf:"bytes,2,opt,name=NodeChangeEvent,proto3,oneof"`
}