Versions in this module Expand all Collapse all v1 v1.6.1 Jul 9, 2019 Changes in this version + var NodeChangeEvent_EventType_name = map[int32]string + var NodeChangeEvent_EventType_value = map[string]int32 + var NodeType_name = map[int32]string + var NodeType_value = map[string]int32 + var SyncChange_Type_name = map[int32]string + var SyncChange_Type_value = map[string]int32 + func IgnoreNodeForOutput(ctx context.Context, node *Node) bool + func RegisterFileKeyManagerHandler(s server.Server, hdlr FileKeyManagerHandler, 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) + type ChangeLog struct + Data []byte + Description string + Event *NodeChangeEvent + MTime int64 + OwnerUuid string + Size int64 + Uuid string + func (*ChangeLog) Descriptor() ([]byte, []int) + func (*ChangeLog) ProtoMessage() + func (log *ChangeLog) MarshalLogObject(encoder zapcore.ObjectEncoder) error + func (log *ChangeLog) Zap() zapcore.Field + 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 (m *ChangeLog) Reset() + func (m *ChangeLog) String() string + type CloseSessionRequest struct + Session *IndexationSession + func (*CloseSessionRequest) Descriptor() ([]byte, []int) + func (*CloseSessionRequest) ProtoMessage() + func (m *CloseSessionRequest) GetSession() *IndexationSession + func (m *CloseSessionRequest) Reset() + func (m *CloseSessionRequest) String() string + type CloseSessionResponse struct + Session *IndexationSession + func (*CloseSessionResponse) Descriptor() ([]byte, []int) + func (*CloseSessionResponse) ProtoMessage() + func (m *CloseSessionResponse) GetSession() *IndexationSession + func (m *CloseSessionResponse) Reset() + func (m *CloseSessionResponse) String() string + type CreateNodeRequest struct + IndexationSession string + Node *Node + Silent bool + UpdateIfExists bool + func (*CreateNodeRequest) Descriptor() ([]byte, []int) + func (*CreateNodeRequest) ProtoMessage() + func (m *CreateNodeRequest) GetIndexationSession() string + func (m *CreateNodeRequest) GetNode() *Node + func (m *CreateNodeRequest) GetSilent() bool + func (m *CreateNodeRequest) GetUpdateIfExists() bool + func (m *CreateNodeRequest) Reset() + func (m *CreateNodeRequest) String() string + type CreateNodeResponse struct + Node *Node + Success bool + func (*CreateNodeResponse) Descriptor() ([]byte, []int) + func (*CreateNodeResponse) ProtoMessage() + func (m *CreateNodeResponse) GetNode() *Node + func (m *CreateNodeResponse) GetSuccess() bool + func (m *CreateNodeResponse) Reset() + func (m *CreateNodeResponse) String() string + type CreateVersionRequest struct + Node *Node + TriggerEvent *NodeChangeEvent + func (*CreateVersionRequest) Descriptor() ([]byte, []int) + func (*CreateVersionRequest) ProtoMessage() + func (m *CreateVersionRequest) GetNode() *Node + func (m *CreateVersionRequest) GetTriggerEvent() *NodeChangeEvent + func (m *CreateVersionRequest) Reset() + func (m *CreateVersionRequest) String() string + type CreateVersionResponse struct + Version *ChangeLog + func (*CreateVersionResponse) Descriptor() ([]byte, []int) + func (*CreateVersionResponse) ProtoMessage() + func (m *CreateVersionResponse) GetVersion() *ChangeLog + func (m *CreateVersionResponse) Reset() + func (m *CreateVersionResponse) String() string + type DeleteNodeRequest struct + IndexationSession string + Node *Node + Silent bool + func (*DeleteNodeRequest) Descriptor() ([]byte, []int) + func (*DeleteNodeRequest) ProtoMessage() + func (m *DeleteNodeRequest) GetIndexationSession() string + func (m *DeleteNodeRequest) GetNode() *Node + func (m *DeleteNodeRequest) GetSilent() bool + func (m *DeleteNodeRequest) Reset() + func (m *DeleteNodeRequest) String() string + type DeleteNodeResponse struct + Success bool + func (*DeleteNodeResponse) Descriptor() ([]byte, []int) + func (*DeleteNodeResponse) ProtoMessage() + func (m *DeleteNodeResponse) GetSuccess() bool + func (m *DeleteNodeResponse) Reset() + func (m *DeleteNodeResponse) String() string + type FileKeyManager struct + func (h *FileKeyManager) GetEncryptionKey(ctx context.Context, in *GetEncryptionKeyRequest, ...) error + type FileKeyManagerClient interface + GetEncryptionKey func(ctx context.Context, in *GetEncryptionKeyRequest, opts ...client.CallOption) (*GetEncryptionKeyResponse, error) + func NewFileKeyManagerClient(serviceName string, c client.Client) FileKeyManagerClient + type FileKeyManagerHandler interface + GetEncryptionKey func(context.Context, *GetEncryptionKeyRequest, *GetEncryptionKeyResponse) error + type FlushSessionRequest struct + Session *IndexationSession + func (*FlushSessionRequest) Descriptor() ([]byte, []int) + func (*FlushSessionRequest) ProtoMessage() + func (m *FlushSessionRequest) GetSession() *IndexationSession + func (m *FlushSessionRequest) Reset() + func (m *FlushSessionRequest) String() string + type FlushSessionResponse struct + Session *IndexationSession + func (*FlushSessionResponse) Descriptor() ([]byte, []int) + func (*FlushSessionResponse) ProtoMessage() + func (m *FlushSessionResponse) GetSession() *IndexationSession + func (m *FlushSessionResponse) Reset() + func (m *FlushSessionResponse) String() string + type GeoPoint struct + Lat float64 + Lon float64 + func (*GeoPoint) Descriptor() ([]byte, []int) + func (*GeoPoint) ProtoMessage() + func (m *GeoPoint) GetLat() float64 + func (m *GeoPoint) GetLon() float64 + func (m *GeoPoint) Reset() + func (m *GeoPoint) String() string + type GeoQuery struct + BottomRight *GeoPoint + Center *GeoPoint + Distance string + TopLeft *GeoPoint + func (*GeoQuery) Descriptor() ([]byte, []int) + func (*GeoQuery) ProtoMessage() + func (m *GeoQuery) GetBottomRight() *GeoPoint + func (m *GeoQuery) GetCenter() *GeoPoint + func (m *GeoQuery) GetDistance() string + func (m *GeoQuery) GetTopLeft() *GeoPoint + func (m *GeoQuery) Reset() + func (m *GeoQuery) String() string + type GetEncryptionKeyRequest struct + Create bool + Node *Node + Password string + User string + func (*GetEncryptionKeyRequest) Descriptor() ([]byte, []int) + func (*GetEncryptionKeyRequest) ProtoMessage() + func (m *GetEncryptionKeyRequest) GetCreate() bool + func (m *GetEncryptionKeyRequest) GetNode() *Node + func (m *GetEncryptionKeyRequest) GetPassword() string + func (m *GetEncryptionKeyRequest) GetUser() string + func (m *GetEncryptionKeyRequest) Reset() + func (m *GetEncryptionKeyRequest) String() string + type GetEncryptionKeyResponse struct + Key []byte + func (*GetEncryptionKeyResponse) Descriptor() ([]byte, []int) + func (*GetEncryptionKeyResponse) ProtoMessage() + func (m *GetEncryptionKeyResponse) GetKey() []byte + func (m *GetEncryptionKeyResponse) Reset() + func (m *GetEncryptionKeyResponse) String() string + type HeadVersionRequest struct + Node *Node + VersionId string + func (*HeadVersionRequest) Descriptor() ([]byte, []int) + func (*HeadVersionRequest) ProtoMessage() + func (m *HeadVersionRequest) GetNode() *Node + func (m *HeadVersionRequest) GetVersionId() string + func (m *HeadVersionRequest) Reset() + func (m *HeadVersionRequest) String() string + type HeadVersionResponse struct + Version *ChangeLog + func (*HeadVersionResponse) Descriptor() ([]byte, []int) + func (*HeadVersionResponse) ProtoMessage() + func (m *HeadVersionResponse) GetVersion() *ChangeLog + func (m *HeadVersionResponse) Reset() + func (m *HeadVersionResponse) String() string + type IndexEvent struct + DataSourceName string + ErrorDetected bool + ErrorPath string + SessionForceClose string + func (*IndexEvent) Descriptor() ([]byte, []int) + func (*IndexEvent) ProtoMessage() + func (m *IndexEvent) GetDataSourceName() string + func (m *IndexEvent) GetErrorDetected() bool + func (m *IndexEvent) GetErrorPath() string + func (m *IndexEvent) GetSessionForceClose() string + func (m *IndexEvent) Reset() + func (m *IndexEvent) String() string + type IndexationOperation struct + Cursor int64 + Description string + SessionUuid string + func (*IndexationOperation) Descriptor() ([]byte, []int) + func (*IndexationOperation) ProtoMessage() + func (m *IndexationOperation) GetCursor() int64 + func (m *IndexationOperation) GetDescription() string + func (m *IndexationOperation) GetSessionUuid() string + func (m *IndexationOperation) Reset() + func (m *IndexationOperation) String() string + type IndexationSession struct + CurrentOperationCount int64 + Description string + ExpectedOperationsCount int64 + RootNode *Node + Uuid string + func (*IndexationSession) Descriptor() ([]byte, []int) + func (*IndexationSession) ProtoMessage() + func (m *IndexationSession) GetCurrentOperationCount() int64 + func (m *IndexationSession) GetDescription() string + func (m *IndexationSession) GetExpectedOperationsCount() int64 + func (m *IndexationSession) GetRootNode() *Node + func (m *IndexationSession) GetUuid() string + func (m *IndexationSession) Reset() + func (m *IndexationSession) String() string + type ListNodesRequest struct + Ancestors bool + FilterType NodeType + Limit int64 + Node *Node + Offset int64 + Recursive bool + WithCommits bool + WithVersions bool + func (*ListNodesRequest) Descriptor() ([]byte, []int) + func (*ListNodesRequest) ProtoMessage() + 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 (m *ListNodesRequest) Reset() + func (m *ListNodesRequest) String() string + type ListNodesResponse struct + Node *Node + func (*ListNodesResponse) Descriptor() ([]byte, []int) + func (*ListNodesResponse) ProtoMessage() + func (m *ListNodesResponse) GetNode() *Node + func (m *ListNodesResponse) Reset() + func (m *ListNodesResponse) String() string + type ListVersionsRequest struct + Node *Node + func (*ListVersionsRequest) Descriptor() ([]byte, []int) + func (*ListVersionsRequest) ProtoMessage() + func (m *ListVersionsRequest) GetNode() *Node + func (m *ListVersionsRequest) Reset() + func (m *ListVersionsRequest) String() string + type ListVersionsResponse struct + Version *ChangeLog + func (*ListVersionsResponse) Descriptor() ([]byte, []int) + func (*ListVersionsResponse) ProtoMessage() + func (m *ListVersionsResponse) GetVersion() *ChangeLog + func (m *ListVersionsResponse) Reset() + func (m *ListVersionsResponse) String() string + type Node struct + AppearsIn []*WorkspaceRelativePath + Commits []*ChangeLog + Etag string + MTime int64 + MetaStore map[string]string + Mode int32 + Path string + Size int64 + Type NodeType + Uuid string + func BuildAncestorsList(ctx context.Context, treeClient NodeProviderClient, node *Node) (parentUuids []*Node, err error) + func BuildAncestorsListOrParent(ctx context.Context, treeClient NodeProviderClient, node *Node) (parentUuids []*Node, err error) + func (*Node) Descriptor() ([]byte, []int) + func (*Node) ProtoMessage() + func (m *Node) GetAppearsIn() []*WorkspaceRelativePath + func (m *Node) GetCommits() []*ChangeLog + func (m *Node) GetEtag() string + func (m *Node) GetMTime() int64 + func (m *Node) GetMetaStore() map[string]string + func (m *Node) GetMode() int32 + func (m *Node) GetPath() string + func (m *Node) GetSize() int64 + func (m *Node) GetType() NodeType + func (m *Node) GetUuid() string + func (m *Node) Reset() + func (m *Node) String() string + func (node *Node) AllMetaDeserialized(excludes map[string]struct{}) map[string]interface{} + func (node *Node) Clone() *Node + func (node *Node) GetMeta(namespace string, jsonStruc interface{}) error + func (node *Node) GetModTime() time.Time + func (node *Node) GetStringMeta(namespace string) string + func (node *Node) HasMetaKey(keyName string) bool + func (node *Node) HasSource() bool + func (node *Node) IsLeaf() bool + func (node *Node) IsLeafInt() int + func (node *Node) LegacyMeta(meta map[string]interface{}) + func (node *Node) MarshalLogObject(encoder zapcore.ObjectEncoder) error + func (node *Node) SetMeta(namespace string, jsonMeta interface{}) (err 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 struct + Optimistic bool + Silent bool + Source *Node + Target *Node + Type NodeChangeEvent_EventType + func (*NodeChangeEvent) Descriptor() ([]byte, []int) + func (*NodeChangeEvent) ProtoMessage() + 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 (m *NodeChangeEvent) Reset() + func (m *NodeChangeEvent) String() string + func (msg *NodeChangeEvent) Zap() zapcore.Field + type NodeChangeEvent_EventType int32 + const NodeChangeEvent_CREATE + const NodeChangeEvent_DELETE + const NodeChangeEvent_READ + const NodeChangeEvent_UPDATE_CONTENT + const NodeChangeEvent_UPDATE_META + const NodeChangeEvent_UPDATE_PATH + const NodeChangeEvent_UPDATE_USER_META + func (NodeChangeEvent_EventType) EnumDescriptor() ([]byte, []int) + func (x NodeChangeEvent_EventType) String() string + type NodeContentReader struct + type NodeContentReaderClient interface + func NewNodeContentReaderClient(serviceName string, c client.Client) NodeContentReaderClient + type NodeContentReaderHandler interface + type NodeContentWriter struct + type NodeContentWriterClient interface + func NewNodeContentWriterClient(serviceName string, c client.Client) NodeContentWriterClient + type NodeContentWriterHandler interface + type NodeEventsProvider struct + func (h *NodeEventsProvider) WatchNode(ctx context.Context, stream server.Streamer) error + type NodeEventsProviderClient interface + WatchNode func(ctx context.Context, in *WatchNodeRequest, opts ...client.CallOption) (NodeEventsProvider_WatchNodeClient, error) + func NewNodeEventsProviderClient(serviceName string, c client.Client) NodeEventsProviderClient + type NodeEventsProviderHandler interface + WatchNode func(context.Context, *WatchNodeRequest, NodeEventsProvider_WatchNodeStream) error + type NodeEventsProvider_WatchNodeClient interface + Close func() error + Recv func() (*WatchNodeResponse, error) + RecvMsg func(interface{}) error + SendMsg func(interface{}) error + type NodeEventsProvider_WatchNodeStream interface + Close func() error + RecvMsg func(interface{}) error + Send func(*WatchNodeResponse) error + SendMsg func(interface{}) error + type NodeProvider struct + func (h *NodeProvider) ListNodes(ctx context.Context, stream server.Streamer) error + func (h *NodeProvider) ReadNode(ctx context.Context, in *ReadNodeRequest, out *ReadNodeResponse) error + type NodeProviderClient interface + ListNodes func(ctx context.Context, in *ListNodesRequest, opts ...client.CallOption) (NodeProvider_ListNodesClient, error) + ReadNode func(ctx context.Context, in *ReadNodeRequest, opts ...client.CallOption) (*ReadNodeResponse, error) + func NewNodeProviderClient(serviceName string, c client.Client) NodeProviderClient + type NodeProviderHandler interface + ListNodes func(context.Context, *ListNodesRequest, NodeProvider_ListNodesStream) error + ReadNode func(context.Context, *ReadNodeRequest, *ReadNodeResponse) error + type NodeProviderMock struct + Nodes map[string]string + func (m *NodeProviderMock) ListNodes(ctx context.Context, in *ListNodesRequest, opts ...client.CallOption) (NodeProvider_ListNodesClient, error) + func (m *NodeProviderMock) ReadNode(ctx context.Context, in *ReadNodeRequest, opts ...client.CallOption) (*ReadNodeResponse, error) + type NodeProviderStreamer struct + func (h *NodeProviderStreamer) ReadNodeStream(ctx context.Context, stream server.Streamer) error + type NodeProviderStreamerClient interface + ReadNodeStream func(ctx context.Context, opts ...client.CallOption) (NodeProviderStreamer_ReadNodeStreamClient, error) + func NewNodeProviderStreamerClient(serviceName string, c client.Client) NodeProviderStreamerClient + type NodeProviderStreamerHandler interface + ReadNodeStream func(context.Context, NodeProviderStreamer_ReadNodeStreamStream) error + type NodeProviderStreamer_ReadNodeStreamClient interface + Close func() error + Recv func() (*ReadNodeResponse, error) + RecvMsg func(interface{}) error + Send func(*ReadNodeRequest) error + SendMsg func(interface{}) error + type NodeProviderStreamer_ReadNodeStreamStream interface + Close func() error + Recv func() (*ReadNodeRequest, error) + RecvMsg func(interface{}) error + Send func(*ReadNodeResponse) error + SendMsg func(interface{}) error + type NodeProvider_ListNodesClient interface + Close func() error + Recv func() (*ListNodesResponse, error) + RecvMsg func(interface{}) error + SendMsg func(interface{}) error + type NodeProvider_ListNodesStream interface + Close func() error + RecvMsg func(interface{}) error + Send func(*ListNodesResponse) error + SendMsg func(interface{}) error + type NodeReceiver struct + 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 interface + CreateNode func(ctx context.Context, in *CreateNodeRequest, opts ...client.CallOption) (*CreateNodeResponse, error) + DeleteNode func(ctx context.Context, in *DeleteNodeRequest, opts ...client.CallOption) (*DeleteNodeResponse, error) + UpdateNode func(ctx context.Context, in *UpdateNodeRequest, opts ...client.CallOption) (*UpdateNodeResponse, error) + func NewNodeReceiverClient(serviceName string, c client.Client) NodeReceiverClient + type NodeReceiverHandler interface + CreateNode func(context.Context, *CreateNodeRequest, *CreateNodeResponse) error + DeleteNode func(context.Context, *DeleteNodeRequest, *DeleteNodeResponse) error + UpdateNode func(context.Context, *UpdateNodeRequest, *UpdateNodeResponse) error + type NodeReceiverMock struct + Nodes map[string]string + 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 struct + func (h *NodeReceiverStream) CreateNodeStream(ctx context.Context, stream server.Streamer) error + func (h *NodeReceiverStream) DeleteNodeStream(ctx context.Context, stream server.Streamer) error + func (h *NodeReceiverStream) UpdateNodeStream(ctx context.Context, stream server.Streamer) error + type NodeReceiverStreamClient interface + CreateNodeStream func(ctx context.Context, opts ...client.CallOption) (NodeReceiverStream_CreateNodeStreamClient, error) + DeleteNodeStream func(ctx context.Context, opts ...client.CallOption) (NodeReceiverStream_DeleteNodeStreamClient, error) + UpdateNodeStream func(ctx context.Context, opts ...client.CallOption) (NodeReceiverStream_UpdateNodeStreamClient, error) + func NewNodeReceiverStreamClient(serviceName string, c client.Client) NodeReceiverStreamClient + type NodeReceiverStreamHandler interface + CreateNodeStream func(context.Context, NodeReceiverStream_CreateNodeStreamStream) error + DeleteNodeStream func(context.Context, NodeReceiverStream_DeleteNodeStreamStream) error + UpdateNodeStream func(context.Context, NodeReceiverStream_UpdateNodeStreamStream) error + type NodeReceiverStream_CreateNodeStreamClient interface + Close func() error + Recv func() (*CreateNodeResponse, error) + RecvMsg func(interface{}) error + Send func(*CreateNodeRequest) error + SendMsg func(interface{}) error + type NodeReceiverStream_CreateNodeStreamStream interface + Close func() error + Recv func() (*CreateNodeRequest, error) + RecvMsg func(interface{}) error + Send func(*CreateNodeResponse) error + SendMsg func(interface{}) error + type NodeReceiverStream_DeleteNodeStreamClient interface + Close func() error + Recv func() (*DeleteNodeResponse, error) + RecvMsg func(interface{}) error + Send func(*DeleteNodeRequest) error + SendMsg func(interface{}) error + type NodeReceiverStream_DeleteNodeStreamStream interface + Close func() error + Recv func() (*DeleteNodeRequest, error) + RecvMsg func(interface{}) error + Send func(*DeleteNodeResponse) error + SendMsg func(interface{}) error + type NodeReceiverStream_UpdateNodeStreamClient interface + Close func() error + Recv func() (*UpdateNodeResponse, error) + RecvMsg func(interface{}) error + Send func(*UpdateNodeRequest) error + SendMsg func(interface{}) error + type NodeReceiverStream_UpdateNodeStreamStream interface + Close func() error + Recv func() (*UpdateNodeRequest, error) + RecvMsg func(interface{}) error + Send func(*UpdateNodeResponse) error + SendMsg func(interface{}) error + type NodeType int32 + const NodeType_COLLECTION + const NodeType_LEAF + const NodeType_UNKNOWN + func (NodeType) EnumDescriptor() ([]byte, []int) + func (x NodeType) String() string + type NodeVersioner struct + 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 interface + CreateVersion func(ctx context.Context, in *CreateVersionRequest, opts ...client.CallOption) (*CreateVersionResponse, error) + HeadVersion func(ctx context.Context, in *HeadVersionRequest, opts ...client.CallOption) (*HeadVersionResponse, error) + ListVersions func(ctx context.Context, in *ListVersionsRequest, opts ...client.CallOption) (NodeVersioner_ListVersionsClient, error) + PruneVersions func(ctx context.Context, in *PruneVersionsRequest, opts ...client.CallOption) (*PruneVersionsResponse, error) + StoreVersion func(ctx context.Context, in *StoreVersionRequest, opts ...client.CallOption) (*StoreVersionResponse, error) + func NewNodeVersionerClient(serviceName string, c client.Client) NodeVersionerClient + type NodeVersionerHandler interface + CreateVersion func(context.Context, *CreateVersionRequest, *CreateVersionResponse) error + HeadVersion func(context.Context, *HeadVersionRequest, *HeadVersionResponse) error + ListVersions func(context.Context, *ListVersionsRequest, NodeVersioner_ListVersionsStream) error + PruneVersions func(context.Context, *PruneVersionsRequest, *PruneVersionsResponse) error + StoreVersion func(context.Context, *StoreVersionRequest, *StoreVersionResponse) error + type NodeVersioner_ListVersionsClient interface + Close func() error + Recv func() (*ListVersionsResponse, error) + RecvMsg func(interface{}) error + SendMsg func(interface{}) error + type NodeVersioner_ListVersionsStream interface + Close func() error + RecvMsg func(interface{}) error + Send func(*ListVersionsResponse) error + SendMsg func(interface{}) error + type OpenSessionRequest struct + Session *IndexationSession + func (*OpenSessionRequest) Descriptor() ([]byte, []int) + func (*OpenSessionRequest) ProtoMessage() + func (m *OpenSessionRequest) GetSession() *IndexationSession + func (m *OpenSessionRequest) Reset() + func (m *OpenSessionRequest) String() string + type OpenSessionResponse struct + Session *IndexationSession + func (*OpenSessionResponse) Descriptor() ([]byte, []int) + func (*OpenSessionResponse) ProtoMessage() + func (m *OpenSessionResponse) GetSession() *IndexationSession + func (m *OpenSessionResponse) Reset() + func (m *OpenSessionResponse) String() string + type PruneVersionsRequest struct + AllDeletedNodes bool + UniqueNode *Node + func (*PruneVersionsRequest) Descriptor() ([]byte, []int) + func (*PruneVersionsRequest) ProtoMessage() + func (m *PruneVersionsRequest) GetAllDeletedNodes() bool + func (m *PruneVersionsRequest) GetUniqueNode() *Node + func (m *PruneVersionsRequest) Reset() + func (m *PruneVersionsRequest) String() string + type PruneVersionsResponse struct + DeletedVersions []string + func (*PruneVersionsResponse) Descriptor() ([]byte, []int) + func (*PruneVersionsResponse) ProtoMessage() + func (m *PruneVersionsResponse) GetDeletedVersions() []string + func (m *PruneVersionsResponse) Reset() + func (m *PruneVersionsResponse) String() string + type PutSyncChangeResponse struct + Msg string + Success bool + func (*PutSyncChangeResponse) Descriptor() ([]byte, []int) + func (*PutSyncChangeResponse) ProtoMessage() + func (m *PutSyncChangeResponse) GetMsg() string + func (m *PutSyncChangeResponse) GetSuccess() bool + func (m *PutSyncChangeResponse) Reset() + func (m *PutSyncChangeResponse) String() string + type Query struct + Content string + Extension string + FileName string + FreeString string + GeoQuery *GeoQuery + MaxDate int64 + MaxSize int64 + MinDate int64 + MinSize int64 + PathPrefix []string + Type NodeType + func (*Query) Descriptor() ([]byte, []int) + func (*Query) ProtoMessage() + func (m *Query) GetContent() string + func (m *Query) GetExtension() string + func (m *Query) GetFileName() 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) GetPathPrefix() []string + func (m *Query) GetType() NodeType + func (m *Query) Reset() + func (m *Query) String() string + type ReadNodeRequest struct + Node *Node + ObjectStats bool + WithCommits bool + WithExtendedStats bool + func (*ReadNodeRequest) Descriptor() ([]byte, []int) + func (*ReadNodeRequest) ProtoMessage() + func (m *ReadNodeRequest) GetNode() *Node + func (m *ReadNodeRequest) GetObjectStats() bool + func (m *ReadNodeRequest) GetWithCommits() bool + func (m *ReadNodeRequest) GetWithExtendedStats() bool + func (m *ReadNodeRequest) Reset() + func (m *ReadNodeRequest) String() string + type ReadNodeResponse struct + Node *Node + Success bool + func (*ReadNodeResponse) Descriptor() ([]byte, []int) + func (*ReadNodeResponse) ProtoMessage() + func (m *ReadNodeResponse) GetNode() *Node + func (m *ReadNodeResponse) GetSuccess() bool + func (m *ReadNodeResponse) Reset() + func (m *ReadNodeResponse) String() string + type SearchRequest struct + Details bool + Facet string + From int32 + Query *Query + Size int32 + func (*SearchRequest) Descriptor() ([]byte, []int) + func (*SearchRequest) ProtoMessage() + func (m *SearchRequest) GetDetails() bool + func (m *SearchRequest) GetFacet() string + func (m *SearchRequest) GetFrom() int32 + func (m *SearchRequest) GetQuery() *Query + func (m *SearchRequest) GetSize() int32 + func (m *SearchRequest) Reset() + func (m *SearchRequest) String() string + type SearchResponse struct + Node *Node + func (*SearchResponse) Descriptor() ([]byte, []int) + func (*SearchResponse) ProtoMessage() + func (m *SearchResponse) GetNode() *Node + func (m *SearchResponse) Reset() + func (m *SearchResponse) String() string + type SearchSyncChangeRequest struct + Flatten bool + LastSeqOnly bool + Prefix string + Seq uint64 + func (*SearchSyncChangeRequest) Descriptor() ([]byte, []int) + func (*SearchSyncChangeRequest) ProtoMessage() + func (m *SearchSyncChangeRequest) GetFlatten() bool + func (m *SearchSyncChangeRequest) GetLastSeqOnly() bool + func (m *SearchSyncChangeRequest) GetPrefix() string + func (m *SearchSyncChangeRequest) GetSeq() uint64 + func (m *SearchSyncChangeRequest) Reset() + func (m *SearchSyncChangeRequest) String() string + type Searcher struct + func (h *Searcher) Search(ctx context.Context, stream server.Streamer) error + type SearcherClient interface + Search func(ctx context.Context, in *SearchRequest, opts ...client.CallOption) (Searcher_SearchClient, error) + func NewSearcherClient(serviceName string, c client.Client) SearcherClient + type SearcherHandler interface + Search func(context.Context, *SearchRequest, Searcher_SearchStream) error + type Searcher_SearchClient interface + Close func() error + Recv func() (*SearchResponse, error) + RecvMsg func(interface{}) error + SendMsg func(interface{}) error + type Searcher_SearchStream interface + Close func() error + RecvMsg func(interface{}) error + Send func(*SearchResponse) error + SendMsg func(interface{}) error + type SessionIndexer struct + 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 interface + CloseSession func(ctx context.Context, in *CloseSessionRequest, opts ...client.CallOption) (*CloseSessionResponse, error) + FlushSession func(ctx context.Context, in *FlushSessionRequest, opts ...client.CallOption) (*FlushSessionResponse, error) + OpenSession func(ctx context.Context, in *OpenSessionRequest, opts ...client.CallOption) (*OpenSessionResponse, error) + func NewSessionIndexerClient(serviceName string, c client.Client) SessionIndexerClient + type SessionIndexerHandler interface + CloseSession func(context.Context, *CloseSessionRequest, *CloseSessionResponse) error + FlushSession func(context.Context, *FlushSessionRequest, *FlushSessionResponse) error + OpenSession func(context.Context, *OpenSessionRequest, *OpenSessionResponse) error + type StoreVersionRequest struct + Node *Node + Version *ChangeLog + func (*StoreVersionRequest) Descriptor() ([]byte, []int) + func (*StoreVersionRequest) ProtoMessage() + func (m *StoreVersionRequest) GetNode() *Node + func (m *StoreVersionRequest) GetVersion() *ChangeLog + func (m *StoreVersionRequest) Reset() + func (m *StoreVersionRequest) String() string + type StoreVersionResponse struct + PruneVersions []*ChangeLog + Success bool + func (*StoreVersionResponse) Descriptor() ([]byte, []int) + func (*StoreVersionResponse) ProtoMessage() + func (m *StoreVersionResponse) GetPruneVersions() []*ChangeLog + func (m *StoreVersionResponse) GetSuccess() bool + func (m *StoreVersionResponse) Reset() + func (m *StoreVersionResponse) String() string + type StreamerMock struct + func (*StreamerMock) Close() error + func (*StreamerMock) Context() context.Context + func (*StreamerMock) Error() error + func (*StreamerMock) Recv(interface{}) error + func (*StreamerMock) Request() client.Request + func (*StreamerMock) Send(interface{}) error + type SyncChange struct + Node *SyncChangeNode + NodeId string + Seq uint64 + Source string + Target string + Type SyncChange_Type + func (*SyncChange) Descriptor() ([]byte, []int) + func (*SyncChange) ProtoMessage() + 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 (m *SyncChange) Reset() + func (m *SyncChange) String() string + type SyncChangeNode struct + Bytesize int64 + Md5 string + Mtime int64 + NodePath string + RepositoryIdentifier string + func (*SyncChangeNode) Descriptor() ([]byte, []int) + func (*SyncChangeNode) ProtoMessage() + 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 (m *SyncChangeNode) Reset() + func (m *SyncChangeNode) String() string + type SyncChange_Type int32 + const SyncChange_content + const SyncChange_create + const SyncChange_delete + const SyncChange_path + const SyncChange_unknown + func (SyncChange_Type) EnumDescriptor() ([]byte, []int) + func (x SyncChange_Type) String() string + type SyncChanges struct + func (h *SyncChanges) Put(ctx context.Context, stream server.Streamer) error + func (h *SyncChanges) Search(ctx context.Context, stream server.Streamer) error + type SyncChangesClient interface + Put func(ctx context.Context, opts ...client.CallOption) (SyncChanges_PutClient, error) + Search func(ctx context.Context, in *SearchSyncChangeRequest, opts ...client.CallOption) (SyncChanges_SearchClient, error) + func NewSyncChangesClient(serviceName string, c client.Client) SyncChangesClient + type SyncChangesHandler interface + Put func(context.Context, SyncChanges_PutStream) error + Search func(context.Context, *SearchSyncChangeRequest, SyncChanges_SearchStream) error + type SyncChanges_PutClient interface + Close func() error + RecvMsg func(interface{}) error + Send func(*SyncChange) error + SendMsg func(interface{}) error + type SyncChanges_PutStream interface + Close func() error + Recv func() (*SyncChange, error) + RecvMsg func(interface{}) error + SendMsg func(interface{}) error + type SyncChanges_SearchClient interface + Close func() error + Recv func() (*SyncChange, error) + RecvMsg func(interface{}) error + SendMsg func(interface{}) error + type SyncChanges_SearchStream interface + Close func() error + RecvMsg func(interface{}) error + Send func(*SyncChange) error + SendMsg func(interface{}) error + type UpdateNodeRequest struct + From *Node + IndexationSession string + Silent bool + To *Node + func (*UpdateNodeRequest) Descriptor() ([]byte, []int) + func (*UpdateNodeRequest) ProtoMessage() + func (m *UpdateNodeRequest) GetFrom() *Node + func (m *UpdateNodeRequest) GetIndexationSession() string + func (m *UpdateNodeRequest) GetSilent() bool + func (m *UpdateNodeRequest) GetTo() *Node + func (m *UpdateNodeRequest) Reset() + func (m *UpdateNodeRequest) String() string + type UpdateNodeResponse struct + Node *Node + Success bool + func (*UpdateNodeResponse) Descriptor() ([]byte, []int) + func (*UpdateNodeResponse) ProtoMessage() + func (m *UpdateNodeResponse) GetNode() *Node + func (m *UpdateNodeResponse) GetSuccess() bool + func (m *UpdateNodeResponse) Reset() + func (m *UpdateNodeResponse) String() string + type VersioningKeepPeriod struct + IntervalStart string + MaxNumber int32 + func (*VersioningKeepPeriod) Descriptor() ([]byte, []int) + func (*VersioningKeepPeriod) ProtoMessage() + func (m *VersioningKeepPeriod) GetIntervalStart() string + func (m *VersioningKeepPeriod) GetMaxNumber() int32 + func (m *VersioningKeepPeriod) Reset() + func (m *VersioningKeepPeriod) String() string + type VersioningPolicy struct + Description string + IgnoreFilesGreaterThan int64 + KeepPeriods []*VersioningKeepPeriod + MaxSizePerFile int64 + MaxTotalSize int64 + Name string + Uuid string + VersionsDataSourceBucket string + VersionsDataSourceName string + func (*VersioningPolicy) Descriptor() ([]byte, []int) + func (*VersioningPolicy) ProtoMessage() + 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 (m *VersioningPolicy) Reset() + func (m *VersioningPolicy) String() string + func (policy *VersioningPolicy) MarshalLogObject(encoder zapcore.ObjectEncoder) error + func (policy *VersioningPolicy) Zap() zapcore.Field + type WatchNodeRequest struct + Node *Node + func (*WatchNodeRequest) Descriptor() ([]byte, []int) + func (*WatchNodeRequest) ProtoMessage() + func (m *WatchNodeRequest) GetNode() *Node + func (m *WatchNodeRequest) Reset() + func (m *WatchNodeRequest) String() string + type WatchNodeResponse struct + Node *Node + func (*WatchNodeResponse) Descriptor() ([]byte, []int) + func (*WatchNodeResponse) ProtoMessage() + func (m *WatchNodeResponse) GetNode() *Node + func (m *WatchNodeResponse) Reset() + func (m *WatchNodeResponse) String() string + type WorkspaceRelativePath struct + Path string + WsLabel string + WsUuid string + func (*WorkspaceRelativePath) Descriptor() ([]byte, []int) + func (*WorkspaceRelativePath) ProtoMessage() + func (m *WorkspaceRelativePath) GetPath() string + func (m *WorkspaceRelativePath) GetWsLabel() string + func (m *WorkspaceRelativePath) GetWsUuid() string + func (m *WorkspaceRelativePath) Reset() + func (m *WorkspaceRelativePath) String() string Incompatible versions in this module v2.0.6+incompatible Apr 23, 2020