Documentation ¶
Overview ¶
Package tree is a generated protocol buffer package.
It is generated from these files:
tree.proto
It has these top-level messages:
ReadNodeRequest ReadNodeResponse ListNodesRequest ListNodesResponse WrappingStreamerResponse CreateNodeRequest CreateNodeResponse UpdateNodeRequest UpdateNodeResponse DeleteNodeRequest DeleteNodeResponse IndexationSession IndexationOperation OpenSessionRequest OpenSessionResponse FlushSessionRequest FlushSessionResponse CloseSessionRequest CloseSessionResponse WatchNodeRequest WatchNodeResponse SearchRequest SearchFacet SearchResponse CreateVersionRequest CreateVersionResponse ListVersionsRequest ListVersionsResponse HeadVersionRequest HeadVersionResponse StoreVersionRequest StoreVersionResponse PruneVersionsRequest PruneVersionsResponse VersioningPolicy VersioningKeepPeriod Node WorkspaceRelativePath ChangeLog Query GeoQuery GeoPoint StreamChangesRequest NodeChangeEvent IndexEvent GetEncryptionKeyRequest GetEncryptionKeyResponse SyncChange SyncChangeNode PutSyncChangeResponse SearchSyncChangeRequest
Package tree is a generated protocol buffer package.
It is generated from these files:
tree.proto
It has these top-level messages:
ReadNodeRequest ReadNodeResponse ListNodesRequest ListNodesResponse WrappingStreamerResponse CreateNodeRequest CreateNodeResponse UpdateNodeRequest UpdateNodeResponse DeleteNodeRequest DeleteNodeResponse IndexationSession IndexationOperation OpenSessionRequest OpenSessionResponse FlushSessionRequest FlushSessionResponse CloseSessionRequest CloseSessionResponse WatchNodeRequest WatchNodeResponse SearchRequest SearchFacet SearchResponse CreateVersionRequest CreateVersionResponse ListVersionsRequest ListVersionsResponse HeadVersionRequest HeadVersionResponse StoreVersionRequest StoreVersionResponse PruneVersionsRequest PruneVersionsResponse VersioningPolicy VersioningKeepPeriod Node WorkspaceRelativePath ChangeLog Query GeoQuery GeoPoint StreamChangesRequest NodeChangeEvent IndexEvent GetEncryptionKeyRequest GetEncryptionKeyResponse SyncChange SyncChangeNode PutSyncChangeResponse SearchSyncChangeRequest
Index ¶
- Constants
- Variables
- func IgnoreNodeForOutput(ctx context.Context, node *Node) bool
- func PredefineError(f ErrorThrower)
- func RegisterFileKeyManagerHandler(s server.Server, hdlr FileKeyManagerHandler, opts ...server.HandlerOption)
- func RegisterNodeChangesStreamerHandler(s server.Server, hdlr NodeChangesStreamerHandler, opts ...server.HandlerOption)
- func RegisterNodeContentReaderHandler(s server.Server, hdlr NodeContentReaderHandler, opts ...server.HandlerOption)
- func RegisterNodeContentWriterHandler(s server.Server, hdlr NodeContentWriterHandler, opts ...server.HandlerOption)
- func RegisterNodeEventsProviderHandler(s server.Server, hdlr NodeEventsProviderHandler, opts ...server.HandlerOption)
- func RegisterNodeProviderHandler(s server.Server, hdlr NodeProviderHandler, opts ...server.HandlerOption)
- func RegisterNodeProviderStreamerHandler(s server.Server, hdlr NodeProviderStreamerHandler, ...)
- func RegisterNodeReceiverHandler(s server.Server, hdlr NodeReceiverHandler, opts ...server.HandlerOption)
- func RegisterNodeReceiverStreamHandler(s server.Server, hdlr NodeReceiverStreamHandler, opts ...server.HandlerOption)
- func RegisterNodeVersionerHandler(s server.Server, hdlr NodeVersionerHandler, opts ...server.HandlerOption)
- func RegisterSearcherHandler(s server.Server, hdlr SearcherHandler, opts ...server.HandlerOption)
- func RegisterSessionIndexerHandler(s server.Server, hdlr SessionIndexerHandler, opts ...server.HandlerOption)
- func RegisterSyncChangesHandler(s server.Server, hdlr SyncChangesHandler, opts ...server.HandlerOption)
- func ShouldError(obj interface{}, fn string, params ...interface{}) error
- type ChangeLog
- func (*ChangeLog) Descriptor() ([]byte, []int)
- func (m *ChangeLog) GetData() []byte
- func (m *ChangeLog) GetDescription() string
- func (m *ChangeLog) GetEvent() *NodeChangeEvent
- func (m *ChangeLog) GetMTime() int64
- func (m *ChangeLog) GetOwnerUuid() string
- func (m *ChangeLog) GetSize() int64
- func (m *ChangeLog) GetUuid() string
- func (log *ChangeLog) MarshalLogObject(encoder zapcore.ObjectEncoder) error
- func (*ChangeLog) ProtoMessage()
- func (m *ChangeLog) Reset()
- func (m *ChangeLog) String() string
- func (this *ChangeLog) Validate() error
- func (log *ChangeLog) Zap() zapcore.Field
- type CloseSessionRequest
- type CloseSessionResponse
- func (*CloseSessionResponse) Descriptor() ([]byte, []int)
- func (m *CloseSessionResponse) GetSession() *IndexationSession
- func (*CloseSessionResponse) ProtoMessage()
- func (m *CloseSessionResponse) Reset()
- func (m *CloseSessionResponse) String() string
- func (this *CloseSessionResponse) Validate() error
- type CreateNodeRequest
- func (*CreateNodeRequest) Descriptor() ([]byte, []int)
- func (m *CreateNodeRequest) GetIndexationSession() string
- func (m *CreateNodeRequest) GetNode() *Node
- func (m *CreateNodeRequest) GetSilent() bool
- func (m *CreateNodeRequest) GetUpdateIfExists() bool
- func (*CreateNodeRequest) ProtoMessage()
- func (m *CreateNodeRequest) Reset()
- func (m *CreateNodeRequest) String() string
- func (this *CreateNodeRequest) Validate() error
- type CreateNodeResponse
- func (*CreateNodeResponse) Descriptor() ([]byte, []int)
- func (m *CreateNodeResponse) GetNode() *Node
- func (m *CreateNodeResponse) GetSuccess() bool
- func (*CreateNodeResponse) ProtoMessage()
- func (m *CreateNodeResponse) Reset()
- func (m *CreateNodeResponse) String() string
- func (this *CreateNodeResponse) Validate() error
- type CreateVersionRequest
- func (*CreateVersionRequest) Descriptor() ([]byte, []int)
- func (m *CreateVersionRequest) GetNode() *Node
- func (m *CreateVersionRequest) GetTriggerEvent() *NodeChangeEvent
- func (*CreateVersionRequest) ProtoMessage()
- func (m *CreateVersionRequest) Reset()
- func (m *CreateVersionRequest) String() string
- func (this *CreateVersionRequest) Validate() error
- type CreateVersionResponse
- type DeleteNodeRequest
- func (*DeleteNodeRequest) Descriptor() ([]byte, []int)
- func (m *DeleteNodeRequest) GetIndexationSession() string
- func (m *DeleteNodeRequest) GetNode() *Node
- func (m *DeleteNodeRequest) GetSilent() bool
- func (*DeleteNodeRequest) ProtoMessage()
- func (m *DeleteNodeRequest) Reset()
- func (m *DeleteNodeRequest) String() string
- func (this *DeleteNodeRequest) Validate() error
- type DeleteNodeResponse
- type ErrorThrower
- type FileKeyManager
- type FileKeyManagerClient
- type FileKeyManagerHandler
- type FlushSessionRequest
- type FlushSessionResponse
- func (*FlushSessionResponse) Descriptor() ([]byte, []int)
- func (m *FlushSessionResponse) GetSession() *IndexationSession
- func (*FlushSessionResponse) ProtoMessage()
- func (m *FlushSessionResponse) Reset()
- func (m *FlushSessionResponse) String() string
- func (this *FlushSessionResponse) Validate() error
- type GeoPoint
- type GeoQuery
- func (*GeoQuery) Descriptor() ([]byte, []int)
- func (m *GeoQuery) GetBottomRight() *GeoPoint
- func (m *GeoQuery) GetCenter() *GeoPoint
- func (m *GeoQuery) GetDistance() string
- func (m *GeoQuery) GetTopLeft() *GeoPoint
- func (*GeoQuery) ProtoMessage()
- func (m *GeoQuery) Reset()
- func (m *GeoQuery) String() string
- func (this *GeoQuery) Validate() error
- type GetEncryptionKeyRequest
- func (*GetEncryptionKeyRequest) Descriptor() ([]byte, []int)
- func (m *GetEncryptionKeyRequest) GetCreate() bool
- func (m *GetEncryptionKeyRequest) GetNode() *Node
- func (m *GetEncryptionKeyRequest) GetPassword() string
- func (m *GetEncryptionKeyRequest) GetUser() string
- func (*GetEncryptionKeyRequest) ProtoMessage()
- func (m *GetEncryptionKeyRequest) Reset()
- func (m *GetEncryptionKeyRequest) String() string
- func (this *GetEncryptionKeyRequest) Validate() error
- type GetEncryptionKeyResponse
- func (*GetEncryptionKeyResponse) Descriptor() ([]byte, []int)
- func (m *GetEncryptionKeyResponse) GetKey() []byte
- func (*GetEncryptionKeyResponse) ProtoMessage()
- func (m *GetEncryptionKeyResponse) Reset()
- func (m *GetEncryptionKeyResponse) String() string
- func (this *GetEncryptionKeyResponse) Validate() error
- type HeadVersionRequest
- func (*HeadVersionRequest) Descriptor() ([]byte, []int)
- func (m *HeadVersionRequest) GetNode() *Node
- func (m *HeadVersionRequest) GetVersionId() string
- func (*HeadVersionRequest) ProtoMessage()
- func (m *HeadVersionRequest) Reset()
- func (m *HeadVersionRequest) String() string
- func (this *HeadVersionRequest) Validate() error
- type HeadVersionResponse
- type IndexEvent
- func (*IndexEvent) Descriptor() ([]byte, []int)
- func (m *IndexEvent) GetDataSourceName() string
- func (m *IndexEvent) GetErrorDetected() bool
- func (m *IndexEvent) GetErrorPath() string
- func (m *IndexEvent) GetSessionForceClose() string
- func (*IndexEvent) ProtoMessage()
- func (m *IndexEvent) Reset()
- func (m *IndexEvent) String() string
- func (this *IndexEvent) Validate() error
- type IndexableNode
- type IndexationOperation
- func (*IndexationOperation) Descriptor() ([]byte, []int)
- func (m *IndexationOperation) GetCursor() int64
- func (m *IndexationOperation) GetDescription() string
- func (m *IndexationOperation) GetSessionUuid() string
- func (*IndexationOperation) ProtoMessage()
- func (m *IndexationOperation) Reset()
- func (m *IndexationOperation) String() string
- func (this *IndexationOperation) Validate() error
- type IndexationSession
- func (*IndexationSession) Descriptor() ([]byte, []int)
- func (m *IndexationSession) GetCurrentOperationCount() int64
- func (m *IndexationSession) GetDescription() string
- func (m *IndexationSession) GetExpectedOperationsCount() int64
- func (m *IndexationSession) GetRootNode() *Node
- func (m *IndexationSession) GetSilent() bool
- func (m *IndexationSession) GetUuid() string
- func (*IndexationSession) ProtoMessage()
- func (m *IndexationSession) Reset()
- func (m *IndexationSession) String() string
- func (this *IndexationSession) Validate() error
- type ListNodesRequest
- func (*ListNodesRequest) Descriptor() ([]byte, []int)
- func (m *ListNodesRequest) GetAncestors() bool
- func (m *ListNodesRequest) GetFilterType() NodeType
- func (m *ListNodesRequest) GetLimit() int64
- func (m *ListNodesRequest) GetNode() *Node
- func (m *ListNodesRequest) GetOffset() int64
- func (m *ListNodesRequest) GetRecursive() bool
- func (m *ListNodesRequest) GetWithCommits() bool
- func (m *ListNodesRequest) GetWithVersions() bool
- func (*ListNodesRequest) ProtoMessage()
- func (m *ListNodesRequest) Reset()
- func (m *ListNodesRequest) String() string
- func (this *ListNodesRequest) Validate() error
- type ListNodesResponse
- type ListVersionsRequest
- type ListVersionsResponse
- type MetaFilter
- type Node
- func (node *Node) AllMetaDeserialized(excludes map[string]struct{}) map[string]interface{}
- func (node *Node) Clone() *Node
- func (*Node) Descriptor() ([]byte, []int)
- func (m *Node) GetAppearsIn() []*WorkspaceRelativePath
- func (m *Node) GetCommits() []*ChangeLog
- func (m *Node) GetEtag() string
- func (m *Node) GetMTime() int64
- func (node *Node) GetMeta(namespace string, jsonStruc interface{}) error
- func (m *Node) GetMetaStore() map[string]string
- func (node *Node) GetModTime() time.Time
- func (m *Node) GetMode() int32
- func (m *Node) GetPath() string
- func (m *Node) GetSize() int64
- func (node *Node) GetStringMeta(namespace string) string
- func (m *Node) GetType() NodeType
- func (m *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) ProtoMessage()
- func (m *Node) Reset()
- func (node *Node) SetMeta(namespace string, jsonMeta interface{}) (err error)
- func (m *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)
- func (m *NodeChangeEvent) GetMetadata() map[string]string
- func (m *NodeChangeEvent) GetOptimistic() bool
- func (m *NodeChangeEvent) GetSilent() bool
- func (m *NodeChangeEvent) GetSource() *Node
- func (m *NodeChangeEvent) GetTarget() *Node
- func (m *NodeChangeEvent) GetType() NodeChangeEvent_EventType
- func (*NodeChangeEvent) ProtoMessage()
- func (m *NodeChangeEvent) Reset()
- func (m *NodeChangeEvent) String() string
- func (this *NodeChangeEvent) Validate() error
- func (msg *NodeChangeEvent) Zap() zapcore.Field
- type NodeChangeEvent_EventType
- type NodeChangesStreamer
- type NodeChangesStreamerClient
- type NodeChangesStreamerHandler
- type NodeChangesStreamer_StreamChangesClient
- type NodeChangesStreamer_StreamChangesStream
- type NodeContentReader
- type NodeContentReaderClient
- type NodeContentReaderHandler
- type NodeContentWriter
- type NodeContentWriterClient
- type NodeContentWriterHandler
- type NodeEventsProvider
- type NodeEventsProviderClient
- type NodeEventsProviderHandler
- type NodeEventsProvider_WatchNodeClient
- type NodeEventsProvider_WatchNodeStream
- type NodeProvider
- type NodeProviderClient
- type NodeProviderHandler
- type NodeProviderMock
- type NodeProviderStreamer
- type NodeProviderStreamerClient
- type NodeProviderStreamerHandler
- type NodeProviderStreamer_ReadNodeStreamClient
- type NodeProviderStreamer_ReadNodeStreamStream
- type NodeProvider_ListNodesClient
- type NodeProvider_ListNodesStream
- type NodeReceiver
- func (h *NodeReceiver) CreateNode(ctx context.Context, in *CreateNodeRequest, out *CreateNodeResponse) error
- func (h *NodeReceiver) DeleteNode(ctx context.Context, in *DeleteNodeRequest, out *DeleteNodeResponse) error
- func (h *NodeReceiver) UpdateNode(ctx context.Context, in *UpdateNodeRequest, out *UpdateNodeResponse) error
- type NodeReceiverClient
- type NodeReceiverHandler
- type NodeReceiverMock
- func (m *NodeReceiverMock) CreateNode(ctx context.Context, in *CreateNodeRequest, opts ...client.CallOption) (*CreateNodeResponse, error)
- func (m *NodeReceiverMock) DeleteNode(ctx context.Context, in *DeleteNodeRequest, opts ...client.CallOption) (*DeleteNodeResponse, error)
- func (m *NodeReceiverMock) UpdateNode(ctx context.Context, in *UpdateNodeRequest, opts ...client.CallOption) (*UpdateNodeResponse, error)
- type NodeReceiverStream
- type NodeReceiverStreamClient
- type NodeReceiverStreamHandler
- type NodeReceiverStream_CreateNodeStreamClient
- type NodeReceiverStream_CreateNodeStreamStream
- type NodeReceiverStream_DeleteNodeStreamClient
- type NodeReceiverStream_DeleteNodeStreamStream
- type NodeReceiverStream_UpdateNodeStreamClient
- type NodeReceiverStream_UpdateNodeStreamStream
- type NodeType
- type NodeVersioner
- func (h *NodeVersioner) CreateVersion(ctx context.Context, in *CreateVersionRequest, out *CreateVersionResponse) error
- func (h *NodeVersioner) HeadVersion(ctx context.Context, in *HeadVersionRequest, out *HeadVersionResponse) error
- func (h *NodeVersioner) ListVersions(ctx context.Context, stream server.Streamer) error
- func (h *NodeVersioner) PruneVersions(ctx context.Context, in *PruneVersionsRequest, out *PruneVersionsResponse) error
- func (h *NodeVersioner) StoreVersion(ctx context.Context, in *StoreVersionRequest, out *StoreVersionResponse) error
- type NodeVersionerClient
- type NodeVersionerHandler
- type NodeVersioner_ListVersionsClient
- type NodeVersioner_ListVersionsStream
- type OpenSessionRequest
- type OpenSessionResponse
- type PruneVersionsRequest
- func (*PruneVersionsRequest) Descriptor() ([]byte, []int)
- func (m *PruneVersionsRequest) GetAllDeletedNodes() bool
- func (m *PruneVersionsRequest) GetUniqueNode() *Node
- func (*PruneVersionsRequest) ProtoMessage()
- func (m *PruneVersionsRequest) Reset()
- func (m *PruneVersionsRequest) String() string
- func (this *PruneVersionsRequest) Validate() error
- type PruneVersionsResponse
- func (*PruneVersionsResponse) Descriptor() ([]byte, []int)
- func (m *PruneVersionsResponse) GetDeletedVersions() []string
- func (*PruneVersionsResponse) ProtoMessage()
- func (m *PruneVersionsResponse) Reset()
- func (m *PruneVersionsResponse) String() string
- func (this *PruneVersionsResponse) Validate() error
- type PutSyncChangeResponse
- func (*PutSyncChangeResponse) Descriptor() ([]byte, []int)
- func (m *PutSyncChangeResponse) GetMsg() string
- func (m *PutSyncChangeResponse) GetSuccess() bool
- func (*PutSyncChangeResponse) ProtoMessage()
- func (m *PutSyncChangeResponse) Reset()
- func (m *PutSyncChangeResponse) String() string
- func (this *PutSyncChangeResponse) Validate() error
- type Query
- func (*Query) Descriptor() ([]byte, []int)
- func (m *Query) GetContent() string
- func (m *Query) GetDurationDate() string
- func (m *Query) GetExtension() string
- func (m *Query) GetFileName() string
- func (m *Query) GetFileNameOrContent() string
- func (m *Query) GetFreeString() string
- func (m *Query) GetGeoQuery() *GeoQuery
- func (m *Query) GetMaxDate() int64
- func (m *Query) GetMaxSize() int64
- func (m *Query) GetMinDate() int64
- func (m *Query) GetMinSize() int64
- func (m *Query) GetNot() bool
- func (m *Query) GetPathDepth() int32
- func (m *Query) GetPathPrefix() []string
- func (m *Query) GetPaths() []string
- func (m *Query) GetType() NodeType
- func (m *Query) GetUUIDs() []string
- func (m *Query) ParseDurationDate(ref ...time.Time) error
- func (*Query) ProtoMessage()
- func (m *Query) Reset()
- func (m *Query) String() string
- func (this *Query) Validate() error
- type ReadNodeRequest
- func (*ReadNodeRequest) Descriptor() ([]byte, []int)
- func (m *ReadNodeRequest) GetNode() *Node
- func (m *ReadNodeRequest) GetObjectStats() bool
- func (m *ReadNodeRequest) GetWithCommits() bool
- func (m *ReadNodeRequest) GetWithExtendedStats() bool
- func (*ReadNodeRequest) ProtoMessage()
- func (m *ReadNodeRequest) Reset()
- func (m *ReadNodeRequest) String() string
- func (this *ReadNodeRequest) Validate() error
- type ReadNodeResponse
- func (*ReadNodeResponse) Descriptor() ([]byte, []int)
- func (m *ReadNodeResponse) GetNode() *Node
- func (m *ReadNodeResponse) GetSuccess() bool
- func (*ReadNodeResponse) ProtoMessage()
- func (m *ReadNodeResponse) Reset()
- func (m *ReadNodeResponse) String() string
- func (this *ReadNodeResponse) Validate() error
- type SearchFacet
- func (*SearchFacet) Descriptor() ([]byte, []int)
- func (m *SearchFacet) GetCount() int32
- func (m *SearchFacet) GetEnd() int32
- func (m *SearchFacet) GetFieldName() string
- func (m *SearchFacet) GetLabel() string
- func (m *SearchFacet) GetMax() int64
- func (m *SearchFacet) GetMin() int64
- func (m *SearchFacet) GetStart() int32
- func (m *SearchFacet) GetTerm() string
- func (*SearchFacet) ProtoMessage()
- func (m *SearchFacet) Reset()
- func (m *SearchFacet) String() string
- func (this *SearchFacet) Validate() error
- type SearchRequest
- func (*SearchRequest) Descriptor() ([]byte, []int)
- func (m *SearchRequest) GetDetails() bool
- func (m *SearchRequest) GetFrom() int32
- func (m *SearchRequest) GetQuery() *Query
- func (m *SearchRequest) GetSize() int32
- func (*SearchRequest) ProtoMessage()
- func (m *SearchRequest) Reset()
- func (m *SearchRequest) String() string
- func (this *SearchRequest) Validate() error
- type SearchResponse
- type SearchSyncChangeRequest
- func (*SearchSyncChangeRequest) Descriptor() ([]byte, []int)
- func (m *SearchSyncChangeRequest) GetFlatten() bool
- func (m *SearchSyncChangeRequest) GetLastSeqOnly() bool
- func (m *SearchSyncChangeRequest) GetPrefix() string
- func (m *SearchSyncChangeRequest) GetSeq() uint64
- func (*SearchSyncChangeRequest) ProtoMessage()
- func (m *SearchSyncChangeRequest) Reset()
- func (m *SearchSyncChangeRequest) String() string
- func (this *SearchSyncChangeRequest) Validate() error
- type Searcher
- type SearcherClient
- type SearcherHandler
- type Searcher_SearchClient
- type Searcher_SearchStream
- type SessionIndexer
- func (h *SessionIndexer) CloseSession(ctx context.Context, in *CloseSessionRequest, out *CloseSessionResponse) error
- func (h *SessionIndexer) FlushSession(ctx context.Context, in *FlushSessionRequest, out *FlushSessionResponse) error
- func (h *SessionIndexer) OpenSession(ctx context.Context, in *OpenSessionRequest, out *OpenSessionResponse) error
- type SessionIndexerClient
- type SessionIndexerHandler
- type SessionIndexerMock
- func (s *SessionIndexerMock) CloseSession(ctx context.Context, in *CloseSessionRequest, opts ...client.CallOption) (*CloseSessionResponse, error)
- func (s *SessionIndexerMock) FlushSession(ctx context.Context, in *FlushSessionRequest, opts ...client.CallOption) (*FlushSessionResponse, error)
- func (s *SessionIndexerMock) OpenSession(ctx context.Context, in *OpenSessionRequest, opts ...client.CallOption) (*OpenSessionResponse, error)
- type StoreVersionRequest
- func (*StoreVersionRequest) Descriptor() ([]byte, []int)
- func (m *StoreVersionRequest) GetNode() *Node
- func (m *StoreVersionRequest) GetVersion() *ChangeLog
- func (*StoreVersionRequest) ProtoMessage()
- func (m *StoreVersionRequest) Reset()
- func (m *StoreVersionRequest) String() string
- func (this *StoreVersionRequest) Validate() error
- type StoreVersionResponse
- func (*StoreVersionResponse) Descriptor() ([]byte, []int)
- func (m *StoreVersionResponse) GetPruneVersions() []*ChangeLog
- func (m *StoreVersionResponse) GetSuccess() bool
- func (*StoreVersionResponse) ProtoMessage()
- func (m *StoreVersionResponse) Reset()
- func (m *StoreVersionResponse) String() string
- func (this *StoreVersionResponse) Validate() error
- type StreamChangesRequest
- type StreamerMock
- type SyncChange
- func (*SyncChange) Descriptor() ([]byte, []int)
- func (m *SyncChange) GetNode() *SyncChangeNode
- func (m *SyncChange) GetNodeId() string
- func (m *SyncChange) GetSeq() uint64
- func (m *SyncChange) GetSource() string
- func (m *SyncChange) GetTarget() string
- func (m *SyncChange) GetType() SyncChange_Type
- func (*SyncChange) ProtoMessage()
- func (m *SyncChange) Reset()
- func (m *SyncChange) String() string
- func (this *SyncChange) Validate() error
- type SyncChangeNode
- func (*SyncChangeNode) Descriptor() ([]byte, []int)
- func (m *SyncChangeNode) GetBytesize() int64
- func (m *SyncChangeNode) GetMd5() string
- func (m *SyncChangeNode) GetMtime() int64
- func (m *SyncChangeNode) GetNodePath() string
- func (m *SyncChangeNode) GetRepositoryIdentifier() string
- func (*SyncChangeNode) ProtoMessage()
- func (m *SyncChangeNode) Reset()
- func (m *SyncChangeNode) String() string
- func (this *SyncChangeNode) Validate() error
- type SyncChange_Type
- type SyncChanges
- type SyncChangesClient
- type SyncChangesHandler
- type SyncChanges_PutClient
- type SyncChanges_PutStream
- type SyncChanges_SearchClient
- type SyncChanges_SearchStream
- type UpdateNodeRequest
- func (*UpdateNodeRequest) Descriptor() ([]byte, []int)
- func (m *UpdateNodeRequest) GetFrom() *Node
- func (m *UpdateNodeRequest) GetIndexationSession() string
- func (m *UpdateNodeRequest) GetSilent() bool
- func (m *UpdateNodeRequest) GetTo() *Node
- func (*UpdateNodeRequest) ProtoMessage()
- func (m *UpdateNodeRequest) Reset()
- func (m *UpdateNodeRequest) String() string
- func (this *UpdateNodeRequest) Validate() error
- type UpdateNodeResponse
- func (*UpdateNodeResponse) Descriptor() ([]byte, []int)
- func (m *UpdateNodeResponse) GetNode() *Node
- func (m *UpdateNodeResponse) GetSuccess() bool
- func (*UpdateNodeResponse) ProtoMessage()
- func (m *UpdateNodeResponse) Reset()
- func (m *UpdateNodeResponse) String() string
- func (this *UpdateNodeResponse) Validate() error
- type VersioningKeepPeriod
- func (*VersioningKeepPeriod) Descriptor() ([]byte, []int)
- func (m *VersioningKeepPeriod) GetIntervalStart() string
- func (m *VersioningKeepPeriod) GetMaxNumber() int32
- func (*VersioningKeepPeriod) ProtoMessage()
- func (m *VersioningKeepPeriod) Reset()
- func (m *VersioningKeepPeriod) String() string
- func (this *VersioningKeepPeriod) Validate() error
- type VersioningPolicy
- func (*VersioningPolicy) Descriptor() ([]byte, []int)
- func (m *VersioningPolicy) GetDescription() string
- func (m *VersioningPolicy) GetIgnoreFilesGreaterThan() int64
- func (m *VersioningPolicy) GetKeepPeriods() []*VersioningKeepPeriod
- func (m *VersioningPolicy) GetMaxSizePerFile() int64
- func (m *VersioningPolicy) GetMaxTotalSize() int64
- func (m *VersioningPolicy) GetName() string
- func (m *VersioningPolicy) GetUuid() string
- func (m *VersioningPolicy) GetVersionsDataSourceBucket() string
- func (m *VersioningPolicy) GetVersionsDataSourceName() string
- func (policy *VersioningPolicy) MarshalLogObject(encoder zapcore.ObjectEncoder) error
- func (*VersioningPolicy) ProtoMessage()
- func (m *VersioningPolicy) Reset()
- func (m *VersioningPolicy) String() string
- func (this *VersioningPolicy) Validate() error
- func (policy *VersioningPolicy) Zap() zapcore.Field
- type WatchNodeRequest
- type WatchNodeResponse
- type WorkspaceRelativePath
- func (*WorkspaceRelativePath) Descriptor() ([]byte, []int)
- func (m *WorkspaceRelativePath) GetPath() string
- func (m *WorkspaceRelativePath) GetWsLabel() string
- func (m *WorkspaceRelativePath) GetWsScope() string
- func (m *WorkspaceRelativePath) GetWsSlug() string
- func (m *WorkspaceRelativePath) GetWsUuid() string
- func (*WorkspaceRelativePath) ProtoMessage()
- func (m *WorkspaceRelativePath) Reset()
- func (m *WorkspaceRelativePath) String() string
- func (this *WorkspaceRelativePath) Validate() error
- type WrappingStreamerResponse
- func (*WrappingStreamerResponse) Descriptor() ([]byte, []int)
- func (m *WrappingStreamerResponse) GetData() isWrappingStreamerResponse_Data
- func (m *WrappingStreamerResponse) GetError() string
- func (m *WrappingStreamerResponse) GetListNodesResponse() *ListNodesResponse
- func (m *WrappingStreamerResponse) GetNodeChangeEvent() *NodeChangeEvent
- func (*WrappingStreamerResponse) ProtoMessage()
- func (m *WrappingStreamerResponse) Reset()
- func (m *WrappingStreamerResponse) String() string
- func (this *WrappingStreamerResponse) Validate() error
- func (*WrappingStreamerResponse) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)
- type WrappingStreamerResponse_ListNodesResponse
- type WrappingStreamerResponse_NodeChangeEvent
Constants ¶
const ( MetaFilterGrep = "grep" MetaFilterNoGrep = "no-grep" MetaFilterTime = "time" MetaFilterSize = "size" MetaFilterDepth = "depth" )
Variables ¶
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",
}
var 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,
}
var NodeType_name = map[int32]string{
0: "UNKNOWN",
1: "LEAF",
2: "COLLECTION",
}
var NodeType_value = map[string]int32{
"UNKNOWN": 0,
"LEAF": 1,
"COLLECTION": 2,
}
var SyncChange_Type_name = map[int32]string{
0: "unknown",
1: "create",
2: "delete",
3: "path",
4: "content",
}
var SyncChange_Type_value = map[string]int32{
"unknown": 0,
"create": 1,
"delete": 2,
"path": 3,
"content": 4,
}
Functions ¶
func IgnoreNodeForOutput ¶ added in v1.4.1
IgnoreNodeForOutput checks wether a node shall be ignored for outputs sent to end user (typically websocket events, activities, etc)
func PredefineError ¶
func PredefineError(f ErrorThrower)
func RegisterFileKeyManagerHandler ¶
func RegisterFileKeyManagerHandler(s server.Server, hdlr FileKeyManagerHandler, opts ...server.HandlerOption)
func RegisterNodeChangesStreamerHandler ¶ added in v1.6.2
func RegisterNodeChangesStreamerHandler(s server.Server, hdlr NodeChangesStreamerHandler, opts ...server.HandlerOption)
func RegisterNodeContentReaderHandler ¶
func RegisterNodeContentReaderHandler(s server.Server, hdlr NodeContentReaderHandler, opts ...server.HandlerOption)
func RegisterNodeContentWriterHandler ¶
func RegisterNodeContentWriterHandler(s server.Server, hdlr NodeContentWriterHandler, opts ...server.HandlerOption)
func RegisterNodeEventsProviderHandler ¶
func RegisterNodeEventsProviderHandler(s server.Server, hdlr NodeEventsProviderHandler, opts ...server.HandlerOption)
func RegisterNodeProviderHandler ¶
func RegisterNodeProviderHandler(s server.Server, hdlr NodeProviderHandler, opts ...server.HandlerOption)
func RegisterNodeProviderStreamerHandler ¶
func RegisterNodeProviderStreamerHandler(s server.Server, hdlr NodeProviderStreamerHandler, opts ...server.HandlerOption)
func RegisterNodeReceiverHandler ¶
func RegisterNodeReceiverHandler(s server.Server, hdlr NodeReceiverHandler, opts ...server.HandlerOption)
func RegisterNodeReceiverStreamHandler ¶
func RegisterNodeReceiverStreamHandler(s server.Server, hdlr NodeReceiverStreamHandler, opts ...server.HandlerOption)
func RegisterNodeVersionerHandler ¶
func RegisterNodeVersionerHandler(s server.Server, hdlr NodeVersionerHandler, opts ...server.HandlerOption)
func RegisterSearcherHandler ¶
func RegisterSearcherHandler(s server.Server, hdlr SearcherHandler, opts ...server.HandlerOption)
func RegisterSessionIndexerHandler ¶
func RegisterSessionIndexerHandler(s server.Server, hdlr SessionIndexerHandler, opts ...server.HandlerOption)
func RegisterSyncChangesHandler ¶
func RegisterSyncChangesHandler(s server.Server, hdlr SyncChangesHandler, opts ...server.HandlerOption)
func ShouldError ¶
Types ¶
type ChangeLog ¶
type ChangeLog struct { // Unique commit ID Uuid string `protobuf:"bytes,1,opt,name=Uuid" json:"Uuid,omitempty"` // Human-readable description of what happened Description string `protobuf:"bytes,2,opt,name=Description" json:"Description,omitempty"` // Unix Timestamp MTime int64 `protobuf:"varint,3,opt,name=MTime" json:"MTime,omitempty"` // Content Size at that moment Size int64 `protobuf:"varint,4,opt,name=Size" 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" json:"OwnerUuid,omitempty"` // Event that triggered this change Event *NodeChangeEvent `protobuf:"bytes,7,opt,name=Event" json:"Event,omitempty"` }
func (*ChangeLog) Descriptor ¶
func (*ChangeLog) GetDescription ¶
func (*ChangeLog) GetEvent ¶
func (m *ChangeLog) GetEvent() *NodeChangeEvent
func (*ChangeLog) GetOwnerUuid ¶
func (*ChangeLog) MarshalLogObject ¶ added in v1.5.0
func (log *ChangeLog) MarshalLogObject(encoder zapcore.ObjectEncoder) error
MarshalLogObject implements custom marshalling for logs
func (*ChangeLog) ProtoMessage ¶
func (*ChangeLog) ProtoMessage()
type CloseSessionRequest ¶
type CloseSessionRequest struct {
Session *IndexationSession `protobuf:"bytes,1,opt,name=Session" json:"Session,omitempty"`
}
func (*CloseSessionRequest) Descriptor ¶
func (*CloseSessionRequest) Descriptor() ([]byte, []int)
func (*CloseSessionRequest) GetSession ¶
func (m *CloseSessionRequest) GetSession() *IndexationSession
func (*CloseSessionRequest) ProtoMessage ¶
func (*CloseSessionRequest) ProtoMessage()
func (*CloseSessionRequest) Reset ¶
func (m *CloseSessionRequest) Reset()
func (*CloseSessionRequest) String ¶
func (m *CloseSessionRequest) String() string
func (*CloseSessionRequest) Validate ¶ added in v1.6.2
func (this *CloseSessionRequest) Validate() error
type CloseSessionResponse ¶
type CloseSessionResponse struct {
Session *IndexationSession `protobuf:"bytes,1,opt,name=Session" json:"Session,omitempty"`
}
func (*CloseSessionResponse) Descriptor ¶
func (*CloseSessionResponse) Descriptor() ([]byte, []int)
func (*CloseSessionResponse) GetSession ¶
func (m *CloseSessionResponse) GetSession() *IndexationSession
func (*CloseSessionResponse) ProtoMessage ¶
func (*CloseSessionResponse) ProtoMessage()
func (*CloseSessionResponse) Reset ¶
func (m *CloseSessionResponse) Reset()
func (*CloseSessionResponse) String ¶
func (m *CloseSessionResponse) String() string
func (*CloseSessionResponse) Validate ¶ added in v1.6.2
func (this *CloseSessionResponse) Validate() error
type CreateNodeRequest ¶
type CreateNodeRequest struct { Node *Node `protobuf:"bytes,1,opt,name=Node" json:"Node,omitempty"` UpdateIfExists bool `protobuf:"varint,2,opt,name=UpdateIfExists" json:"UpdateIfExists,omitempty"` IndexationSession string `protobuf:"bytes,3,opt,name=IndexationSession" json:"IndexationSession,omitempty"` Silent bool `protobuf:"varint,4,opt,name=Silent" json:"Silent,omitempty"` }
Request / Responses Messages
func (*CreateNodeRequest) Descriptor ¶
func (*CreateNodeRequest) Descriptor() ([]byte, []int)
func (*CreateNodeRequest) GetIndexationSession ¶
func (m *CreateNodeRequest) GetIndexationSession() string
func (*CreateNodeRequest) GetNode ¶
func (m *CreateNodeRequest) GetNode() *Node
func (*CreateNodeRequest) GetSilent ¶ added in v1.2.0
func (m *CreateNodeRequest) GetSilent() bool
func (*CreateNodeRequest) GetUpdateIfExists ¶
func (m *CreateNodeRequest) GetUpdateIfExists() bool
func (*CreateNodeRequest) ProtoMessage ¶
func (*CreateNodeRequest) ProtoMessage()
func (*CreateNodeRequest) Reset ¶
func (m *CreateNodeRequest) Reset()
func (*CreateNodeRequest) String ¶
func (m *CreateNodeRequest) String() string
func (*CreateNodeRequest) Validate ¶ added in v1.6.2
func (this *CreateNodeRequest) Validate() error
type CreateNodeResponse ¶
type CreateNodeResponse struct { Success bool `protobuf:"varint,1,opt,name=Success" json:"Success,omitempty"` Node *Node `protobuf:"bytes,2,opt,name=Node" json:"Node,omitempty"` }
func (*CreateNodeResponse) Descriptor ¶
func (*CreateNodeResponse) Descriptor() ([]byte, []int)
func (*CreateNodeResponse) GetNode ¶
func (m *CreateNodeResponse) GetNode() *Node
func (*CreateNodeResponse) GetSuccess ¶
func (m *CreateNodeResponse) GetSuccess() bool
func (*CreateNodeResponse) ProtoMessage ¶
func (*CreateNodeResponse) ProtoMessage()
func (*CreateNodeResponse) Reset ¶
func (m *CreateNodeResponse) Reset()
func (*CreateNodeResponse) String ¶
func (m *CreateNodeResponse) String() string
func (*CreateNodeResponse) Validate ¶ added in v1.6.2
func (this *CreateNodeResponse) Validate() error
type CreateVersionRequest ¶
type CreateVersionRequest struct { Node *Node `protobuf:"bytes,1,opt,name=Node" json:"Node,omitempty"` TriggerEvent *NodeChangeEvent `protobuf:"bytes,2,opt,name=TriggerEvent" json:"TriggerEvent,omitempty"` }
func (*CreateVersionRequest) Descriptor ¶
func (*CreateVersionRequest) Descriptor() ([]byte, []int)
func (*CreateVersionRequest) GetNode ¶
func (m *CreateVersionRequest) GetNode() *Node
func (*CreateVersionRequest) GetTriggerEvent ¶
func (m *CreateVersionRequest) GetTriggerEvent() *NodeChangeEvent
func (*CreateVersionRequest) ProtoMessage ¶
func (*CreateVersionRequest) ProtoMessage()
func (*CreateVersionRequest) Reset ¶
func (m *CreateVersionRequest) Reset()
func (*CreateVersionRequest) String ¶
func (m *CreateVersionRequest) String() string
func (*CreateVersionRequest) Validate ¶ added in v1.6.2
func (this *CreateVersionRequest) Validate() error
type CreateVersionResponse ¶
type CreateVersionResponse struct {
Version *ChangeLog `protobuf:"bytes,1,opt,name=Version" json:"Version,omitempty"`
}
func (*CreateVersionResponse) Descriptor ¶
func (*CreateVersionResponse) Descriptor() ([]byte, []int)
func (*CreateVersionResponse) GetVersion ¶
func (m *CreateVersionResponse) GetVersion() *ChangeLog
func (*CreateVersionResponse) ProtoMessage ¶
func (*CreateVersionResponse) ProtoMessage()
func (*CreateVersionResponse) Reset ¶
func (m *CreateVersionResponse) Reset()
func (*CreateVersionResponse) String ¶
func (m *CreateVersionResponse) String() string
func (*CreateVersionResponse) Validate ¶ added in v1.6.2
func (this *CreateVersionResponse) Validate() error
type DeleteNodeRequest ¶
type DeleteNodeRequest struct { Node *Node `protobuf:"bytes,1,opt,name=Node" json:"Node,omitempty"` IndexationSession string `protobuf:"bytes,2,opt,name=IndexationSession" json:"IndexationSession,omitempty"` Silent bool `protobuf:"varint,3,opt,name=Silent" json:"Silent,omitempty"` }
func (*DeleteNodeRequest) Descriptor ¶
func (*DeleteNodeRequest) Descriptor() ([]byte, []int)
func (*DeleteNodeRequest) GetIndexationSession ¶
func (m *DeleteNodeRequest) GetIndexationSession() string
func (*DeleteNodeRequest) GetNode ¶
func (m *DeleteNodeRequest) GetNode() *Node
func (*DeleteNodeRequest) GetSilent ¶ added in v1.2.0
func (m *DeleteNodeRequest) GetSilent() bool
func (*DeleteNodeRequest) ProtoMessage ¶
func (*DeleteNodeRequest) ProtoMessage()
func (*DeleteNodeRequest) Reset ¶
func (m *DeleteNodeRequest) Reset()
func (*DeleteNodeRequest) String ¶
func (m *DeleteNodeRequest) String() string
func (*DeleteNodeRequest) Validate ¶ added in v1.6.2
func (this *DeleteNodeRequest) Validate() error
type DeleteNodeResponse ¶
type DeleteNodeResponse struct {
Success bool `protobuf:"varint,1,opt,name=Success" json:"Success,omitempty"`
}
func (*DeleteNodeResponse) Descriptor ¶
func (*DeleteNodeResponse) Descriptor() ([]byte, []int)
func (*DeleteNodeResponse) GetSuccess ¶
func (m *DeleteNodeResponse) GetSuccess() bool
func (*DeleteNodeResponse) ProtoMessage ¶
func (*DeleteNodeResponse) ProtoMessage()
func (*DeleteNodeResponse) Reset ¶
func (m *DeleteNodeResponse) Reset()
func (*DeleteNodeResponse) String ¶
func (m *DeleteNodeResponse) String() string
func (*DeleteNodeResponse) Validate ¶ added in v1.6.2
func (this *DeleteNodeResponse) Validate() error
type ErrorThrower ¶
type FileKeyManager ¶
type FileKeyManager struct {
FileKeyManagerHandler
}
func (*FileKeyManager) GetEncryptionKey ¶
func (h *FileKeyManager) GetEncryptionKey(ctx context.Context, in *GetEncryptionKeyRequest, out *GetEncryptionKeyResponse) error
type FileKeyManagerClient ¶
type FileKeyManagerClient interface {
GetEncryptionKey(ctx context.Context, in *GetEncryptionKeyRequest, opts ...client.CallOption) (*GetEncryptionKeyResponse, error)
}
func NewFileKeyManagerClient ¶
func NewFileKeyManagerClient(serviceName string, c client.Client) FileKeyManagerClient
type FileKeyManagerHandler ¶
type FileKeyManagerHandler interface {
GetEncryptionKey(context.Context, *GetEncryptionKeyRequest, *GetEncryptionKeyResponse) error
}
type FlushSessionRequest ¶ added in v1.0.0
type FlushSessionRequest struct {
Session *IndexationSession `protobuf:"bytes,1,opt,name=Session" json:"Session,omitempty"`
}
func (*FlushSessionRequest) Descriptor ¶ added in v1.0.0
func (*FlushSessionRequest) Descriptor() ([]byte, []int)
func (*FlushSessionRequest) GetSession ¶ added in v1.0.0
func (m *FlushSessionRequest) GetSession() *IndexationSession
func (*FlushSessionRequest) ProtoMessage ¶ added in v1.0.0
func (*FlushSessionRequest) ProtoMessage()
func (*FlushSessionRequest) Reset ¶ added in v1.0.0
func (m *FlushSessionRequest) Reset()
func (*FlushSessionRequest) String ¶ added in v1.0.0
func (m *FlushSessionRequest) String() string
func (*FlushSessionRequest) Validate ¶ added in v1.6.2
func (this *FlushSessionRequest) Validate() error
type FlushSessionResponse ¶ added in v1.0.0
type FlushSessionResponse struct {
Session *IndexationSession `protobuf:"bytes,1,opt,name=Session" json:"Session,omitempty"`
}
func (*FlushSessionResponse) Descriptor ¶ added in v1.0.0
func (*FlushSessionResponse) Descriptor() ([]byte, []int)
func (*FlushSessionResponse) GetSession ¶ added in v1.0.0
func (m *FlushSessionResponse) GetSession() *IndexationSession
func (*FlushSessionResponse) ProtoMessage ¶ added in v1.0.0
func (*FlushSessionResponse) ProtoMessage()
func (*FlushSessionResponse) Reset ¶ added in v1.0.0
func (m *FlushSessionResponse) Reset()
func (*FlushSessionResponse) String ¶ added in v1.0.0
func (m *FlushSessionResponse) String() string
func (*FlushSessionResponse) Validate ¶ added in v1.6.2
func (this *FlushSessionResponse) Validate() error
type GeoPoint ¶
type GeoPoint struct { Lat float64 `protobuf:"fixed64,1,opt,name=Lat" json:"Lat,omitempty"` Lon float64 `protobuf:"fixed64,2,opt,name=Lon" json:"Lon,omitempty"` }
func (*GeoPoint) Descriptor ¶
func (*GeoPoint) ProtoMessage ¶
func (*GeoPoint) ProtoMessage()
type GeoQuery ¶
type GeoQuery struct { // Either use a center point and a distance Center *GeoPoint `protobuf:"bytes,1,opt,name=Center" 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" json:"Distance,omitempty"` // Or use a bounding box with TopLeft and BottomRight points TopLeft *GeoPoint `protobuf:"bytes,3,opt,name=TopLeft" json:"TopLeft,omitempty"` BottomRight *GeoPoint `protobuf:"bytes,4,opt,name=BottomRight" json:"BottomRight,omitempty"` }
func (*GeoQuery) Descriptor ¶
func (*GeoQuery) GetBottomRight ¶
func (*GeoQuery) GetDistance ¶
func (*GeoQuery) GetTopLeft ¶
func (*GeoQuery) ProtoMessage ¶
func (*GeoQuery) ProtoMessage()
type GetEncryptionKeyRequest ¶
type GetEncryptionKeyRequest struct { User string `protobuf:"bytes,1,opt,name=User" json:"User,omitempty"` Password string `protobuf:"bytes,2,opt,name=Password" json:"Password,omitempty"` Node *Node `protobuf:"bytes,3,opt,name=Node" json:"Node,omitempty"` Create bool `protobuf:"varint,5,opt,name=Create" json:"Create,omitempty"` }
func (*GetEncryptionKeyRequest) Descriptor ¶
func (*GetEncryptionKeyRequest) Descriptor() ([]byte, []int)
func (*GetEncryptionKeyRequest) GetCreate ¶
func (m *GetEncryptionKeyRequest) GetCreate() bool
func (*GetEncryptionKeyRequest) GetNode ¶
func (m *GetEncryptionKeyRequest) GetNode() *Node
func (*GetEncryptionKeyRequest) GetPassword ¶
func (m *GetEncryptionKeyRequest) GetPassword() string
func (*GetEncryptionKeyRequest) GetUser ¶
func (m *GetEncryptionKeyRequest) GetUser() string
func (*GetEncryptionKeyRequest) ProtoMessage ¶
func (*GetEncryptionKeyRequest) ProtoMessage()
func (*GetEncryptionKeyRequest) Reset ¶
func (m *GetEncryptionKeyRequest) Reset()
func (*GetEncryptionKeyRequest) String ¶
func (m *GetEncryptionKeyRequest) String() string
func (*GetEncryptionKeyRequest) Validate ¶ added in v1.6.2
func (this *GetEncryptionKeyRequest) Validate() error
type GetEncryptionKeyResponse ¶
type GetEncryptionKeyResponse struct {
Key []byte `protobuf:"bytes,1,opt,name=Key,proto3" json:"Key,omitempty"`
}
func (*GetEncryptionKeyResponse) Descriptor ¶
func (*GetEncryptionKeyResponse) Descriptor() ([]byte, []int)
func (*GetEncryptionKeyResponse) GetKey ¶
func (m *GetEncryptionKeyResponse) GetKey() []byte
func (*GetEncryptionKeyResponse) ProtoMessage ¶
func (*GetEncryptionKeyResponse) ProtoMessage()
func (*GetEncryptionKeyResponse) Reset ¶
func (m *GetEncryptionKeyResponse) Reset()
func (*GetEncryptionKeyResponse) String ¶
func (m *GetEncryptionKeyResponse) String() string
func (*GetEncryptionKeyResponse) Validate ¶ added in v1.6.2
func (this *GetEncryptionKeyResponse) Validate() error
type HeadVersionRequest ¶
type HeadVersionRequest struct { Node *Node `protobuf:"bytes,1,opt,name=Node" json:"Node,omitempty"` VersionId string `protobuf:"bytes,2,opt,name=VersionId" json:"VersionId,omitempty"` }
func (*HeadVersionRequest) Descriptor ¶
func (*HeadVersionRequest) Descriptor() ([]byte, []int)
func (*HeadVersionRequest) GetNode ¶
func (m *HeadVersionRequest) GetNode() *Node
func (*HeadVersionRequest) GetVersionId ¶
func (m *HeadVersionRequest) GetVersionId() string
func (*HeadVersionRequest) ProtoMessage ¶
func (*HeadVersionRequest) ProtoMessage()
func (*HeadVersionRequest) Reset ¶
func (m *HeadVersionRequest) Reset()
func (*HeadVersionRequest) String ¶
func (m *HeadVersionRequest) String() string
func (*HeadVersionRequest) Validate ¶ added in v1.6.2
func (this *HeadVersionRequest) Validate() error
type HeadVersionResponse ¶
type HeadVersionResponse struct {
Version *ChangeLog `protobuf:"bytes,1,opt,name=Version" json:"Version,omitempty"`
}
func (*HeadVersionResponse) Descriptor ¶
func (*HeadVersionResponse) Descriptor() ([]byte, []int)
func (*HeadVersionResponse) GetVersion ¶
func (m *HeadVersionResponse) GetVersion() *ChangeLog
func (*HeadVersionResponse) ProtoMessage ¶
func (*HeadVersionResponse) ProtoMessage()
func (*HeadVersionResponse) Reset ¶
func (m *HeadVersionResponse) Reset()
func (*HeadVersionResponse) String ¶
func (m *HeadVersionResponse) String() string
func (*HeadVersionResponse) Validate ¶ added in v1.6.2
func (this *HeadVersionResponse) Validate() error
type IndexEvent ¶ added in v1.5.0
type IndexEvent struct { ErrorDetected bool `protobuf:"varint,1,opt,name=ErrorDetected" json:"ErrorDetected,omitempty"` DataSourceName string `protobuf:"bytes,2,opt,name=DataSourceName" json:"DataSourceName,omitempty"` ErrorPath string `protobuf:"bytes,3,opt,name=ErrorPath" json:"ErrorPath,omitempty"` SessionForceClose string `protobuf:"bytes,4,opt,name=SessionForceClose" json:"SessionForceClose,omitempty"` }
func (*IndexEvent) Descriptor ¶ added in v1.5.0
func (*IndexEvent) Descriptor() ([]byte, []int)
func (*IndexEvent) GetDataSourceName ¶ added in v1.5.0
func (m *IndexEvent) GetDataSourceName() string
func (*IndexEvent) GetErrorDetected ¶ added in v1.5.0
func (m *IndexEvent) GetErrorDetected() bool
func (*IndexEvent) GetErrorPath ¶ added in v1.5.0
func (m *IndexEvent) GetErrorPath() string
func (*IndexEvent) GetSessionForceClose ¶ added in v1.5.0
func (m *IndexEvent) GetSessionForceClose() string
func (*IndexEvent) ProtoMessage ¶ added in v1.5.0
func (*IndexEvent) ProtoMessage()
func (*IndexEvent) Reset ¶ added in v1.5.0
func (m *IndexEvent) Reset()
func (*IndexEvent) String ¶ added in v1.5.0
func (m *IndexEvent) String() string
func (*IndexEvent) Validate ¶ added in v1.6.2
func (this *IndexEvent) Validate() error
type IndexableNode ¶
type IndexableNode struct { Node ReloadCore bool ReloadNs bool ModifTime time.Time Basename string NodeType string Extension string TextContent string GeoPoint map[string]interface{} Meta map[string]interface{} }
func NewMemIndexableNode ¶
func NewMemIndexableNode(n *Node) *IndexableNode
func (*IndexableNode) BleveType ¶
func (i *IndexableNode) BleveType() string
func (*IndexableNode) MemLoad ¶
func (i *IndexableNode) MemLoad()
type IndexationOperation ¶
type IndexationOperation struct { SessionUuid string `protobuf:"bytes,1,opt,name=SessionUuid" json:"SessionUuid,omitempty"` Description string `protobuf:"bytes,2,opt,name=Description" json:"Description,omitempty"` Cursor int64 `protobuf:"varint,3,opt,name=Cursor" json:"Cursor,omitempty"` }
func (*IndexationOperation) Descriptor ¶
func (*IndexationOperation) Descriptor() ([]byte, []int)
func (*IndexationOperation) GetCursor ¶
func (m *IndexationOperation) GetCursor() int64
func (*IndexationOperation) GetDescription ¶
func (m *IndexationOperation) GetDescription() string
func (*IndexationOperation) GetSessionUuid ¶
func (m *IndexationOperation) GetSessionUuid() string
func (*IndexationOperation) ProtoMessage ¶
func (*IndexationOperation) ProtoMessage()
func (*IndexationOperation) Reset ¶
func (m *IndexationOperation) Reset()
func (*IndexationOperation) String ¶
func (m *IndexationOperation) String() string
func (*IndexationOperation) Validate ¶ added in v1.6.2
func (this *IndexationOperation) Validate() error
type IndexationSession ¶
type IndexationSession struct { Uuid string `protobuf:"bytes,1,opt,name=Uuid" json:"Uuid,omitempty"` Description string `protobuf:"bytes,2,opt,name=Description" json:"Description,omitempty"` RootNode *Node `protobuf:"bytes,3,opt,name=RootNode" json:"RootNode,omitempty"` ExpectedOperationsCount int64 `protobuf:"varint,4,opt,name=ExpectedOperationsCount" json:"ExpectedOperationsCount,omitempty"` CurrentOperationCount int64 `protobuf:"varint,5,opt,name=CurrentOperationCount" json:"CurrentOperationCount,omitempty"` Silent bool `protobuf:"varint,6,opt,name=Silent" json:"Silent,omitempty"` }
func (*IndexationSession) Descriptor ¶
func (*IndexationSession) Descriptor() ([]byte, []int)
func (*IndexationSession) GetCurrentOperationCount ¶
func (m *IndexationSession) GetCurrentOperationCount() int64
func (*IndexationSession) GetDescription ¶
func (m *IndexationSession) GetDescription() string
func (*IndexationSession) GetExpectedOperationsCount ¶
func (m *IndexationSession) GetExpectedOperationsCount() int64
func (*IndexationSession) GetRootNode ¶
func (m *IndexationSession) GetRootNode() *Node
func (*IndexationSession) GetSilent ¶ added in v1.6.2
func (m *IndexationSession) GetSilent() bool
func (*IndexationSession) GetUuid ¶
func (m *IndexationSession) GetUuid() string
func (*IndexationSession) ProtoMessage ¶
func (*IndexationSession) ProtoMessage()
func (*IndexationSession) Reset ¶
func (m *IndexationSession) Reset()
func (*IndexationSession) String ¶
func (m *IndexationSession) String() string
func (*IndexationSession) Validate ¶ added in v1.6.2
func (this *IndexationSession) Validate() error
type ListNodesRequest ¶
type ListNodesRequest struct { // Main node used as a parent Node *Node `protobuf:"bytes,1,opt,name=Node" json:"Node,omitempty"` // Send back all children of the node Recursive bool `protobuf:"varint,2,opt,name=Recursive" 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" json:"Ancestors,omitempty"` // Sends the list of versions for a given node WithVersions bool `protobuf:"varint,7,opt,name=WithVersions" json:"WithVersions,omitempty"` // Sends the list of commits for a given node (not used) WithCommits bool `protobuf:"varint,8,opt,name=WithCommits" json:"WithCommits,omitempty"` // Limit the number of results Limit int64 `protobuf:"varint,4,opt,name=Limit" json:"Limit,omitempty"` // Start listing at a given position Offset int64 `protobuf:"varint,5,opt,name=Offset" json:"Offset,omitempty"` // Filter by node type (LEAF / COLLECTION) FilterType NodeType `protobuf:"varint,6,opt,name=FilterType,enum=tree.NodeType" json:"FilterType,omitempty"` }
func (*ListNodesRequest) Descriptor ¶
func (*ListNodesRequest) Descriptor() ([]byte, []int)
func (*ListNodesRequest) GetAncestors ¶
func (m *ListNodesRequest) GetAncestors() bool
func (*ListNodesRequest) GetFilterType ¶
func (m *ListNodesRequest) GetFilterType() NodeType
func (*ListNodesRequest) GetLimit ¶
func (m *ListNodesRequest) GetLimit() int64
func (*ListNodesRequest) GetNode ¶
func (m *ListNodesRequest) GetNode() *Node
func (*ListNodesRequest) GetOffset ¶
func (m *ListNodesRequest) GetOffset() int64
func (*ListNodesRequest) GetRecursive ¶
func (m *ListNodesRequest) GetRecursive() bool
func (*ListNodesRequest) GetWithCommits ¶
func (m *ListNodesRequest) GetWithCommits() bool
func (*ListNodesRequest) GetWithVersions ¶
func (m *ListNodesRequest) GetWithVersions() bool
func (*ListNodesRequest) ProtoMessage ¶
func (*ListNodesRequest) ProtoMessage()
func (*ListNodesRequest) Reset ¶
func (m *ListNodesRequest) Reset()
func (*ListNodesRequest) String ¶
func (m *ListNodesRequest) String() string
func (*ListNodesRequest) Validate ¶ added in v1.6.2
func (this *ListNodesRequest) Validate() error
type ListNodesResponse ¶
type ListNodesResponse struct {
Node *Node `protobuf:"bytes,1,opt,name=Node" json:"Node,omitempty"`
}
func (*ListNodesResponse) Descriptor ¶
func (*ListNodesResponse) Descriptor() ([]byte, []int)
func (*ListNodesResponse) GetNode ¶
func (m *ListNodesResponse) GetNode() *Node
func (*ListNodesResponse) ProtoMessage ¶
func (*ListNodesResponse) ProtoMessage()
func (*ListNodesResponse) Reset ¶
func (m *ListNodesResponse) Reset()
func (*ListNodesResponse) String ¶
func (m *ListNodesResponse) String() string
func (*ListNodesResponse) Validate ¶ added in v1.6.2
func (this *ListNodesResponse) Validate() error
type ListVersionsRequest ¶
type ListVersionsRequest struct {
Node *Node `protobuf:"bytes,1,opt,name=Node" json:"Node,omitempty"`
}
func (*ListVersionsRequest) Descriptor ¶
func (*ListVersionsRequest) Descriptor() ([]byte, []int)
func (*ListVersionsRequest) GetNode ¶
func (m *ListVersionsRequest) GetNode() *Node
func (*ListVersionsRequest) ProtoMessage ¶
func (*ListVersionsRequest) ProtoMessage()
func (*ListVersionsRequest) Reset ¶
func (m *ListVersionsRequest) Reset()
func (*ListVersionsRequest) String ¶
func (m *ListVersionsRequest) String() string
func (*ListVersionsRequest) Validate ¶ added in v1.6.2
func (this *ListVersionsRequest) Validate() error
type ListVersionsResponse ¶
type ListVersionsResponse struct {
Version *ChangeLog `protobuf:"bytes,1,opt,name=Version" json:"Version,omitempty"`
}
func (*ListVersionsResponse) Descriptor ¶
func (*ListVersionsResponse) Descriptor() ([]byte, []int)
func (*ListVersionsResponse) GetVersion ¶
func (m *ListVersionsResponse) GetVersion() *ChangeLog
func (*ListVersionsResponse) ProtoMessage ¶
func (*ListVersionsResponse) ProtoMessage()
func (*ListVersionsResponse) Reset ¶
func (m *ListVersionsResponse) Reset()
func (*ListVersionsResponse) String ¶
func (m *ListVersionsResponse) String() string
func (*ListVersionsResponse) Validate ¶ added in v1.6.2
func (this *ListVersionsResponse) Validate() error
type MetaFilter ¶
type MetaFilter struct {
// contains filtered or unexported fields
}
func NewMetaFilter ¶
func NewMetaFilter(node *Node) *MetaFilter
func (*MetaFilter) LimitDepth ¶
func (m *MetaFilter) LimitDepth() int
func (*MetaFilter) Parse ¶
func (m *MetaFilter) Parse() bool
type Node ¶
type Node struct { // ------------------------------------ // Core identification of the node // ------------------------------------ Uuid string `protobuf:"bytes,1,opt,name=Uuid" json:"Uuid,omitempty"` Path string `protobuf:"bytes,2,opt,name=Path" json:"Path,omitempty"` Type NodeType `protobuf:"varint,3,opt,name=Type,enum=tree.NodeType" json:"Type,omitempty"` // Size of the file, or cumulated size of folder Size int64 `protobuf:"varint,4,opt,name=Size" json:"Size,omitempty"` // Last modification Timestamp MTime int64 `protobuf:"varint,5,opt,name=MTime" json:"MTime,omitempty"` // Permission mode, like 0777 Mode int32 `protobuf:"varint,6,opt,name=Mode" json:"Mode,omitempty"` // Hash of the content if node is a LEAF, Uuid or Etag string `protobuf:"bytes,7,opt,name=Etag" json:"Etag,omitempty"` // List of successive commits Commits []*ChangeLog `protobuf:"bytes,9,rep,name=Commits" json:"Commits,omitempty"` // ------------------------------------ // Then a free K => V representation of any kind of metadata // ------------------------------------ MetaStore map[string]string `` /* 138-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" json:"AppearsIn,omitempty"` }
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 ¶
func (*Node) GetAppearsIn ¶
func (m *Node) GetAppearsIn() []*WorkspaceRelativePath
func (*Node) GetCommits ¶
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 ¶ added in v1.5.0
func (node *Node) MarshalLogObject(encoder zapcore.ObjectEncoder) error
LOGGING SUPPORT
MarshalLogObject implements custom marshalling for logs
func (*Node) ProtoMessage ¶
func (*Node) ProtoMessage()
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,enum=tree.NodeChangeEvent_EventType" json:"Type,omitempty"` Source *Node `protobuf:"bytes,2,opt,name=Source" json:"Source,omitempty"` Target *Node `protobuf:"bytes,3,opt,name=Target" json:"Target,omitempty"` Metadata map[string]string `` /* 136-byte string literal not displayed */ Silent bool `protobuf:"varint,4,opt,name=Silent" json:"Silent,omitempty"` Optimistic bool `protobuf:"varint,5,opt,name=Optimistic" json:"Optimistic,omitempty"` }
func (*NodeChangeEvent) Descriptor ¶
func (*NodeChangeEvent) Descriptor() ([]byte, []int)
func (*NodeChangeEvent) GetMetadata ¶ added in v1.6.2
func (m *NodeChangeEvent) GetMetadata() map[string]string
func (*NodeChangeEvent) GetOptimistic ¶ added in v1.5.0
func (m *NodeChangeEvent) GetOptimistic() bool
func (*NodeChangeEvent) GetSilent ¶ added in v1.5.0
func (m *NodeChangeEvent) GetSilent() bool
func (*NodeChangeEvent) GetSource ¶
func (m *NodeChangeEvent) GetSource() *Node
func (*NodeChangeEvent) GetTarget ¶
func (m *NodeChangeEvent) GetTarget() *Node
func (*NodeChangeEvent) GetType ¶
func (m *NodeChangeEvent) GetType() NodeChangeEvent_EventType
func (*NodeChangeEvent) ProtoMessage ¶
func (*NodeChangeEvent) ProtoMessage()
func (*NodeChangeEvent) Reset ¶
func (m *NodeChangeEvent) Reset()
func (*NodeChangeEvent) String ¶
func (m *NodeChangeEvent) String() string
func (*NodeChangeEvent) Validate ¶ added in v1.6.2
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) EnumDescriptor ¶
func (NodeChangeEvent_EventType) EnumDescriptor() ([]byte, []int)
func (NodeChangeEvent_EventType) String ¶
func (x NodeChangeEvent_EventType) String() string
type NodeChangesStreamer ¶ added in v1.6.2
type NodeChangesStreamer struct {
NodeChangesStreamerHandler
}
func (*NodeChangesStreamer) StreamChanges ¶ added in v1.6.2
type NodeChangesStreamerClient ¶ added in v1.6.2
type NodeChangesStreamerClient interface {
StreamChanges(ctx context.Context, in *StreamChangesRequest, opts ...client.CallOption) (NodeChangesStreamer_StreamChangesClient, error)
}
func NewNodeChangesStreamerClient ¶ added in v1.6.2
func NewNodeChangesStreamerClient(serviceName string, c client.Client) NodeChangesStreamerClient
type NodeChangesStreamerHandler ¶ added in v1.6.2
type NodeChangesStreamerHandler interface {
StreamChanges(context.Context, *StreamChangesRequest, NodeChangesStreamer_StreamChangesStream) error
}
type NodeChangesStreamer_StreamChangesClient ¶ added in v1.6.2
type NodeChangesStreamer_StreamChangesClient interface { SendMsg(interface{}) error RecvMsg(interface{}) error Close() error Recv() (*NodeChangeEvent, error) }
type NodeChangesStreamer_StreamChangesStream ¶ added in v1.6.2
type NodeChangesStreamer_StreamChangesStream interface { SendMsg(interface{}) error RecvMsg(interface{}) error Close() error Send(*NodeChangeEvent) error }
type NodeContentReader ¶
type NodeContentReader struct {
NodeContentReaderHandler
}
type NodeContentReaderClient ¶
type NodeContentReaderClient interface { }
func NewNodeContentReaderClient ¶
func NewNodeContentReaderClient(serviceName string, c client.Client) NodeContentReaderClient
type NodeContentReaderHandler ¶
type NodeContentReaderHandler interface { }
type NodeContentWriter ¶
type NodeContentWriter struct {
NodeContentWriterHandler
}
type NodeContentWriterClient ¶
type NodeContentWriterClient interface { }
func NewNodeContentWriterClient ¶
func NewNodeContentWriterClient(serviceName string, c client.Client) NodeContentWriterClient
type NodeContentWriterHandler ¶
type NodeContentWriterHandler interface { }
type NodeEventsProvider ¶
type NodeEventsProvider struct {
NodeEventsProviderHandler
}
type NodeEventsProviderClient ¶
type NodeEventsProviderClient interface {
WatchNode(ctx context.Context, in *WatchNodeRequest, opts ...client.CallOption) (NodeEventsProvider_WatchNodeClient, error)
}
func NewNodeEventsProviderClient ¶
func NewNodeEventsProviderClient(serviceName string, c client.Client) NodeEventsProviderClient
type NodeEventsProviderHandler ¶
type NodeEventsProviderHandler interface {
WatchNode(context.Context, *WatchNodeRequest, NodeEventsProvider_WatchNodeStream) error
}
type NodeEventsProvider_WatchNodeClient ¶
type NodeEventsProvider_WatchNodeClient interface { SendMsg(interface{}) error RecvMsg(interface{}) error Close() error Recv() (*WatchNodeResponse, error) }
type NodeEventsProvider_WatchNodeStream ¶
type NodeEventsProvider_WatchNodeStream interface { SendMsg(interface{}) error RecvMsg(interface{}) error Close() error Send(*WatchNodeResponse) error }
type NodeProvider ¶
type NodeProvider struct {
NodeProviderHandler
}
func (*NodeProvider) ReadNode ¶
func (h *NodeProvider) ReadNode(ctx context.Context, in *ReadNodeRequest, out *ReadNodeResponse) error
type NodeProviderClient ¶
type NodeProviderClient interface { ReadNode(ctx context.Context, in *ReadNodeRequest, opts ...client.CallOption) (*ReadNodeResponse, error) ListNodes(ctx context.Context, in *ListNodesRequest, opts ...client.CallOption) (NodeProvider_ListNodesClient, error) }
func NewNodeProviderClient ¶
func NewNodeProviderClient(serviceName string, c client.Client) NodeProviderClient
type NodeProviderHandler ¶
type NodeProviderHandler interface { ReadNode(context.Context, *ReadNodeRequest, *ReadNodeResponse) error ListNodes(context.Context, *ListNodesRequest, NodeProvider_ListNodesStream) 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 ...client.CallOption) (NodeProvider_ListNodesClient, error)
func (*NodeProviderMock) ReadNode ¶
func (m *NodeProviderMock) ReadNode(ctx context.Context, in *ReadNodeRequest, opts ...client.CallOption) (*ReadNodeResponse, error)
type NodeProviderStreamer ¶
type NodeProviderStreamer struct {
NodeProviderStreamerHandler
}
func (*NodeProviderStreamer) ReadNodeStream ¶
type NodeProviderStreamerClient ¶
type NodeProviderStreamerClient interface {
ReadNodeStream(ctx context.Context, opts ...client.CallOption) (NodeProviderStreamer_ReadNodeStreamClient, error)
}
func NewNodeProviderStreamerClient ¶
func NewNodeProviderStreamerClient(serviceName string, c client.Client) NodeProviderStreamerClient
type NodeProviderStreamerHandler ¶
type NodeProviderStreamerHandler interface {
ReadNodeStream(context.Context, NodeProviderStreamer_ReadNodeStreamStream) error
}
type NodeProviderStreamer_ReadNodeStreamClient ¶
type NodeProviderStreamer_ReadNodeStreamClient interface { SendMsg(interface{}) error RecvMsg(interface{}) error Close() error Send(*ReadNodeRequest) error Recv() (*ReadNodeResponse, error) }
type NodeProviderStreamer_ReadNodeStreamStream ¶
type NodeProviderStreamer_ReadNodeStreamStream interface { SendMsg(interface{}) error RecvMsg(interface{}) error Close() error Send(*ReadNodeResponse) error Recv() (*ReadNodeRequest, error) }
type NodeProvider_ListNodesClient ¶
type NodeProvider_ListNodesClient interface { SendMsg(interface{}) error RecvMsg(interface{}) error Close() error Recv() (*ListNodesResponse, error) }
type NodeProvider_ListNodesStream ¶
type NodeProvider_ListNodesStream interface { SendMsg(interface{}) error RecvMsg(interface{}) error Close() error Send(*ListNodesResponse) error }
type NodeReceiver ¶
type NodeReceiver struct {
NodeReceiverHandler
}
func (*NodeReceiver) CreateNode ¶
func (h *NodeReceiver) CreateNode(ctx context.Context, in *CreateNodeRequest, out *CreateNodeResponse) error
func (*NodeReceiver) DeleteNode ¶
func (h *NodeReceiver) DeleteNode(ctx context.Context, in *DeleteNodeRequest, out *DeleteNodeResponse) error
func (*NodeReceiver) UpdateNode ¶
func (h *NodeReceiver) UpdateNode(ctx context.Context, in *UpdateNodeRequest, out *UpdateNodeResponse) error
type NodeReceiverClient ¶
type NodeReceiverClient interface { CreateNode(ctx context.Context, in *CreateNodeRequest, opts ...client.CallOption) (*CreateNodeResponse, error) UpdateNode(ctx context.Context, in *UpdateNodeRequest, opts ...client.CallOption) (*UpdateNodeResponse, error) DeleteNode(ctx context.Context, in *DeleteNodeRequest, opts ...client.CallOption) (*DeleteNodeResponse, error) }
func NewNodeReceiverClient ¶
func NewNodeReceiverClient(serviceName string, c client.Client) NodeReceiverClient
type NodeReceiverHandler ¶
type NodeReceiverHandler interface { CreateNode(context.Context, *CreateNodeRequest, *CreateNodeResponse) error UpdateNode(context.Context, *UpdateNodeRequest, *UpdateNodeResponse) error DeleteNode(context.Context, *DeleteNodeRequest, *DeleteNodeResponse) error }
type NodeReceiverMock ¶
func (*NodeReceiverMock) CreateNode ¶
func (m *NodeReceiverMock) CreateNode(ctx context.Context, in *CreateNodeRequest, opts ...client.CallOption) (*CreateNodeResponse, error)
func (*NodeReceiverMock) DeleteNode ¶
func (m *NodeReceiverMock) DeleteNode(ctx context.Context, in *DeleteNodeRequest, opts ...client.CallOption) (*DeleteNodeResponse, error)
func (*NodeReceiverMock) UpdateNode ¶
func (m *NodeReceiverMock) UpdateNode(ctx context.Context, in *UpdateNodeRequest, opts ...client.CallOption) (*UpdateNodeResponse, error)
type NodeReceiverStream ¶
type NodeReceiverStream struct {
NodeReceiverStreamHandler
}
func (*NodeReceiverStream) CreateNodeStream ¶
func (*NodeReceiverStream) DeleteNodeStream ¶
func (*NodeReceiverStream) UpdateNodeStream ¶
type NodeReceiverStreamClient ¶
type NodeReceiverStreamClient interface { CreateNodeStream(ctx context.Context, opts ...client.CallOption) (NodeReceiverStream_CreateNodeStreamClient, error) UpdateNodeStream(ctx context.Context, opts ...client.CallOption) (NodeReceiverStream_UpdateNodeStreamClient, error) DeleteNodeStream(ctx context.Context, opts ...client.CallOption) (NodeReceiverStream_DeleteNodeStreamClient, error) }
func NewNodeReceiverStreamClient ¶
func NewNodeReceiverStreamClient(serviceName string, c client.Client) NodeReceiverStreamClient
type NodeReceiverStreamHandler ¶
type NodeReceiverStreamHandler interface { CreateNodeStream(context.Context, NodeReceiverStream_CreateNodeStreamStream) error UpdateNodeStream(context.Context, NodeReceiverStream_UpdateNodeStreamStream) error DeleteNodeStream(context.Context, NodeReceiverStream_DeleteNodeStreamStream) error }
type NodeReceiverStream_CreateNodeStreamClient ¶
type NodeReceiverStream_CreateNodeStreamClient interface { SendMsg(interface{}) error RecvMsg(interface{}) error Close() error Send(*CreateNodeRequest) error Recv() (*CreateNodeResponse, error) }
type NodeReceiverStream_CreateNodeStreamStream ¶
type NodeReceiverStream_CreateNodeStreamStream interface { SendMsg(interface{}) error RecvMsg(interface{}) error Close() error Send(*CreateNodeResponse) error Recv() (*CreateNodeRequest, error) }
type NodeReceiverStream_DeleteNodeStreamClient ¶
type NodeReceiverStream_DeleteNodeStreamClient interface { SendMsg(interface{}) error RecvMsg(interface{}) error Close() error Send(*DeleteNodeRequest) error Recv() (*DeleteNodeResponse, error) }
type NodeReceiverStream_DeleteNodeStreamStream ¶
type NodeReceiverStream_DeleteNodeStreamStream interface { SendMsg(interface{}) error RecvMsg(interface{}) error Close() error Send(*DeleteNodeResponse) error Recv() (*DeleteNodeRequest, error) }
type NodeReceiverStream_UpdateNodeStreamClient ¶
type NodeReceiverStream_UpdateNodeStreamClient interface { SendMsg(interface{}) error RecvMsg(interface{}) error Close() error Send(*UpdateNodeRequest) error Recv() (*UpdateNodeResponse, error) }
type NodeReceiverStream_UpdateNodeStreamStream ¶
type NodeReceiverStream_UpdateNodeStreamStream interface { SendMsg(interface{}) error RecvMsg(interface{}) error Close() error Send(*UpdateNodeResponse) error Recv() (*UpdateNodeRequest, error) }
type NodeType ¶
type NodeType int32
========================================================== * Standard Messages ==========================================================
func (NodeType) EnumDescriptor ¶
type NodeVersioner ¶
type NodeVersioner struct {
NodeVersionerHandler
}
func (*NodeVersioner) CreateVersion ¶
func (h *NodeVersioner) CreateVersion(ctx context.Context, in *CreateVersionRequest, out *CreateVersionResponse) error
func (*NodeVersioner) HeadVersion ¶
func (h *NodeVersioner) HeadVersion(ctx context.Context, in *HeadVersionRequest, out *HeadVersionResponse) error
func (*NodeVersioner) ListVersions ¶
func (*NodeVersioner) PruneVersions ¶
func (h *NodeVersioner) PruneVersions(ctx context.Context, in *PruneVersionsRequest, out *PruneVersionsResponse) error
func (*NodeVersioner) StoreVersion ¶
func (h *NodeVersioner) StoreVersion(ctx context.Context, in *StoreVersionRequest, out *StoreVersionResponse) error
type NodeVersionerClient ¶
type NodeVersionerClient interface { CreateVersion(ctx context.Context, in *CreateVersionRequest, opts ...client.CallOption) (*CreateVersionResponse, error) StoreVersion(ctx context.Context, in *StoreVersionRequest, opts ...client.CallOption) (*StoreVersionResponse, error) ListVersions(ctx context.Context, in *ListVersionsRequest, opts ...client.CallOption) (NodeVersioner_ListVersionsClient, error) HeadVersion(ctx context.Context, in *HeadVersionRequest, opts ...client.CallOption) (*HeadVersionResponse, error) PruneVersions(ctx context.Context, in *PruneVersionsRequest, opts ...client.CallOption) (*PruneVersionsResponse, error) }
func NewNodeVersionerClient ¶
func NewNodeVersionerClient(serviceName string, c client.Client) NodeVersionerClient
type NodeVersionerHandler ¶
type NodeVersionerHandler interface { CreateVersion(context.Context, *CreateVersionRequest, *CreateVersionResponse) error StoreVersion(context.Context, *StoreVersionRequest, *StoreVersionResponse) error ListVersions(context.Context, *ListVersionsRequest, NodeVersioner_ListVersionsStream) error HeadVersion(context.Context, *HeadVersionRequest, *HeadVersionResponse) error PruneVersions(context.Context, *PruneVersionsRequest, *PruneVersionsResponse) error }
type NodeVersioner_ListVersionsClient ¶
type NodeVersioner_ListVersionsClient interface { SendMsg(interface{}) error RecvMsg(interface{}) error Close() error Recv() (*ListVersionsResponse, error) }
type NodeVersioner_ListVersionsStream ¶
type NodeVersioner_ListVersionsStream interface { SendMsg(interface{}) error RecvMsg(interface{}) error Close() error Send(*ListVersionsResponse) error }
type OpenSessionRequest ¶
type OpenSessionRequest struct {
Session *IndexationSession `protobuf:"bytes,1,opt,name=Session" json:"Session,omitempty"`
}
func (*OpenSessionRequest) Descriptor ¶
func (*OpenSessionRequest) Descriptor() ([]byte, []int)
func (*OpenSessionRequest) GetSession ¶
func (m *OpenSessionRequest) GetSession() *IndexationSession
func (*OpenSessionRequest) ProtoMessage ¶
func (*OpenSessionRequest) ProtoMessage()
func (*OpenSessionRequest) Reset ¶
func (m *OpenSessionRequest) Reset()
func (*OpenSessionRequest) String ¶
func (m *OpenSessionRequest) String() string
func (*OpenSessionRequest) Validate ¶ added in v1.6.2
func (this *OpenSessionRequest) Validate() error
type OpenSessionResponse ¶
type OpenSessionResponse struct {
Session *IndexationSession `protobuf:"bytes,1,opt,name=Session" json:"Session,omitempty"`
}
func (*OpenSessionResponse) Descriptor ¶
func (*OpenSessionResponse) Descriptor() ([]byte, []int)
func (*OpenSessionResponse) GetSession ¶
func (m *OpenSessionResponse) GetSession() *IndexationSession
func (*OpenSessionResponse) ProtoMessage ¶
func (*OpenSessionResponse) ProtoMessage()
func (*OpenSessionResponse) Reset ¶
func (m *OpenSessionResponse) Reset()
func (*OpenSessionResponse) String ¶
func (m *OpenSessionResponse) String() string
func (*OpenSessionResponse) Validate ¶ added in v1.6.2
func (this *OpenSessionResponse) Validate() error
type PruneVersionsRequest ¶
type PruneVersionsRequest struct { UniqueNode *Node `protobuf:"bytes,1,opt,name=UniqueNode" json:"UniqueNode,omitempty"` AllDeletedNodes bool `protobuf:"varint,2,opt,name=AllDeletedNodes" json:"AllDeletedNodes,omitempty"` }
func (*PruneVersionsRequest) Descriptor ¶
func (*PruneVersionsRequest) Descriptor() ([]byte, []int)
func (*PruneVersionsRequest) GetAllDeletedNodes ¶
func (m *PruneVersionsRequest) GetAllDeletedNodes() bool
func (*PruneVersionsRequest) GetUniqueNode ¶
func (m *PruneVersionsRequest) GetUniqueNode() *Node
func (*PruneVersionsRequest) ProtoMessage ¶
func (*PruneVersionsRequest) ProtoMessage()
func (*PruneVersionsRequest) Reset ¶
func (m *PruneVersionsRequest) Reset()
func (*PruneVersionsRequest) String ¶
func (m *PruneVersionsRequest) String() string
func (*PruneVersionsRequest) Validate ¶ added in v1.6.2
func (this *PruneVersionsRequest) Validate() error
type PruneVersionsResponse ¶
type PruneVersionsResponse struct {
DeletedVersions []string `protobuf:"bytes,1,rep,name=DeletedVersions" json:"DeletedVersions,omitempty"`
}
func (*PruneVersionsResponse) Descriptor ¶
func (*PruneVersionsResponse) Descriptor() ([]byte, []int)
func (*PruneVersionsResponse) GetDeletedVersions ¶
func (m *PruneVersionsResponse) GetDeletedVersions() []string
func (*PruneVersionsResponse) ProtoMessage ¶
func (*PruneVersionsResponse) ProtoMessage()
func (*PruneVersionsResponse) Reset ¶
func (m *PruneVersionsResponse) Reset()
func (*PruneVersionsResponse) String ¶
func (m *PruneVersionsResponse) String() string
func (*PruneVersionsResponse) Validate ¶ added in v1.6.2
func (this *PruneVersionsResponse) Validate() error
type PutSyncChangeResponse ¶
type PutSyncChangeResponse struct { Success bool `protobuf:"varint,1,opt,name=success" json:"success,omitempty"` Msg string `protobuf:"bytes,2,opt,name=msg" json:"msg,omitempty"` }
func (*PutSyncChangeResponse) Descriptor ¶
func (*PutSyncChangeResponse) Descriptor() ([]byte, []int)
func (*PutSyncChangeResponse) GetMsg ¶
func (m *PutSyncChangeResponse) GetMsg() string
func (*PutSyncChangeResponse) GetSuccess ¶
func (m *PutSyncChangeResponse) GetSuccess() bool
func (*PutSyncChangeResponse) ProtoMessage ¶
func (*PutSyncChangeResponse) ProtoMessage()
func (*PutSyncChangeResponse) Reset ¶
func (m *PutSyncChangeResponse) Reset()
func (*PutSyncChangeResponse) String ¶
func (m *PutSyncChangeResponse) String() string
func (*PutSyncChangeResponse) Validate ¶ added in v1.6.2
func (this *PutSyncChangeResponse) Validate() error
type Query ¶
type Query struct { // Preset list of nodes by Path Paths []string `protobuf:"bytes,13,rep,name=Paths" json:"Paths,omitempty"` // Limit to a given subtree PathPrefix []string `protobuf:"bytes,1,rep,name=PathPrefix" json:"PathPrefix,omitempty"` // Range for size MinSize int64 `protobuf:"varint,2,opt,name=MinSize" json:"MinSize,omitempty"` MaxSize int64 `protobuf:"varint,3,opt,name=MaxSize" json:"MaxSize,omitempty"` // Range for date MinDate int64 `protobuf:"varint,4,opt,name=MinDate" json:"MinDate,omitempty"` MaxDate int64 `protobuf:"varint,5,opt,name=MaxDate" json:"MaxDate,omitempty"` // Pass a duration with > or < to compute MinDate / MaxDate DurationDate string `protobuf:"bytes,16,opt,name=DurationDate" json:"DurationDate,omitempty"` // Limit to a given node type Type NodeType `protobuf:"varint,6,opt,name=Type,enum=tree.NodeType" json:"Type,omitempty"` // Search in filename FileName string `protobuf:"bytes,7,opt,name=FileName" json:"FileName,omitempty"` // Search in content Content string `protobuf:"bytes,8,opt,name=Content" json:"Content,omitempty"` // Search in either filename or content (but at least one of them) FileNameOrContent string `protobuf:"bytes,17,opt,name=FileNameOrContent" json:"FileNameOrContent,omitempty"` // Free Query String (for metadata) FreeString string `protobuf:"bytes,9,opt,name=FreeString" json:"FreeString,omitempty"` // Search files by extension Extension string `protobuf:"bytes,10,opt,name=Extension" json:"Extension,omitempty"` // Search geographically GeoQuery *GeoQuery `protobuf:"bytes,11,opt,name=GeoQuery" json:"GeoQuery,omitempty"` // Limit to a given level of the tree - can be used in filters PathDepth int32 `protobuf:"varint,12,opt,name=PathDepth" json:"PathDepth,omitempty"` // Preset list of Node by UUIDs UUIDs []string `protobuf:"bytes,15,rep,name=UUIDs" json:"UUIDs,omitempty"` // Negate this query Not bool `protobuf:"varint,14,opt,name=Not" json:"Not,omitempty"` }
Search Queries
func (*Query) Descriptor ¶
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()
type ReadNodeRequest ¶
type ReadNodeRequest struct { // Input node Node *Node `protobuf:"bytes,1,opt,name=Node" json:"Node,omitempty"` // Gather commit information WithCommits bool `protobuf:"varint,2,opt,name=WithCommits" json:"WithCommits,omitempty"` // Get extended stats - For folders, computes ChildrenCount WithExtendedStats bool `protobuf:"varint,3,opt,name=WithExtendedStats" json:"WithExtendedStats,omitempty"` // Used internally for the router ReadNode request, stat the datasource instead of index ObjectStats bool `protobuf:"varint,4,opt,name=ObjectStats" json:"ObjectStats,omitempty"` }
Request / Responses Messages
func (*ReadNodeRequest) Descriptor ¶
func (*ReadNodeRequest) Descriptor() ([]byte, []int)
func (*ReadNodeRequest) GetNode ¶
func (m *ReadNodeRequest) GetNode() *Node
func (*ReadNodeRequest) GetObjectStats ¶ added in v1.5.0
func (m *ReadNodeRequest) GetObjectStats() bool
func (*ReadNodeRequest) GetWithCommits ¶
func (m *ReadNodeRequest) GetWithCommits() bool
func (*ReadNodeRequest) GetWithExtendedStats ¶ added in v1.2.0
func (m *ReadNodeRequest) GetWithExtendedStats() bool
func (*ReadNodeRequest) ProtoMessage ¶
func (*ReadNodeRequest) ProtoMessage()
func (*ReadNodeRequest) Reset ¶
func (m *ReadNodeRequest) Reset()
func (*ReadNodeRequest) String ¶
func (m *ReadNodeRequest) String() string
func (*ReadNodeRequest) Validate ¶ added in v1.6.2
func (this *ReadNodeRequest) Validate() error
type ReadNodeResponse ¶
type ReadNodeResponse struct { Success bool `protobuf:"varint,1,opt,name=Success" json:"Success,omitempty"` Node *Node `protobuf:"bytes,2,opt,name=Node" json:"Node,omitempty"` }
func (*ReadNodeResponse) Descriptor ¶
func (*ReadNodeResponse) Descriptor() ([]byte, []int)
func (*ReadNodeResponse) GetNode ¶
func (m *ReadNodeResponse) GetNode() *Node
func (*ReadNodeResponse) GetSuccess ¶
func (m *ReadNodeResponse) GetSuccess() bool
func (*ReadNodeResponse) ProtoMessage ¶
func (*ReadNodeResponse) ProtoMessage()
func (*ReadNodeResponse) Reset ¶
func (m *ReadNodeResponse) Reset()
func (*ReadNodeResponse) String ¶
func (m *ReadNodeResponse) String() string
func (*ReadNodeResponse) Validate ¶ added in v1.6.2
func (this *ReadNodeResponse) Validate() error
type SearchFacet ¶
type SearchFacet struct { // Facet field name FieldName string `protobuf:"bytes,1,opt,name=FieldName" json:"FieldName,omitempty"` // Segment Label Label string `protobuf:"bytes,2,opt,name=Label" json:"Label,omitempty"` // Segment results count Count int32 `protobuf:"varint,3,opt,name=Count" json:"Count,omitempty"` // For string facets, term value Term string `protobuf:"bytes,4,opt,name=Term" json:"Term,omitempty"` // For NumericRange facets, min/max values Min int64 `protobuf:"varint,5,opt,name=Min" json:"Min,omitempty"` Max int64 `protobuf:"varint,6,opt,name=Max" json:"Max,omitempty"` // For DateRange facets, start/end values Start int32 `protobuf:"varint,7,opt,name=Start" json:"Start,omitempty"` End int32 `protobuf:"varint,8,opt,name=End" json:"End,omitempty"` }
func (*SearchFacet) Descriptor ¶
func (*SearchFacet) Descriptor() ([]byte, []int)
func (*SearchFacet) GetCount ¶
func (m *SearchFacet) GetCount() int32
func (*SearchFacet) GetEnd ¶
func (m *SearchFacet) GetEnd() int32
func (*SearchFacet) GetFieldName ¶
func (m *SearchFacet) GetFieldName() string
func (*SearchFacet) GetLabel ¶
func (m *SearchFacet) GetLabel() string
func (*SearchFacet) GetMax ¶
func (m *SearchFacet) GetMax() int64
func (*SearchFacet) GetMin ¶
func (m *SearchFacet) GetMin() int64
func (*SearchFacet) GetStart ¶
func (m *SearchFacet) GetStart() int32
func (*SearchFacet) GetTerm ¶
func (m *SearchFacet) GetTerm() string
func (*SearchFacet) ProtoMessage ¶
func (*SearchFacet) ProtoMessage()
func (*SearchFacet) Reset ¶
func (m *SearchFacet) Reset()
func (*SearchFacet) String ¶
func (m *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" json:"Query,omitempty"` // Limit the number of results Size int32 `protobuf:"varint,2,opt,name=Size" json:"Size,omitempty"` // Start at given position From int32 `protobuf:"varint,3,opt,name=From" json:"From,omitempty"` // Load node details Details bool `protobuf:"varint,4,opt,name=Details" json:"Details,omitempty"` }
func (*SearchRequest) Descriptor ¶
func (*SearchRequest) Descriptor() ([]byte, []int)
func (*SearchRequest) GetDetails ¶
func (m *SearchRequest) GetDetails() bool
func (*SearchRequest) GetFrom ¶
func (m *SearchRequest) GetFrom() int32
func (*SearchRequest) GetQuery ¶
func (m *SearchRequest) GetQuery() *Query
func (*SearchRequest) GetSize ¶
func (m *SearchRequest) GetSize() int32
func (*SearchRequest) ProtoMessage ¶
func (*SearchRequest) ProtoMessage()
func (*SearchRequest) Reset ¶
func (m *SearchRequest) Reset()
func (*SearchRequest) String ¶
func (m *SearchRequest) String() string
func (*SearchRequest) Validate ¶ added in v1.6.2
func (this *SearchRequest) Validate() error
type SearchResponse ¶
type SearchResponse struct { Node *Node `protobuf:"bytes,1,opt,name=Node" json:"Node,omitempty"` Facet *SearchFacet `protobuf:"bytes,2,opt,name=Facet" json:"Facet,omitempty"` }
func (*SearchResponse) Descriptor ¶
func (*SearchResponse) Descriptor() ([]byte, []int)
func (*SearchResponse) GetFacet ¶
func (m *SearchResponse) GetFacet() *SearchFacet
func (*SearchResponse) GetNode ¶
func (m *SearchResponse) GetNode() *Node
func (*SearchResponse) ProtoMessage ¶
func (*SearchResponse) ProtoMessage()
func (*SearchResponse) Reset ¶
func (m *SearchResponse) Reset()
func (*SearchResponse) String ¶
func (m *SearchResponse) String() string
func (*SearchResponse) Validate ¶ added in v1.6.2
func (this *SearchResponse) Validate() error
type SearchSyncChangeRequest ¶
type SearchSyncChangeRequest struct { Seq uint64 `protobuf:"varint,1,opt,name=seq" json:"seq,omitempty"` Flatten bool `protobuf:"varint,2,opt,name=flatten" json:"flatten,omitempty"` Prefix string `protobuf:"bytes,3,opt,name=prefix" json:"prefix,omitempty"` LastSeqOnly bool `protobuf:"varint,4,opt,name=lastSeqOnly" json:"lastSeqOnly,omitempty"` }
func (*SearchSyncChangeRequest) Descriptor ¶
func (*SearchSyncChangeRequest) Descriptor() ([]byte, []int)
func (*SearchSyncChangeRequest) GetFlatten ¶
func (m *SearchSyncChangeRequest) GetFlatten() bool
func (*SearchSyncChangeRequest) GetLastSeqOnly ¶
func (m *SearchSyncChangeRequest) GetLastSeqOnly() bool
func (*SearchSyncChangeRequest) GetPrefix ¶
func (m *SearchSyncChangeRequest) GetPrefix() string
func (*SearchSyncChangeRequest) GetSeq ¶
func (m *SearchSyncChangeRequest) GetSeq() uint64
func (*SearchSyncChangeRequest) ProtoMessage ¶
func (*SearchSyncChangeRequest) ProtoMessage()
func (*SearchSyncChangeRequest) Reset ¶
func (m *SearchSyncChangeRequest) Reset()
func (*SearchSyncChangeRequest) String ¶
func (m *SearchSyncChangeRequest) String() string
func (*SearchSyncChangeRequest) Validate ¶ added in v1.6.2
func (this *SearchSyncChangeRequest) Validate() error
type Searcher ¶
type Searcher struct {
SearcherHandler
}
type SearcherClient ¶
type SearcherClient interface {
Search(ctx context.Context, in *SearchRequest, opts ...client.CallOption) (Searcher_SearchClient, error)
}
func NewSearcherClient ¶
func NewSearcherClient(serviceName string, c client.Client) SearcherClient
type SearcherHandler ¶
type SearcherHandler interface {
Search(context.Context, *SearchRequest, Searcher_SearchStream) error
}
type Searcher_SearchClient ¶
type Searcher_SearchClient interface { SendMsg(interface{}) error RecvMsg(interface{}) error Close() error Recv() (*SearchResponse, error) }
type Searcher_SearchStream ¶
type Searcher_SearchStream interface { SendMsg(interface{}) error RecvMsg(interface{}) error Close() error Send(*SearchResponse) error }
type SessionIndexer ¶
type SessionIndexer struct {
SessionIndexerHandler
}
func (*SessionIndexer) CloseSession ¶
func (h *SessionIndexer) CloseSession(ctx context.Context, in *CloseSessionRequest, out *CloseSessionResponse) error
func (*SessionIndexer) FlushSession ¶ added in v1.0.0
func (h *SessionIndexer) FlushSession(ctx context.Context, in *FlushSessionRequest, out *FlushSessionResponse) error
func (*SessionIndexer) OpenSession ¶
func (h *SessionIndexer) OpenSession(ctx context.Context, in *OpenSessionRequest, out *OpenSessionResponse) error
type SessionIndexerClient ¶
type SessionIndexerClient interface { OpenSession(ctx context.Context, in *OpenSessionRequest, opts ...client.CallOption) (*OpenSessionResponse, error) FlushSession(ctx context.Context, in *FlushSessionRequest, opts ...client.CallOption) (*FlushSessionResponse, error) CloseSession(ctx context.Context, in *CloseSessionRequest, opts ...client.CallOption) (*CloseSessionResponse, error) }
func NewSessionIndexerClient ¶
func NewSessionIndexerClient(serviceName string, c client.Client) SessionIndexerClient
type SessionIndexerHandler ¶
type SessionIndexerHandler interface { OpenSession(context.Context, *OpenSessionRequest, *OpenSessionResponse) error FlushSession(context.Context, *FlushSessionRequest, *FlushSessionResponse) error CloseSession(context.Context, *CloseSessionRequest, *CloseSessionResponse) error }
type SessionIndexerMock ¶
type SessionIndexerMock struct { }
func (*SessionIndexerMock) CloseSession ¶
func (s *SessionIndexerMock) CloseSession(ctx context.Context, in *CloseSessionRequest, opts ...client.CallOption) (*CloseSessionResponse, error)
func (*SessionIndexerMock) FlushSession ¶
func (s *SessionIndexerMock) FlushSession(ctx context.Context, in *FlushSessionRequest, opts ...client.CallOption) (*FlushSessionResponse, error)
func (*SessionIndexerMock) OpenSession ¶
func (s *SessionIndexerMock) OpenSession(ctx context.Context, in *OpenSessionRequest, opts ...client.CallOption) (*OpenSessionResponse, error)
type StoreVersionRequest ¶
type StoreVersionRequest struct { Node *Node `protobuf:"bytes,1,opt,name=Node" json:"Node,omitempty"` Version *ChangeLog `protobuf:"bytes,2,opt,name=Version" json:"Version,omitempty"` }
func (*StoreVersionRequest) Descriptor ¶
func (*StoreVersionRequest) Descriptor() ([]byte, []int)
func (*StoreVersionRequest) GetNode ¶
func (m *StoreVersionRequest) GetNode() *Node
func (*StoreVersionRequest) GetVersion ¶
func (m *StoreVersionRequest) GetVersion() *ChangeLog
func (*StoreVersionRequest) ProtoMessage ¶
func (*StoreVersionRequest) ProtoMessage()
func (*StoreVersionRequest) Reset ¶
func (m *StoreVersionRequest) Reset()
func (*StoreVersionRequest) String ¶
func (m *StoreVersionRequest) String() string
func (*StoreVersionRequest) Validate ¶ added in v1.6.2
func (this *StoreVersionRequest) Validate() error
type StoreVersionResponse ¶
type StoreVersionResponse struct { Success bool `protobuf:"varint,1,opt,name=Success" json:"Success,omitempty"` PruneVersions []*ChangeLog `protobuf:"bytes,2,rep,name=PruneVersions" json:"PruneVersions,omitempty"` }
func (*StoreVersionResponse) Descriptor ¶
func (*StoreVersionResponse) Descriptor() ([]byte, []int)
func (*StoreVersionResponse) GetPruneVersions ¶
func (m *StoreVersionResponse) GetPruneVersions() []*ChangeLog
func (*StoreVersionResponse) GetSuccess ¶
func (m *StoreVersionResponse) GetSuccess() bool
func (*StoreVersionResponse) ProtoMessage ¶
func (*StoreVersionResponse) ProtoMessage()
func (*StoreVersionResponse) Reset ¶
func (m *StoreVersionResponse) Reset()
func (*StoreVersionResponse) String ¶
func (m *StoreVersionResponse) String() string
func (*StoreVersionResponse) Validate ¶ added in v1.6.2
func (this *StoreVersionResponse) Validate() error
type StreamChangesRequest ¶ added in v1.6.2
type StreamChangesRequest struct {
RootPath string `protobuf:"bytes,1,opt,name=RootPath" json:"RootPath,omitempty"`
}
func (*StreamChangesRequest) Descriptor ¶ added in v1.6.2
func (*StreamChangesRequest) Descriptor() ([]byte, []int)
func (*StreamChangesRequest) GetRootPath ¶ added in v1.6.2
func (m *StreamChangesRequest) GetRootPath() string
func (*StreamChangesRequest) ProtoMessage ¶ added in v1.6.2
func (*StreamChangesRequest) ProtoMessage()
func (*StreamChangesRequest) Reset ¶ added in v1.6.2
func (m *StreamChangesRequest) Reset()
func (*StreamChangesRequest) String ¶ added in v1.6.2
func (m *StreamChangesRequest) String() string
func (*StreamChangesRequest) Validate ¶ added in v1.6.2
func (this *StreamChangesRequest) Validate() error
type StreamerMock ¶
type StreamerMock struct {
// contains filtered or unexported fields
}
func NewStreamerMock ¶
func NewStreamerMock(nodes map[string]Node) *StreamerMock
func (*StreamerMock) Close ¶
func (m *StreamerMock) Close() 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) Request ¶
func (m *StreamerMock) Request() client.Request
func (*StreamerMock) Send ¶
func (m *StreamerMock) Send(v interface{}) error
type SyncChange ¶
type SyncChange struct { Seq uint64 `protobuf:"varint,1,opt,name=seq" json:"seq,omitempty"` NodeId string `protobuf:"bytes,2,opt,name=nodeId,json=node_id" json:"nodeId,omitempty"` Type SyncChange_Type `protobuf:"varint,3,opt,name=type,enum=tree.SyncChange_Type" json:"type,omitempty"` Source string `protobuf:"bytes,4,opt,name=source" json:"source,omitempty"` Target string `protobuf:"bytes,5,opt,name=target" json:"target,omitempty"` Node *SyncChangeNode `protobuf:"bytes,6,opt,name=node" json:"node,omitempty"` }
func (*SyncChange) Descriptor ¶
func (*SyncChange) Descriptor() ([]byte, []int)
func (*SyncChange) GetNode ¶
func (m *SyncChange) GetNode() *SyncChangeNode
func (*SyncChange) GetNodeId ¶
func (m *SyncChange) GetNodeId() string
func (*SyncChange) GetSeq ¶
func (m *SyncChange) GetSeq() uint64
func (*SyncChange) GetSource ¶
func (m *SyncChange) GetSource() string
func (*SyncChange) GetTarget ¶
func (m *SyncChange) GetTarget() string
func (*SyncChange) GetType ¶
func (m *SyncChange) GetType() SyncChange_Type
func (*SyncChange) ProtoMessage ¶
func (*SyncChange) ProtoMessage()
func (*SyncChange) Reset ¶
func (m *SyncChange) Reset()
func (*SyncChange) String ¶
func (m *SyncChange) String() string
func (*SyncChange) Validate ¶ added in v1.6.2
func (this *SyncChange) Validate() error
type SyncChangeNode ¶
type SyncChangeNode struct { Bytesize int64 `protobuf:"varint,1,opt,name=bytesize" json:"bytesize,omitempty"` Md5 string `protobuf:"bytes,2,opt,name=md5" json:"md5,omitempty"` Mtime int64 `protobuf:"varint,3,opt,name=mtime" json:"mtime,omitempty"` NodePath string `protobuf:"bytes,4,opt,name=nodePath,json=node_path" json:"nodePath,omitempty"` RepositoryIdentifier string `protobuf:"bytes,5,opt,name=repositoryIdentifier,json=repository_identifier" json:"repositoryIdentifier,omitempty"` }
func (*SyncChangeNode) Descriptor ¶
func (*SyncChangeNode) Descriptor() ([]byte, []int)
func (*SyncChangeNode) GetBytesize ¶
func (m *SyncChangeNode) GetBytesize() int64
func (*SyncChangeNode) GetMd5 ¶
func (m *SyncChangeNode) GetMd5() string
func (*SyncChangeNode) GetMtime ¶
func (m *SyncChangeNode) GetMtime() int64
func (*SyncChangeNode) GetNodePath ¶
func (m *SyncChangeNode) GetNodePath() string
func (*SyncChangeNode) GetRepositoryIdentifier ¶
func (m *SyncChangeNode) GetRepositoryIdentifier() string
func (*SyncChangeNode) ProtoMessage ¶
func (*SyncChangeNode) ProtoMessage()
func (*SyncChangeNode) Reset ¶
func (m *SyncChangeNode) Reset()
func (*SyncChangeNode) String ¶
func (m *SyncChangeNode) String() string
func (*SyncChangeNode) Validate ¶ added in v1.6.2
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) EnumDescriptor ¶
func (SyncChange_Type) EnumDescriptor() ([]byte, []int)
func (SyncChange_Type) String ¶
func (x SyncChange_Type) String() string
type SyncChangesClient ¶
type SyncChangesClient interface { Put(ctx context.Context, opts ...client.CallOption) (SyncChanges_PutClient, error) Search(ctx context.Context, in *SearchSyncChangeRequest, opts ...client.CallOption) (SyncChanges_SearchClient, error) }
func NewSyncChangesClient ¶
func NewSyncChangesClient(serviceName string, c client.Client) SyncChangesClient
type SyncChangesHandler ¶
type SyncChangesHandler interface { Put(context.Context, SyncChanges_PutStream) error Search(context.Context, *SearchSyncChangeRequest, SyncChanges_SearchStream) error }
type SyncChanges_PutClient ¶
type SyncChanges_PutClient interface { SendMsg(interface{}) error RecvMsg(interface{}) error Close() error Send(*SyncChange) error }
type SyncChanges_PutStream ¶
type SyncChanges_PutStream interface { SendMsg(interface{}) error RecvMsg(interface{}) error Close() error Recv() (*SyncChange, error) }
type SyncChanges_SearchClient ¶
type SyncChanges_SearchClient interface { SendMsg(interface{}) error RecvMsg(interface{}) error Close() error Recv() (*SyncChange, error) }
type SyncChanges_SearchStream ¶
type SyncChanges_SearchStream interface { SendMsg(interface{}) error RecvMsg(interface{}) error Close() error Send(*SyncChange) error }
type UpdateNodeRequest ¶
type UpdateNodeRequest struct { From *Node `protobuf:"bytes,1,opt,name=From" json:"From,omitempty"` To *Node `protobuf:"bytes,2,opt,name=To" json:"To,omitempty"` IndexationSession string `protobuf:"bytes,3,opt,name=IndexationSession" json:"IndexationSession,omitempty"` Silent bool `protobuf:"varint,4,opt,name=Silent" json:"Silent,omitempty"` }
func (*UpdateNodeRequest) Descriptor ¶
func (*UpdateNodeRequest) Descriptor() ([]byte, []int)
func (*UpdateNodeRequest) GetFrom ¶
func (m *UpdateNodeRequest) GetFrom() *Node
func (*UpdateNodeRequest) GetIndexationSession ¶
func (m *UpdateNodeRequest) GetIndexationSession() string
func (*UpdateNodeRequest) GetSilent ¶ added in v1.2.0
func (m *UpdateNodeRequest) GetSilent() bool
func (*UpdateNodeRequest) GetTo ¶
func (m *UpdateNodeRequest) GetTo() *Node
func (*UpdateNodeRequest) ProtoMessage ¶
func (*UpdateNodeRequest) ProtoMessage()
func (*UpdateNodeRequest) Reset ¶
func (m *UpdateNodeRequest) Reset()
func (*UpdateNodeRequest) String ¶
func (m *UpdateNodeRequest) String() string
func (*UpdateNodeRequest) Validate ¶ added in v1.6.2
func (this *UpdateNodeRequest) Validate() error
type UpdateNodeResponse ¶
type UpdateNodeResponse struct { Success bool `protobuf:"varint,1,opt,name=Success" json:"Success,omitempty"` Node *Node `protobuf:"bytes,2,opt,name=Node" json:"Node,omitempty"` }
func (*UpdateNodeResponse) Descriptor ¶
func (*UpdateNodeResponse) Descriptor() ([]byte, []int)
func (*UpdateNodeResponse) GetNode ¶
func (m *UpdateNodeResponse) GetNode() *Node
func (*UpdateNodeResponse) GetSuccess ¶
func (m *UpdateNodeResponse) GetSuccess() bool
func (*UpdateNodeResponse) ProtoMessage ¶
func (*UpdateNodeResponse) ProtoMessage()
func (*UpdateNodeResponse) Reset ¶
func (m *UpdateNodeResponse) Reset()
func (*UpdateNodeResponse) String ¶
func (m *UpdateNodeResponse) String() string
func (*UpdateNodeResponse) Validate ¶ added in v1.6.2
func (this *UpdateNodeResponse) Validate() error
type VersioningKeepPeriod ¶
type VersioningKeepPeriod struct { IntervalStart string `protobuf:"bytes,1,opt,name=IntervalStart" json:"IntervalStart,omitempty"` MaxNumber int32 `protobuf:"varint,3,opt,name=MaxNumber" json:"MaxNumber,omitempty"` }
func (*VersioningKeepPeriod) Descriptor ¶
func (*VersioningKeepPeriod) Descriptor() ([]byte, []int)
func (*VersioningKeepPeriod) GetIntervalStart ¶
func (m *VersioningKeepPeriod) GetIntervalStart() string
func (*VersioningKeepPeriod) GetMaxNumber ¶
func (m *VersioningKeepPeriod) GetMaxNumber() int32
func (*VersioningKeepPeriod) ProtoMessage ¶
func (*VersioningKeepPeriod) ProtoMessage()
func (*VersioningKeepPeriod) Reset ¶
func (m *VersioningKeepPeriod) Reset()
func (*VersioningKeepPeriod) String ¶
func (m *VersioningKeepPeriod) String() string
func (*VersioningKeepPeriod) Validate ¶ added in v1.6.2
func (this *VersioningKeepPeriod) Validate() error
type VersioningPolicy ¶
type VersioningPolicy struct { Uuid string `protobuf:"bytes,1,opt,name=Uuid" json:"Uuid,omitempty"` Name string `protobuf:"bytes,2,opt,name=Name" json:"Name,omitempty"` Description string `protobuf:"bytes,3,opt,name=Description" json:"Description,omitempty"` VersionsDataSourceName string `protobuf:"bytes,4,opt,name=VersionsDataSourceName" json:"VersionsDataSourceName,omitempty"` VersionsDataSourceBucket string `protobuf:"bytes,5,opt,name=VersionsDataSourceBucket" json:"VersionsDataSourceBucket,omitempty"` MaxTotalSize int64 `protobuf:"varint,6,opt,name=MaxTotalSize" json:"MaxTotalSize,omitempty"` MaxSizePerFile int64 `protobuf:"varint,7,opt,name=MaxSizePerFile" json:"MaxSizePerFile,omitempty"` IgnoreFilesGreaterThan int64 `protobuf:"varint,8,opt,name=IgnoreFilesGreaterThan" json:"IgnoreFilesGreaterThan,omitempty"` KeepPeriods []*VersioningKeepPeriod `protobuf:"bytes,9,rep,name=KeepPeriods" json:"KeepPeriods,omitempty"` }
func (*VersioningPolicy) Descriptor ¶
func (*VersioningPolicy) Descriptor() ([]byte, []int)
func (*VersioningPolicy) GetDescription ¶
func (m *VersioningPolicy) GetDescription() string
func (*VersioningPolicy) GetIgnoreFilesGreaterThan ¶
func (m *VersioningPolicy) GetIgnoreFilesGreaterThan() int64
func (*VersioningPolicy) GetKeepPeriods ¶
func (m *VersioningPolicy) GetKeepPeriods() []*VersioningKeepPeriod
func (*VersioningPolicy) GetMaxSizePerFile ¶
func (m *VersioningPolicy) GetMaxSizePerFile() int64
func (*VersioningPolicy) GetMaxTotalSize ¶
func (m *VersioningPolicy) GetMaxTotalSize() int64
func (*VersioningPolicy) GetName ¶
func (m *VersioningPolicy) GetName() string
func (*VersioningPolicy) GetUuid ¶
func (m *VersioningPolicy) GetUuid() string
func (*VersioningPolicy) GetVersionsDataSourceBucket ¶
func (m *VersioningPolicy) GetVersionsDataSourceBucket() string
func (*VersioningPolicy) GetVersionsDataSourceName ¶
func (m *VersioningPolicy) GetVersionsDataSourceName() string
func (*VersioningPolicy) MarshalLogObject ¶ added in v1.5.0
func (policy *VersioningPolicy) MarshalLogObject(encoder zapcore.ObjectEncoder) error
MarshalLogObject implements custom marshalling for logs
func (*VersioningPolicy) ProtoMessage ¶
func (*VersioningPolicy) ProtoMessage()
func (*VersioningPolicy) Reset ¶
func (m *VersioningPolicy) Reset()
func (*VersioningPolicy) String ¶
func (m *VersioningPolicy) String() string
func (*VersioningPolicy) Validate ¶ added in v1.6.2
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" json:"Node,omitempty"`
}
Request / Responses Messages
func (*WatchNodeRequest) Descriptor ¶
func (*WatchNodeRequest) Descriptor() ([]byte, []int)
func (*WatchNodeRequest) GetNode ¶
func (m *WatchNodeRequest) GetNode() *Node
func (*WatchNodeRequest) ProtoMessage ¶
func (*WatchNodeRequest) ProtoMessage()
func (*WatchNodeRequest) Reset ¶
func (m *WatchNodeRequest) Reset()
func (*WatchNodeRequest) String ¶
func (m *WatchNodeRequest) String() string
func (*WatchNodeRequest) Validate ¶ added in v1.6.2
func (this *WatchNodeRequest) Validate() error
type WatchNodeResponse ¶
type WatchNodeResponse struct {
Node *Node `protobuf:"bytes,1,opt,name=Node" json:"Node,omitempty"`
}
func (*WatchNodeResponse) Descriptor ¶
func (*WatchNodeResponse) Descriptor() ([]byte, []int)
func (*WatchNodeResponse) GetNode ¶
func (m *WatchNodeResponse) GetNode() *Node
func (*WatchNodeResponse) ProtoMessage ¶
func (*WatchNodeResponse) ProtoMessage()
func (*WatchNodeResponse) Reset ¶
func (m *WatchNodeResponse) Reset()
func (*WatchNodeResponse) String ¶
func (m *WatchNodeResponse) String() string
func (*WatchNodeResponse) Validate ¶ added in v1.6.2
func (this *WatchNodeResponse) Validate() error
type WorkspaceRelativePath ¶
type WorkspaceRelativePath struct { // Workspace Id WsUuid string `protobuf:"bytes,1,opt,name=WsUuid" json:"WsUuid,omitempty"` // Workspace Label WsLabel string `protobuf:"bytes,2,opt,name=WsLabel" json:"WsLabel,omitempty"` // Relative Path inside workspace Path string `protobuf:"bytes,3,opt,name=Path" json:"Path,omitempty"` // Workspace slug WsSlug string `protobuf:"bytes,4,opt,name=WsSlug" json:"WsSlug,omitempty"` // Workspace Scope WsScope string `protobuf:"bytes,5,opt,name=WsScope" json:"WsScope,omitempty"` }
Used in AppearsIn to signal a node is appearing in multiple workspaces in the current context
func (*WorkspaceRelativePath) Descriptor ¶
func (*WorkspaceRelativePath) Descriptor() ([]byte, []int)
func (*WorkspaceRelativePath) GetPath ¶
func (m *WorkspaceRelativePath) GetPath() string
func (*WorkspaceRelativePath) GetWsLabel ¶
func (m *WorkspaceRelativePath) GetWsLabel() string
func (*WorkspaceRelativePath) GetWsScope ¶
func (m *WorkspaceRelativePath) GetWsScope() string
func (*WorkspaceRelativePath) GetWsSlug ¶
func (m *WorkspaceRelativePath) GetWsSlug() string
func (*WorkspaceRelativePath) GetWsUuid ¶
func (m *WorkspaceRelativePath) GetWsUuid() string
func (*WorkspaceRelativePath) ProtoMessage ¶
func (*WorkspaceRelativePath) ProtoMessage()
func (*WorkspaceRelativePath) Reset ¶
func (m *WorkspaceRelativePath) Reset()
func (*WorkspaceRelativePath) String ¶
func (m *WorkspaceRelativePath) String() string
func (*WorkspaceRelativePath) Validate ¶ added in v1.6.2
func (this *WorkspaceRelativePath) Validate() error
type WrappingStreamerResponse ¶
type WrappingStreamerResponse struct { // Types that are valid to be assigned to Data: // *WrappingStreamerResponse_ListNodesResponse // *WrappingStreamerResponse_NodeChangeEvent Data isWrappingStreamerResponse_Data `protobuf_oneof:"Data"` Error string `protobuf:"bytes,3,opt,name=Error" json:"Error,omitempty"` }
func (*WrappingStreamerResponse) Descriptor ¶
func (*WrappingStreamerResponse) Descriptor() ([]byte, []int)
func (*WrappingStreamerResponse) GetData ¶
func (m *WrappingStreamerResponse) GetData() isWrappingStreamerResponse_Data
func (*WrappingStreamerResponse) GetError ¶
func (m *WrappingStreamerResponse) GetError() string
func (*WrappingStreamerResponse) GetListNodesResponse ¶
func (m *WrappingStreamerResponse) GetListNodesResponse() *ListNodesResponse
func (*WrappingStreamerResponse) GetNodeChangeEvent ¶
func (m *WrappingStreamerResponse) GetNodeChangeEvent() *NodeChangeEvent
func (*WrappingStreamerResponse) ProtoMessage ¶
func (*WrappingStreamerResponse) ProtoMessage()
func (*WrappingStreamerResponse) Reset ¶
func (m *WrappingStreamerResponse) Reset()
func (*WrappingStreamerResponse) String ¶
func (m *WrappingStreamerResponse) String() string
func (*WrappingStreamerResponse) Validate ¶
func (this *WrappingStreamerResponse) Validate() error
func (*WrappingStreamerResponse) XXX_OneofFuncs ¶
func (*WrappingStreamerResponse) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})
XXX_OneofFuncs is for the internal use of the proto package.
type WrappingStreamerResponse_ListNodesResponse ¶
type WrappingStreamerResponse_ListNodesResponse struct {
ListNodesResponse *ListNodesResponse `protobuf:"bytes,1,opt,name=ListNodesResponse,oneof"`
}
type WrappingStreamerResponse_NodeChangeEvent ¶
type WrappingStreamerResponse_NodeChangeEvent struct {
NodeChangeEvent *NodeChangeEvent `protobuf:"bytes,2,opt,name=NodeChangeEvent,oneof"`
}