tree

package
v5.0.0-...-2679821 Latest Latest
Warning

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

 Go to latest Published: Jan 6, 2025 License: AGPL-3.0 Imports: 37 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	MetaFilterGrep      = "grep"
	MetaFilterNoGrep    = "no-grep"
	MetaFilterForceGrep = "force-grep"
	MetaFilterTime      = "time"
	MetaFilterSize      = "size"
	MetaFilterETag      = "etag"
	MetaFilterDepth     = "depth"

	MetaSortTime   = "mtime"
	MetaSortSize   = "size"
	MetaSortName   = "name"
	MetaSortNameCI = "name_ci"
	MetaSortMPath  = "mpath1,mpath2,mpath3,mpath4"
	MetaSortType   = "leaf"
)
View Source 
const (
	StatFlagDefault uint32 = iota
	StatFlagNone
	StatFlagFolderSize
	StatFlagFolderCounts
	StatFlagMetaMinimal
	StatFlagRecursiveCount

	StatFlagHeaderName = "x-pydio-read-stat-flags"
)

Variables

View Source 
var (
	VersioningNodeDeletedStrategy_name = map[int32]string{
		0: "KeepAll",
		1: "KeepLast",
		2: "KeepNone",
	}
	VersioningNodeDeletedStrategy_value = map[string]int32{
		"KeepAll":  0,
		"KeepLast": 1,
		"KeepNone": 2,
	}
)

Enum value maps for VersioningNodeDeletedStrategy.

View Source 
var (
	NodeType_name = map[int32]string{
		0: "UNKNOWN",
		1: "LEAF",
		2: "COLLECTION",
	}
	NodeType_value = map[string]int32{
		"UNKNOWN":    0,
		"LEAF":       1,
		"COLLECTION": 2,
	}
)

Enum value maps for NodeType.

View Source 
var (
	NodeChangeEvent_EventType_name = map[int32]string{
		0: "CREATE",
		1: "READ",
		2: "UPDATE_PATH",
		3: "UPDATE_CONTENT",
		4: "UPDATE_META",
		6: "UPDATE_USER_META",
		5: "DELETE",
	}
	NodeChangeEvent_EventType_value = map[string]int32{
		"CREATE":           0,
		"READ":             1,
		"UPDATE_PATH":      2,
		"UPDATE_CONTENT":   3,
		"UPDATE_META":      4,
		"UPDATE_USER_META": 6,
		"DELETE":           5,
	}
)

Enum value maps for NodeChangeEvent_EventType.

View Source 
var (
	SyncChange_Type_name = map[int32]string{
		0: "unknown",
		1: "create",
		2: "delete",
		3: "path",
		4: "content",
	}
	SyncChange_Type_value = map[string]int32{
		"unknown": 0,
		"create":  1,
		"delete":  2,
		"path":    3,
		"content": 4,
	}
)

Enum value maps for SyncChange_Type.

View Source 
var FileKeyManager_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "tree.FileKeyManager",
	HandlerType: (*FileKeyManagerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetEncryptionKey",
			Handler:    _FileKeyManager_GetEncryptionKey_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "cells-tree.proto",
}

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

View Source 
var File_cells_tree_proto protoreflect.FileDescriptor
View Source 
var NodeChangesReceiverStreamer_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "tree.NodeChangesReceiverStreamer",
	HandlerType: (*NodeChangesReceiverStreamerServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "PostNodeChanges",
			Handler:       _NodeChangesReceiverStreamer_PostNodeChanges_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "cells-tree.proto",
}

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

View Source 
var NodeChangesStreamer_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "tree.NodeChangesStreamer",
	HandlerType: (*NodeChangesStreamerServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "StreamChanges",
			Handler:       _NodeChangesStreamer_StreamChanges_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "cells-tree.proto",
}

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

View Source 
var NodeContentReader_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "tree.NodeContentReader",
	HandlerType: (*NodeContentReaderServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams:     []grpc.StreamDesc{},
	Metadata:    "cells-tree.proto",
}

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

View Source 
var NodeContentWriter_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "tree.NodeContentWriter",
	HandlerType: (*NodeContentWriterServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams:     []grpc.StreamDesc{},
	Metadata:    "cells-tree.proto",
}

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

View Source 
var NodeEventsProvider_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "tree.NodeEventsProvider",
	HandlerType: (*NodeEventsProviderServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "WatchNode",
			Handler:       _NodeEventsProvider_WatchNode_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "cells-tree.proto",
}

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

View Source 
var NodeProviderStreamer_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "tree.NodeProviderStreamer",
	HandlerType: (*NodeProviderStreamerServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "ReadNodeStream",
			Handler:       _NodeProviderStreamer_ReadNodeStream_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "cells-tree.proto",
}

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

View Source 
var NodeProvider_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "tree.NodeProvider",
	HandlerType: (*NodeProviderServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ReadNode",
			Handler:    _NodeProvider_ReadNode_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "ListNodes",
			Handler:       _NodeProvider_ListNodes_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "cells-tree.proto",
}

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

View Source 
var NodeReceiverStream_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "tree.NodeReceiverStream",
	HandlerType: (*NodeReceiverStreamServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "CreateNodeStream",
			Handler:       _NodeReceiverStream_CreateNodeStream_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
		{
			StreamName:    "UpdateNodeStream",
			Handler:       _NodeReceiverStream_UpdateNodeStream_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
		{
			StreamName:    "DeleteNodeStream",
			Handler:       _NodeReceiverStream_DeleteNodeStream_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "cells-tree.proto",
}

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

View Source 
var NodeReceiver_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "tree.NodeReceiver",
	HandlerType: (*NodeReceiverServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateNode",
			Handler:    _NodeReceiver_CreateNode_Handler,
		},
		{
			MethodName: "UpdateNode",
			Handler:    _NodeReceiver_UpdateNode_Handler,
		},
		{
			MethodName: "DeleteNode",
			Handler:    _NodeReceiver_DeleteNode_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "cells-tree.proto",
}

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

View Source 
var NodeVersioner_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "tree.NodeVersioner",
	HandlerType: (*NodeVersionerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateVersion",
			Handler:    _NodeVersioner_CreateVersion_Handler,
		},
		{
			MethodName: "StoreVersion",
			Handler:    _NodeVersioner_StoreVersion_Handler,
		},
		{
			MethodName: "HeadVersion",
			Handler:    _NodeVersioner_HeadVersion_Handler,
		},
		{
			MethodName: "PruneVersions",
			Handler:    _NodeVersioner_PruneVersions_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "ListVersions",
			Handler:       _NodeVersioner_ListVersions_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "ListVersioningPolicies",
			Handler:       _NodeVersioner_ListVersioningPolicies_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "cells-tree.proto",
}

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

View Source 
var Searcher_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "tree.Searcher",
	HandlerType: (*SearcherServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Search",
			Handler:       _Searcher_Search_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "cells-tree.proto",
}

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

View Source 
var SessionIndexer_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "tree.SessionIndexer",
	HandlerType: (*SessionIndexerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "OpenSession",
			Handler:    _SessionIndexer_OpenSession_Handler,
		},
		{
			MethodName: "FlushSession",
			Handler:    _SessionIndexer_FlushSession_Handler,
		},
		{
			MethodName: "CloseSession",
			Handler:    _SessionIndexer_CloseSession_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "cells-tree.proto",
}

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

View Source 
var SyncChanges_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "tree.SyncChanges",
	HandlerType: (*SyncChangesServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Put",
			Handler:       _SyncChanges_Put_Handler,
			ClientStreams: true,
		},
		{
			StreamName:    "Search",
			Handler:       _SyncChanges_Search_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "cells-tree.proto",
}

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

Functions

func IgnoreNodeForOutput 

func IgnoreNodeForOutput(ctx context.Context, node *Node) bool

IgnoreNodeForOutput checks wether a node shall be ignored for outputs sent to end user (typically websocket events, activities, etc)

func NewIMPath 

func NewIMPath(x any) error

func NewINode 

func NewINode(x any) error

func NewITreeNode 

func NewITreeNode(x any) error

func NewStreamerMock 

func NewStreamerMock(ctx context.Context, nodes map[string]Node) grpc.ClientStream

func PredefineError 

func PredefineError(f ErrorThrower)

func RegisterFileKeyManagerServer 

func RegisterFileKeyManagerServer(s grpc.ServiceRegistrar, srv FileKeyManagerServer)

func RegisterNodeChangesReceiverStreamerServer 

func RegisterNodeChangesReceiverStreamerServer(s grpc.ServiceRegistrar, srv NodeChangesReceiverStreamerServer)

func RegisterNodeChangesStreamerServer 

func RegisterNodeChangesStreamerServer(s grpc.ServiceRegistrar, srv NodeChangesStreamerServer)

func RegisterNodeContentReaderServer 

func RegisterNodeContentReaderServer(s grpc.ServiceRegistrar, srv NodeContentReaderServer)

func RegisterNodeContentWriterServer 

func RegisterNodeContentWriterServer(s grpc.ServiceRegistrar, srv NodeContentWriterServer)

func RegisterNodeEventsProviderServer 

func RegisterNodeEventsProviderServer(s grpc.ServiceRegistrar, srv NodeEventsProviderServer)

func RegisterNodeProviderServer 

func RegisterNodeProviderServer(s grpc.ServiceRegistrar, srv NodeProviderServer)

func RegisterNodeProviderStreamerServer 

func RegisterNodeProviderStreamerServer(s grpc.ServiceRegistrar, srv NodeProviderStreamerServer)

func RegisterNodeReceiverServer 

func RegisterNodeReceiverServer(s grpc.ServiceRegistrar, srv NodeReceiverServer)

func RegisterNodeReceiverStreamServer 

func RegisterNodeReceiverStreamServer(s grpc.ServiceRegistrar, srv NodeReceiverStreamServer)

func RegisterNodeVersionerServer 

func RegisterNodeVersionerServer(s grpc.ServiceRegistrar, srv NodeVersionerServer)

func RegisterSearcherServer 

func RegisterSearcherServer(s grpc.ServiceRegistrar, srv SearcherServer)

func RegisterSessionIndexerServer 

func RegisterSessionIndexerServer(s grpc.ServiceRegistrar, srv SessionIndexerServer)

func RegisterSyncChangesServer 

func RegisterSyncChangesServer(s grpc.ServiceRegistrar, srv SyncChangesServer)

func ShouldError 

func ShouldError(obj interface{}, fn string, params ...interface{}) error

func ValidSortField 

func ValidSortField(sortField string) bool

Types

type ChangeLog 

type ChangeLog struct {

	// Unique commit ID
	Uuid string `protobuf:"bytes,1,opt,name=Uuid,proto3" json:"Uuid,omitempty"`
	// Human-readable description of what happened
	Description string `protobuf:"bytes,2,opt,name=Description,proto3" json:"Description,omitempty"`
	// Unix Timestamp
	MTime int64 `protobuf:"varint,3,opt,name=MTime,proto3" json:"MTime,omitempty"`
	// Content Size at that moment
	Size int64 `protobuf:"varint,4,opt,name=Size,proto3" json:"Size,omitempty"`
	// Arbitrary additional data
	Data []byte `protobuf:"bytes,5,opt,name=Data,proto3" json:"Data,omitempty"`
	// Who performed this action
	OwnerUuid string `protobuf:"bytes,6,opt,name=OwnerUuid,proto3" json:"OwnerUuid,omitempty"`
	// Event that triggered this change
	Event *NodeChangeEvent `protobuf:"bytes,7,opt,name=Event,proto3" json:"Event,omitempty"`
	// Actual location of the stored version
	Location *Node `protobuf:"bytes,8,opt,name=Location,proto3" json:"Location,omitempty"`
	// contains filtered or unexported fields
}

func (*ChangeLog) Descriptor deprecated 

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

Deprecated: Use ChangeLog.ProtoReflect.Descriptor instead.

func (*ChangeLog) GetData 

func (x *ChangeLog) GetData() []byte

func (*ChangeLog) GetDescription 

func (x *ChangeLog) GetDescription() string

func (*ChangeLog) GetEvent 

func (x *ChangeLog) GetEvent() *NodeChangeEvent

func (*ChangeLog) GetLocation 

func (x *ChangeLog) GetLocation() *Node

func (*ChangeLog) GetMTime 

func (x *ChangeLog) GetMTime() int64

func (*ChangeLog) GetOwnerUuid 

func (x *ChangeLog) GetOwnerUuid() string

func (*ChangeLog) GetSize 

func (x *ChangeLog) GetSize() int64

func (*ChangeLog) GetUuid 

func (x *ChangeLog) GetUuid() string

func (*ChangeLog) MarshalLogObject 

func (log *ChangeLog) MarshalLogObject(encoder zapcore.ObjectEncoder) error

MarshalLogObject implements custom marshalling for logs

func (*ChangeLog) ProtoMessage 

func (*ChangeLog) ProtoMessage()

func (*ChangeLog) ProtoReflect 

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

func (*ChangeLog) Reset 

func (x *ChangeLog) Reset()

func (*ChangeLog) String 

func (x *ChangeLog) String() string

func (*ChangeLog) Zap 

func (log *ChangeLog) Zap() zapcore.Field

Zap simply returns a zapcore.Field object populated with this ChangeLog uneder a standard key

type CloseSessionRequest 

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

func (*CloseSessionRequest) Descriptor deprecated 

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

Deprecated: Use CloseSessionRequest.ProtoReflect.Descriptor instead.

func (*CloseSessionRequest) GetSession 

func (x *CloseSessionRequest) GetSession() *IndexationSession

func (*CloseSessionRequest) ProtoMessage 

func (*CloseSessionRequest) ProtoMessage()

func (*CloseSessionRequest) ProtoReflect 

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

func (*CloseSessionRequest) Reset 

func (x *CloseSessionRequest) Reset()

func (*CloseSessionRequest) String 

func (x *CloseSessionRequest) String() string

type CloseSessionResponse 

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

func (*CloseSessionResponse) Descriptor deprecated 

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

Deprecated: Use CloseSessionResponse.ProtoReflect.Descriptor instead.

func (*CloseSessionResponse) GetSession 

func (x *CloseSessionResponse) GetSession() *IndexationSession

func (*CloseSessionResponse) ProtoMessage 

func (*CloseSessionResponse) ProtoMessage()

func (*CloseSessionResponse) ProtoReflect 

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

func (*CloseSessionResponse) Reset 

func (x *CloseSessionResponse) Reset()

func (*CloseSessionResponse) String 

func (x *CloseSessionResponse) String() string

type CreateNodeRequest 

type CreateNodeRequest struct {
	Node              *Node  `protobuf:"bytes,1,opt,name=Node,proto3" json:"Node,omitempty"`
	UpdateIfExists    bool   `protobuf:"varint,2,opt,name=UpdateIfExists,proto3" json:"UpdateIfExists,omitempty"`
	IndexationSession string `protobuf:"bytes,3,opt,name=IndexationSession,proto3" json:"IndexationSession,omitempty"`
	Silent            bool   `protobuf:"varint,4,opt,name=Silent,proto3" json:"Silent,omitempty"`
	// contains filtered or unexported fields
}

Request / Responses Messages

func (*CreateNodeRequest) Descriptor deprecated 

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

Deprecated: Use CreateNodeRequest.ProtoReflect.Descriptor instead.

func (*CreateNodeRequest) GetIndexationSession 

func (x *CreateNodeRequest) GetIndexationSession() string

func (*CreateNodeRequest) GetNode 

func (x *CreateNodeRequest) GetNode() *Node

func (*CreateNodeRequest) GetSilent 

func (x *CreateNodeRequest) GetSilent() bool

func (*CreateNodeRequest) GetUpdateIfExists 

func (x *CreateNodeRequest) GetUpdateIfExists() bool

func (*CreateNodeRequest) ProtoMessage 

func (*CreateNodeRequest) ProtoMessage()

func (*CreateNodeRequest) ProtoReflect 

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

func (*CreateNodeRequest) Reset 

func (x *CreateNodeRequest) Reset()

func (*CreateNodeRequest) String 

func (x *CreateNodeRequest) String() string

type CreateNodeResponse 

type CreateNodeResponse struct {
	Success bool  `protobuf:"varint,1,opt,name=Success,proto3" json:"Success,omitempty"`
	Node    *Node `protobuf:"bytes,2,opt,name=Node,proto3" json:"Node,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateNodeResponse) Descriptor deprecated 

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

Deprecated: Use CreateNodeResponse.ProtoReflect.Descriptor instead.

func (*CreateNodeResponse) GetNode 

func (x *CreateNodeResponse) GetNode() *Node

func (*CreateNodeResponse) GetSuccess 

func (x *CreateNodeResponse) GetSuccess() bool

func (*CreateNodeResponse) ProtoMessage 

func (*CreateNodeResponse) ProtoMessage()

func (*CreateNodeResponse) ProtoReflect 

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

func (*CreateNodeResponse) Reset 

func (x *CreateNodeResponse) Reset()

func (*CreateNodeResponse) String 

func (x *CreateNodeResponse) String() string

type CreateVersionRequest 

type CreateVersionRequest struct {
	Node         *Node            `protobuf:"bytes,1,opt,name=Node,proto3" json:"Node,omitempty"`
	TriggerEvent *NodeChangeEvent `protobuf:"bytes,2,opt,name=TriggerEvent,proto3" json:"TriggerEvent,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateVersionRequest) Descriptor deprecated 

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

Deprecated: Use CreateVersionRequest.ProtoReflect.Descriptor instead.

func (*CreateVersionRequest) GetNode 

func (x *CreateVersionRequest) GetNode() *Node

func (*CreateVersionRequest) GetTriggerEvent 

func (x *CreateVersionRequest) GetTriggerEvent() *NodeChangeEvent

func (*CreateVersionRequest) ProtoMessage 

func (*CreateVersionRequest) ProtoMessage()

func (*CreateVersionRequest) ProtoReflect 

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

func (*CreateVersionRequest) Reset 

func (x *CreateVersionRequest) Reset()

func (*CreateVersionRequest) String 

func (x *CreateVersionRequest) String() string

type CreateVersionResponse 

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

func (*CreateVersionResponse) Descriptor deprecated 

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

Deprecated: Use CreateVersionResponse.ProtoReflect.Descriptor instead.

func (*CreateVersionResponse) GetVersion 

func (x *CreateVersionResponse) GetVersion() *ChangeLog

func (*CreateVersionResponse) ProtoMessage 

func (*CreateVersionResponse) ProtoMessage()

func (*CreateVersionResponse) ProtoReflect 

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

func (*CreateVersionResponse) Reset 

func (x *CreateVersionResponse) Reset()

func (*CreateVersionResponse) String 

func (x *CreateVersionResponse) String() string

type DeleteNodeRequest 

type DeleteNodeRequest struct {
	Node              *Node  `protobuf:"bytes,1,opt,name=Node,proto3" json:"Node,omitempty"`
	IndexationSession string `protobuf:"bytes,2,opt,name=IndexationSession,proto3" json:"IndexationSession,omitempty"`
	Silent            bool   `protobuf:"varint,3,opt,name=Silent,proto3" json:"Silent,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteNodeRequest) Descriptor deprecated 

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

Deprecated: Use DeleteNodeRequest.ProtoReflect.Descriptor instead.

func (*DeleteNodeRequest) GetIndexationSession 

func (x *DeleteNodeRequest) GetIndexationSession() string

func (*DeleteNodeRequest) GetNode 

func (x *DeleteNodeRequest) GetNode() *Node

func (*DeleteNodeRequest) GetSilent 

func (x *DeleteNodeRequest) GetSilent() bool

func (*DeleteNodeRequest) ProtoMessage 

func (*DeleteNodeRequest) ProtoMessage()

func (*DeleteNodeRequest) ProtoReflect 

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

func (*DeleteNodeRequest) Reset 

func (x *DeleteNodeRequest) Reset()

func (*DeleteNodeRequest) String 

func (x *DeleteNodeRequest) String() string

type DeleteNodeResponse 

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

func (*DeleteNodeResponse) Descriptor deprecated 

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

Deprecated: Use DeleteNodeResponse.ProtoReflect.Descriptor instead.

func (*DeleteNodeResponse) GetSuccess 

func (x *DeleteNodeResponse) GetSuccess() bool

func (*DeleteNodeResponse) ProtoMessage 

func (*DeleteNodeResponse) ProtoMessage()

func (*DeleteNodeResponse) ProtoReflect 

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

func (*DeleteNodeResponse) Reset 

func (x *DeleteNodeResponse) Reset()

func (*DeleteNodeResponse) String 

func (x *DeleteNodeResponse) String() string

type ErrorThrower 

type ErrorThrower func(string, string, ...interface{}) error

type FileKeyManagerClient 

type FileKeyManagerClient interface {
	GetEncryptionKey(ctx context.Context, in *GetEncryptionKeyRequest, opts ...grpc.CallOption) (*GetEncryptionKeyResponse, error)
}

FileKeyManagerClient is the client API for FileKeyManager service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewFileKeyManagerClient 

func NewFileKeyManagerClient(cc grpc.ClientConnInterface) FileKeyManagerClient

type FileKeyManagerServer 

type FileKeyManagerServer interface {
	GetEncryptionKey(context.Context, *GetEncryptionKeyRequest) (*GetEncryptionKeyResponse, error)
	// contains filtered or unexported methods
}

FileKeyManagerServer is the server API for FileKeyManager service. All implementations must embed UnimplementedFileKeyManagerServer for forward compatibility

type FileKeyManagerStub 

type FileKeyManagerStub struct {
	FileKeyManagerServer
}

func (*FileKeyManagerStub) Invoke 

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

func (*FileKeyManagerStub) NewStream 

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

type FilterBuilder 

type FilterBuilder interface {
	// And appends an AND query
	And(query interface{}, args ...interface{})
	// OrderBy appends an ORDER BY instruction
	OrderBy(fieldName string, dir string)
	// Ors creates a combined query of ORS
	Ors(queries []string, args []interface{}) interface{}
}

FilterBuilder interfaces a DB clause builder

type Flags 

type Flags []uint32

func StatFlags 

func StatFlags(flags []uint32) Flags

func StatFlagsFromString 

func StatFlagsFromString(s string) Flags

StatFlagsFromString parses a string of flags separated by dashes

func (Flags) AsMeta 

func (f Flags) AsMeta() map[string]string

AsMeta returns a map of headers to be sent to the client

func (Flags) FolderCounts 

func (f Flags) FolderCounts() bool

func (Flags) Metas 

func (f Flags) Metas() bool

func (Flags) MinimalMetas 

func (f Flags) MinimalMetas() bool

func (Flags) RecursiveCount 

func (f Flags) RecursiveCount() bool

func (Flags) String 

func (f Flags) String() string

String returns a string representation of the flags

type FlushSessionRequest 

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

func (*FlushSessionRequest) Descriptor deprecated 

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

Deprecated: Use FlushSessionRequest.ProtoReflect.Descriptor instead.

func (*FlushSessionRequest) GetSession 

func (x *FlushSessionRequest) GetSession() *IndexationSession

func (*FlushSessionRequest) ProtoMessage 

func (*FlushSessionRequest) ProtoMessage()

func (*FlushSessionRequest) ProtoReflect 

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

func (*FlushSessionRequest) Reset 

func (x *FlushSessionRequest) Reset()

func (*FlushSessionRequest) String 

func (x *FlushSessionRequest) String() string

type FlushSessionResponse 

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

func (*FlushSessionResponse) Descriptor deprecated 

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

Deprecated: Use FlushSessionResponse.ProtoReflect.Descriptor instead.

func (*FlushSessionResponse) GetSession 

func (x *FlushSessionResponse) GetSession() *IndexationSession

func (*FlushSessionResponse) ProtoMessage 

func (*FlushSessionResponse) ProtoMessage()

func (*FlushSessionResponse) ProtoReflect 

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

func (*FlushSessionResponse) Reset 

func (x *FlushSessionResponse) Reset()

func (*FlushSessionResponse) String 

func (x *FlushSessionResponse) String() string

type GeoJson 

type GeoJson struct {
	Type        string    `bson:"type"`
	Coordinates []float64 `bson:"coordinates"`
}

type GeoPoint 

type GeoPoint struct {
	Lat float64 `protobuf:"fixed64,1,opt,name=Lat,proto3" json:"Lat,omitempty"`
	Lon float64 `protobuf:"fixed64,2,opt,name=Lon,proto3" json:"Lon,omitempty"`
	// contains filtered or unexported fields
}

func (*GeoPoint) Descriptor deprecated 

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

Deprecated: Use GeoPoint.ProtoReflect.Descriptor instead.

func (*GeoPoint) GetLat 

func (x *GeoPoint) GetLat() float64

func (*GeoPoint) GetLon 

func (x *GeoPoint) GetLon() float64

func (*GeoPoint) ProtoMessage 

func (*GeoPoint) ProtoMessage()

func (*GeoPoint) ProtoReflect 

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

func (*GeoPoint) Reset 

func (x *GeoPoint) Reset()

func (*GeoPoint) String 

func (x *GeoPoint) String() string

type GeoQuery 

type GeoQuery struct {

	// Either use a center point and a distance
	Center *GeoPoint `protobuf:"bytes,1,opt,name=Center,proto3" json:"Center,omitempty"`
	// Example formats supported:
	// "5in" "5inch" "7yd" "7yards" "9ft" "9feet" "11km" "11kilometers"
	// "3nm" "3nauticalmiles" "13mm" "13millimeters" "15cm" "15centimeters"
	// "17mi" "17miles" "19m" "19meters"
	// If the unit cannot be determined, the entire string is parsed and the
	// unit of meters is assumed.
	Distance string `protobuf:"bytes,2,opt,name=Distance,proto3" json:"Distance,omitempty"`
	// Or use a bounding box with TopLeft and BottomRight points
	TopLeft     *GeoPoint `protobuf:"bytes,3,opt,name=TopLeft,proto3" json:"TopLeft,omitempty"`
	BottomRight *GeoPoint `protobuf:"bytes,4,opt,name=BottomRight,proto3" json:"BottomRight,omitempty"`
	// contains filtered or unexported fields
}

func (*GeoQuery) Descriptor deprecated 

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

Deprecated: Use GeoQuery.ProtoReflect.Descriptor instead.

func (*GeoQuery) GetBottomRight 

func (x *GeoQuery) GetBottomRight() *GeoPoint

func (*GeoQuery) GetCenter 

func (x *GeoQuery) GetCenter() *GeoPoint

func (*GeoQuery) GetDistance 

func (x *GeoQuery) GetDistance() string

func (*GeoQuery) GetTopLeft 

func (x *GeoQuery) GetTopLeft() *GeoPoint

func (*GeoQuery) ProtoMessage 

func (*GeoQuery) ProtoMessage()

func (*GeoQuery) ProtoReflect 

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

func (*GeoQuery) Reset 

func (x *GeoQuery) Reset()

func (*GeoQuery) String 

func (x *GeoQuery) String() string

type GetEncryptionKeyRequest 

type GetEncryptionKeyRequest struct {
	User     string `protobuf:"bytes,1,opt,name=User,proto3" json:"User,omitempty"`
	Password string `protobuf:"bytes,2,opt,name=Password,proto3" json:"Password,omitempty"`
	Node     *Node  `protobuf:"bytes,3,opt,name=Node,proto3" json:"Node,omitempty"`
	Create   bool   `protobuf:"varint,5,opt,name=Create,proto3" json:"Create,omitempty"`
	// contains filtered or unexported fields
}

func (*GetEncryptionKeyRequest) Descriptor deprecated 

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

Deprecated: Use GetEncryptionKeyRequest.ProtoReflect.Descriptor instead.

func (*GetEncryptionKeyRequest) GetCreate 

func (x *GetEncryptionKeyRequest) GetCreate() bool

func (*GetEncryptionKeyRequest) GetNode 

func (x *GetEncryptionKeyRequest) GetNode() *Node

func (*GetEncryptionKeyRequest) GetPassword 

func (x *GetEncryptionKeyRequest) GetPassword() string

func (*GetEncryptionKeyRequest) GetUser 

func (x *GetEncryptionKeyRequest) GetUser() string

func (*GetEncryptionKeyRequest) ProtoMessage 

func (*GetEncryptionKeyRequest) ProtoMessage()

func (*GetEncryptionKeyRequest) ProtoReflect 

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

func (*GetEncryptionKeyRequest) Reset 

func (x *GetEncryptionKeyRequest) Reset()

func (*GetEncryptionKeyRequest) String 

func (x *GetEncryptionKeyRequest) String() string

type GetEncryptionKeyResponse 

type GetEncryptionKeyResponse struct {
	Key []byte `protobuf:"bytes,1,opt,name=Key,proto3" json:"Key,omitempty"`
	// contains filtered or unexported fields
}

func (*GetEncryptionKeyResponse) Descriptor deprecated 

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

Deprecated: Use GetEncryptionKeyResponse.ProtoReflect.Descriptor instead.

func (*GetEncryptionKeyResponse) GetKey 

func (x *GetEncryptionKeyResponse) GetKey() []byte

func (*GetEncryptionKeyResponse) ProtoMessage 

func (*GetEncryptionKeyResponse) ProtoMessage()

func (*GetEncryptionKeyResponse) ProtoReflect 

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

func (*GetEncryptionKeyResponse) Reset 

func (x *GetEncryptionKeyResponse) Reset()

func (*GetEncryptionKeyResponse) String 

func (x *GetEncryptionKeyResponse) String() string

type HeadVersionRequest 

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

func (*HeadVersionRequest) Descriptor deprecated 

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

Deprecated: Use HeadVersionRequest.ProtoReflect.Descriptor instead.

func (*HeadVersionRequest) GetNode 

func (x *HeadVersionRequest) GetNode() *Node

func (*HeadVersionRequest) GetVersionId 

func (x *HeadVersionRequest) GetVersionId() string

func (*HeadVersionRequest) ProtoMessage 

func (*HeadVersionRequest) ProtoMessage()

func (*HeadVersionRequest) ProtoReflect 

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

func (*HeadVersionRequest) Reset 

func (x *HeadVersionRequest) Reset()

func (*HeadVersionRequest) String 

func (x *HeadVersionRequest) String() string

type HeadVersionResponse 

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

func (*HeadVersionResponse) Descriptor deprecated 

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

Deprecated: Use HeadVersionResponse.ProtoReflect.Descriptor instead.

func (*HeadVersionResponse) GetVersion 

func (x *HeadVersionResponse) GetVersion() *ChangeLog

func (*HeadVersionResponse) ProtoMessage 

func (*HeadVersionResponse) ProtoMessage()

func (*HeadVersionResponse) ProtoReflect 

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

func (*HeadVersionResponse) Reset 

func (x *HeadVersionResponse) Reset()

func (*HeadVersionResponse) String 

func (x *HeadVersionResponse) String() string

type IMPath 

type IMPath interface {
	proto.Message
	MPathGetter
	MPathSetter
}

type INode 

type INode interface {
	proto.Message
	NodeGetter
	NodeSetter
}

type ITreeNode 

type ITreeNode interface {
	proto.Message
	TreeNodeGetter
	TreeNodeSetter
}

func EmptyTreeNode 

func EmptyTreeNode() ITreeNode

EmptyTreeNode is a shortcut for NewTreeNode("")

func NewTreeNode 

func NewTreeNode(path string, withNode ...*Node) ITreeNode

NewTreeNode creates an ITreeNode with a path, and optionally more node info for creation

func NewTreeNodePtr 

func NewTreeNodePtr(path string, withNode ...*Node) *ITreeNode

NewTreeNodePtr creates an ITreeNode with a path, and optionally more node info for creation, and return its pointer

type IndexEvent 

type IndexEvent struct {
	ErrorDetected     bool   `protobuf:"varint,1,opt,name=ErrorDetected,proto3" json:"ErrorDetected,omitempty"`
	DataSourceName    string `protobuf:"bytes,2,opt,name=DataSourceName,proto3" json:"DataSourceName,omitempty"`
	ErrorPath         string `protobuf:"bytes,3,opt,name=ErrorPath,proto3" json:"ErrorPath,omitempty"`
	SessionForceClose string `protobuf:"bytes,4,opt,name=SessionForceClose,proto3" json:"SessionForceClose,omitempty"`
	// contains filtered or unexported fields
}

func (*IndexEvent) Descriptor deprecated 

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

Deprecated: Use IndexEvent.ProtoReflect.Descriptor instead.

func (*IndexEvent) GetDataSourceName 

func (x *IndexEvent) GetDataSourceName() string

func (*IndexEvent) GetErrorDetected 

func (x *IndexEvent) GetErrorDetected() bool

func (*IndexEvent) GetErrorPath 

func (x *IndexEvent) GetErrorPath() string

func (*IndexEvent) GetSessionForceClose 

func (x *IndexEvent) GetSessionForceClose() string

func (*IndexEvent) ProtoMessage 

func (*IndexEvent) ProtoMessage()

func (*IndexEvent) ProtoReflect 

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

func (*IndexEvent) Reset 

func (x *IndexEvent) Reset()

func (*IndexEvent) String 

func (x *IndexEvent) String() string

type IndexableNode 

type IndexableNode struct {
	Node       `bson:"inline"`
	ReloadCore bool `bson:"-"`
	ReloadNs   bool `bson:"-"`

	ModifTime   time.Time              `bson:"modif_time"`
	Basename    string                 `bson:"basename"`
	NodeType    string                 `bson:"node_type"`
	Extension   string                 `bson:"extension"`
	TextContent string                 `bson:"text_content,omitempty"`
	GeoPoint    map[string]interface{} `bson:"-"`                  // Used by Bleve
	GeoJson     *GeoJson               `bson:"geo_json,omitempty"` // Used by Mongo
	Meta        map[string]interface{} `bson:"meta"`
}

func NewMemIndexableNode 

func NewMemIndexableNode(n *Node) *IndexableNode

func (*IndexableNode) BleveType 

func (i *IndexableNode) BleveType() string

func (*IndexableNode) IndexID 

func (i *IndexableNode) IndexID() string

IndexID implements IndexIDProvider interface

func (*IndexableNode) MemLoad 

func (i *IndexableNode) MemLoad()

type IndexationOperation 

type IndexationOperation struct {
	SessionUuid string `protobuf:"bytes,1,opt,name=SessionUuid,proto3" json:"SessionUuid,omitempty"`
	Description string `protobuf:"bytes,2,opt,name=Description,proto3" json:"Description,omitempty"`
	Cursor      int64  `protobuf:"varint,3,opt,name=Cursor,proto3" json:"Cursor,omitempty"`
	// contains filtered or unexported fields
}

func (*IndexationOperation) Descriptor deprecated 

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

Deprecated: Use IndexationOperation.ProtoReflect.Descriptor instead.

func (*IndexationOperation) GetCursor 

func (x *IndexationOperation) GetCursor() int64

func (*IndexationOperation) GetDescription 

func (x *IndexationOperation) GetDescription() string

func (*IndexationOperation) GetSessionUuid 

func (x *IndexationOperation) GetSessionUuid() string

func (*IndexationOperation) ProtoMessage 

func (*IndexationOperation) ProtoMessage()

func (*IndexationOperation) ProtoReflect 

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

func (*IndexationOperation) Reset 

func (x *IndexationOperation) Reset()

func (*IndexationOperation) String 

func (x *IndexationOperation) String() string

type IndexationSession 

type IndexationSession struct {
	Uuid                    string `protobuf:"bytes,1,opt,name=Uuid,proto3" json:"Uuid,omitempty"`
	Description             string `protobuf:"bytes,2,opt,name=Description,proto3" json:"Description,omitempty"`
	RootNode                *Node  `protobuf:"bytes,3,opt,name=RootNode,proto3" json:"RootNode,omitempty"`
	ExpectedOperationsCount int64  `protobuf:"varint,4,opt,name=ExpectedOperationsCount,proto3" json:"ExpectedOperationsCount,omitempty"`
	CurrentOperationCount   int64  `protobuf:"varint,5,opt,name=CurrentOperationCount,proto3" json:"CurrentOperationCount,omitempty"`
	Silent                  bool   `protobuf:"varint,6,opt,name=Silent,proto3" json:"Silent,omitempty"`
	// contains filtered or unexported fields
}

func (*IndexationSession) Descriptor deprecated 

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

Deprecated: Use IndexationSession.ProtoReflect.Descriptor instead.

func (*IndexationSession) GetCurrentOperationCount 

func (x *IndexationSession) GetCurrentOperationCount() int64

func (*IndexationSession) GetDescription 

func (x *IndexationSession) GetDescription() string

func (*IndexationSession) GetExpectedOperationsCount 

func (x *IndexationSession) GetExpectedOperationsCount() int64

func (*IndexationSession) GetRootNode 

func (x *IndexationSession) GetRootNode() *Node

func (*IndexationSession) GetSilent 

func (x *IndexationSession) GetSilent() bool

func (*IndexationSession) GetUuid 

func (x *IndexationSession) GetUuid() string

func (*IndexationSession) ProtoMessage 

func (*IndexationSession) ProtoMessage()

func (*IndexationSession) ProtoReflect 

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

func (*IndexationSession) Reset 

func (x *IndexationSession) Reset()

func (*IndexationSession) String 

func (x *IndexationSession) String() string

type ListNodesRequest 

type ListNodesRequest struct {

	// Main node used as a parent
	Node *Node `protobuf:"bytes,1,opt,name=Node,proto3" json:"Node,omitempty"`
	// Send back all children of the node
	Recursive bool `protobuf:"varint,2,opt,name=Recursive,proto3" json:"Recursive,omitempty"`
	// Send back a list of parent nodes, until the root, including the original node
	Ancestors bool `protobuf:"varint,3,opt,name=Ancestors,proto3" json:"Ancestors,omitempty"`
	// Sends the list of versions for a given node
	WithVersions bool `protobuf:"varint,7,opt,name=WithVersions,proto3" json:"WithVersions,omitempty"`
	// Limit the number of results
	Limit int64 `protobuf:"varint,4,opt,name=Limit,proto3" json:"Limit,omitempty"`
	// Start listing at a given position
	Offset int64 `protobuf:"varint,5,opt,name=Offset,proto3" json:"Offset,omitempty"`
	// Filter by node type (LEAF / COLLECTION)
	FilterType NodeType `protobuf:"varint,6,opt,name=FilterType,proto3,enum=tree.NodeType" json:"FilterType,omitempty"`
	// Generic Details Flags
	StatFlags []uint32 `protobuf:"varint,9,rep,packed,name=StatFlags,proto3" json:"StatFlags,omitempty"`
	// Remote Sort on specific field
	SortField string `protobuf:"bytes,10,opt,name=SortField,proto3" json:"SortField,omitempty"`
	// Sort descending (otherwise ascending)
	SortDirDesc bool `protobuf:"varint,11,opt,name=SortDirDesc,proto3" json:"SortDirDesc,omitempty"`
	// Sends the list of commits for a given node (Deprecated)
	WithCommits bool `protobuf:"varint,8,opt,name=WithCommits,proto3" json:"WithCommits,omitempty"`
	// contains filtered or unexported fields
}

func (*ListNodesRequest) Descriptor deprecated 

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

Deprecated: Use ListNodesRequest.ProtoReflect.Descriptor instead.

func (*ListNodesRequest) GetAncestors 

func (x *ListNodesRequest) GetAncestors() bool

func (*ListNodesRequest) GetFilterType 

func (x *ListNodesRequest) GetFilterType() NodeType

func (*ListNodesRequest) GetLimit 

func (x *ListNodesRequest) GetLimit() int64

func (*ListNodesRequest) GetNode 

func (x *ListNodesRequest) GetNode() *Node

func (*ListNodesRequest) GetOffset 

func (x *ListNodesRequest) GetOffset() int64

func (*ListNodesRequest) GetRecursive 

func (x *ListNodesRequest) GetRecursive() bool

func (*ListNodesRequest) GetSortDirDesc 

func (x *ListNodesRequest) GetSortDirDesc() bool

func (*ListNodesRequest) GetSortField 

func (x *ListNodesRequest) GetSortField() string

func (*ListNodesRequest) GetStatFlags 

func (x *ListNodesRequest) GetStatFlags() []uint32

func (*ListNodesRequest) GetWithCommits 

func (x *ListNodesRequest) GetWithCommits() bool

func (*ListNodesRequest) GetWithVersions 

func (x *ListNodesRequest) GetWithVersions() bool

func (*ListNodesRequest) ProtoMessage 

func (*ListNodesRequest) ProtoMessage()

func (*ListNodesRequest) ProtoReflect 

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

func (*ListNodesRequest) Reset 

func (x *ListNodesRequest) Reset()

func (*ListNodesRequest) String 

func (x *ListNodesRequest) String() string

type ListNodesResponse 

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

func (*ListNodesResponse) Descriptor deprecated 

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

Deprecated: Use ListNodesResponse.ProtoReflect.Descriptor instead.

func (*ListNodesResponse) GetNode 

func (x *ListNodesResponse) GetNode() *Node

func (*ListNodesResponse) ProtoMessage 

func (*ListNodesResponse) ProtoMessage()

func (*ListNodesResponse) ProtoReflect 

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

func (*ListNodesResponse) Reset 

func (x *ListNodesResponse) Reset()

func (*ListNodesResponse) String 

func (x *ListNodesResponse) String() string

type ListVersioningPoliciesRequest 

type ListVersioningPoliciesRequest struct {

	// Limit list to one specific policy
	PolicyID string `protobuf:"bytes,1,opt,name=PolicyID,proto3" json:"PolicyID,omitempty"`
	// Limit the number of results
	Limit int64 `protobuf:"varint,4,opt,name=Limit,proto3" json:"Limit,omitempty"`
	// Start listing at a given position
	Offset int64 `protobuf:"varint,5,opt,name=Offset,proto3" json:"Offset,omitempty"`
	// contains filtered or unexported fields
}

func (*ListVersioningPoliciesRequest) Descriptor deprecated 

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

Deprecated: Use ListVersioningPoliciesRequest.ProtoReflect.Descriptor instead.

func (*ListVersioningPoliciesRequest) GetLimit 

func (x *ListVersioningPoliciesRequest) GetLimit() int64

func (*ListVersioningPoliciesRequest) GetOffset 

func (x *ListVersioningPoliciesRequest) GetOffset() int64

func (*ListVersioningPoliciesRequest) GetPolicyID 

func (x *ListVersioningPoliciesRequest) GetPolicyID() string

func (*ListVersioningPoliciesRequest) ProtoMessage 

func (*ListVersioningPoliciesRequest) ProtoMessage()

func (*ListVersioningPoliciesRequest) ProtoReflect 

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

func (*ListVersioningPoliciesRequest) Reset 

func (x *ListVersioningPoliciesRequest) Reset()

func (*ListVersioningPoliciesRequest) String 

func (x *ListVersioningPoliciesRequest) String() string

type ListVersionsRequest 

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

func (*ListVersionsRequest) Descriptor deprecated 

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

Deprecated: Use ListVersionsRequest.ProtoReflect.Descriptor instead.

func (*ListVersionsRequest) GetNode 

func (x *ListVersionsRequest) GetNode() *Node

func (*ListVersionsRequest) ProtoMessage 

func (*ListVersionsRequest) ProtoMessage()

func (*ListVersionsRequest) ProtoReflect 

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

func (*ListVersionsRequest) Reset 

func (x *ListVersionsRequest) Reset()

func (*ListVersionsRequest) String 

func (x *ListVersionsRequest) String() string

type ListVersionsResponse 

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

func (*ListVersionsResponse) Descriptor deprecated 

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

Deprecated: Use ListVersionsResponse.ProtoReflect.Descriptor instead.

func (*ListVersionsResponse) GetVersion 

func (x *ListVersionsResponse) GetVersion() *ChangeLog

func (*ListVersionsResponse) ProtoMessage 

func (*ListVersionsResponse) ProtoMessage()

func (*ListVersionsResponse) ProtoReflect 

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

func (*ListVersionsResponse) Reset 

func (x *ListVersionsResponse) Reset()

func (*ListVersionsResponse) String 

func (x *ListVersionsResponse) String() string

type MPath 

type MPath struct {
	MPath1 string `` /* 135-byte string literal not displayed */
	MPath2 string `` /* 135-byte string literal not displayed */
	MPath3 string `` /* 135-byte string literal not displayed */
	MPath4 string `` /* 135-byte string literal not displayed */
	// contains filtered or unexported fields
}

func NewMPath 

func NewMPath(m ...uint64) *MPath

func (*MPath) Append 

func (m *MPath) Append(idx uint64) *MPath

func (*MPath) CommonRoot 

func (m *MPath) CommonRoot(m2 *MPath) *MPath

func (*MPath) Descriptor deprecated 

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

Deprecated: Use MPath.ProtoReflect.Descriptor instead.

func (*MPath) FromString 

func (m *MPath) FromString(str string) *MPath

func (*MPath) GetMPath1 

func (x *MPath) GetMPath1() string

func (*MPath) GetMPath2 

func (x *MPath) GetMPath2() string

func (*MPath) GetMPath3 

func (x *MPath) GetMPath3() string

func (*MPath) GetMPath4 

func (x *MPath) GetMPath4() string

func (*MPath) Length 

func (m *MPath) Length() int

func (*MPath) Parent 

func (m *MPath) Parent() *MPath

Parent of a specific path

func (*MPath) Parents 

func (m *MPath) Parents() []*MPath

func (*MPath) ProtoMessage 

func (*MPath) ProtoMessage()

func (*MPath) ProtoReflect 

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

func (*MPath) Reset 

func (x *MPath) Reset()

func (*MPath) SetMPath1 

func (x *MPath) SetMPath1(v string)

func (*MPath) SetMPath2 

func (x *MPath) SetMPath2(v string)

func (*MPath) SetMPath3 

func (x *MPath) SetMPath3(v string)

func (*MPath) SetMPath4 

func (x *MPath) SetMPath4(v string)

func (*MPath) Sibling 

func (m *MPath) Sibling() *MPath

Sibling of a specific path

func (*MPath) String 

func (x *MPath) String() string

func (*MPath) ToString 

func (m *MPath) ToString() string

type MPathEquals 

type MPathEquals struct {
	Value *MPath
}

MPathEquals greater than for where

func (MPathEquals) Build 

func (me MPathEquals) Build(builder clause.Builder)

type MPathEqualsOrLike 

type MPathEqualsOrLike struct {
	Value *MPath
}

MPathEqualsOrLike greater than for where

func (MPathEqualsOrLike) Build 

func (m MPathEqualsOrLike) Build(builder clause.Builder)

type MPathGetter 

type MPathGetter interface {
	GetMPath1() string
	GetMPath2() string
	GetMPath3() string
	GetMPath4() string
}

type MPathLike 

type MPathLike struct {
	Value *MPath
	Alias string
}

MPathLike greater than for where

func (MPathLike) Build 

func (me MPathLike) Build(builder clause.Builder)

type MPathSetter 

type MPathSetter interface {
	SetMPath1(string)
	SetMPath2(string)
	SetMPath3(string)
	SetMPath4(string)
}

type MPathsEquals 

type MPathsEquals struct {
	Values []*MPath
}

MPathsEquals greater than for where

func (MPathsEquals) Build 

func (m MPathsEquals) Build(builder clause.Builder)

type MetaFilter 

type MetaFilter struct {
	// contains filtered or unexported fields
}

MetaFilter holds specific filtering conditions, generally transformed from standard search queries to basic Listing options.

func NewMetaFilter 

func NewMetaFilter(node *Node) *MetaFilter

NewMetaFilter creates a meta filter looking for request node metadata specific keys.

func (*MetaFilter) AddSort 

func (m *MetaFilter) AddSort(defaultField, sortField string, sortDesc bool)

AddSort adds a sort instruction

func (*MetaFilter) Build 

func (m *MetaFilter) Build(builder FilterBuilder)

Build uses appends all clauses to a FilterBuilder

func (*MetaFilter) HasSQLFilters 

func (m *MetaFilter) HasSQLFilters() bool

HasSQLFilters returns true if MetaFilter has one of grep (unless forced), negativeGrep, filterType or int comparators set.

func (*MetaFilter) HasSort 

func (m *MetaFilter) HasSort() bool

HasSort checks if sortField is not empty

func (*MetaFilter) LimitDepth 

func (m *MetaFilter) LimitDepth() int

LimitDepth returns an optional depth limitation.

func (*MetaFilter) Match 

func (m *MetaFilter) Match(name string, n *Node) bool

Match checks node results against conditions.

func (*MetaFilter) MatchForceGrep 

func (m *MetaFilter) MatchForceGrep(name string) bool

MatchForceGrep applies if a meta specifically told to use grep filtering instead of SQL.

func (*MetaFilter) Parse 

func (m *MetaFilter) Parse() bool

Parse loads the filter keys.

func (*MetaFilter) ParseType 

func (m *MetaFilter) ParseType(t NodeType)

ParseType register a node filter type

type N 

type N interface {
	INode

	As(interface{}) bool
	AsProto() *Node

	IsLeaf() bool

	RenewUuidIfEmpty(force bool)

	SetChildrenSize(uint64)
	SetChildrenFiles(uint64)
	SetChildrenFolders(uint64)
	GetChildrenSize() (uint64, bool)
	GetChildrenFiles() (uint64, bool)
	GetChildrenFolders() (uint64, bool)
	SetRawMetadata(map[string]string)
	ListRawMetadata() map[string]string
	GetStringMeta(namespace string) string

	MarshalLogObject(encoder zapcore.ObjectEncoder) error
	Zap(key ...string) zapcore.Field
	ZapPath() zapcore.Field
	ZapUuid() zapcore.Field
}

N is the extracted interface from Node

func LightNode 

func LightNode(nodeType NodeType, uuid, path, eTag string, size, mTime int64, mode int32) N

LightNode create a lightNode

func LightNodeFromProto 

func LightNodeFromProto(n N) N

type Node 

type Node struct {

	// ------------------------------------
	// Core identification of the node
	// ------------------------------------
	Uuid string   `protobuf:"bytes,1,opt,name=Uuid,proto3" json:"Uuid,omitempty" gorm:"column:uuid;type:VARCHAR(128);primaryKey;"`
	Path string   `protobuf:"bytes,2,opt,name=Path,proto3" json:"Path,omitempty" gorm:"-:all"`
	Type NodeType `` /* 136-byte string literal not displayed */
	// Size of the file, or cumulated size of folder
	Size int64 `protobuf:"varint,4,opt,name=Size,proto3" json:"Size,omitempty" gorm:"column:size;type:BIGINT NOT NULL;default:0;"`
	// Last modification Timestamp
	MTime int64 `protobuf:"varint,5,opt,name=MTime,proto3" json:"MTime,omitempty" gorm:"column:mtime;type:INT;"`
	// Permission mode, like 0777. Stored as string using custom ModeString field.
	Mode int32 `protobuf:"varint,6,opt,name=Mode,proto3" json:"Mode,omitempty" gorm:"-:all"`
	// String representation of Mode
	ModeString string `protobuf:"bytes,11,opt,name=ModeString,proto3" json:"ModeString,omitempty" gorm:"column:mode;type:VARCHAR(10);notNull;"`
	// Hash of the content if node is a LEAF, Uuid or
	Etag string `protobuf:"bytes,7,opt,name=Etag,proto3" json:"Etag,omitempty" gorm:"column:etag;type:VARCHAR(255);notNull;"`
	// List of successive commits
	//
	// Deprecated: Marked as deprecated in cells-tree.proto.
	Commits []*ChangeLog `protobuf:"bytes,9,rep,name=Commits,proto3" json:"Commits,omitempty" gorm:"-:all"`
	// ------------------------------------
	// Then a free K => V representation of any kind of metadata
	// ------------------------------------
	MetaStore map[string]string `` /* 172-byte string literal not displayed */
	// Can be used for output when node is appearing in multiple workspaces
	AppearsIn []*WorkspaceRelativePath `protobuf:"bytes,10,rep,name=AppearsIn,proto3" json:"AppearsIn,omitempty" gorm:"-:all"`
	// contains filtered or unexported fields
}

func (*Node) AllMetaDeserialized 

func (node *Node) AllMetaDeserialized(excludes map[string]struct{}) map[string]interface{}

AllMetaDeserialized unmarshall all defined metadata to JSON objects, skipping reserved meta (e.g. meta that have a key prefixed by "pydio:")

func (*Node) As 

func (node *Node) As(out any) bool

func (*Node) AsProto 

func (node *Node) AsProto() *Node

AsProto just implements the sync/model/N interface

func (*Node) Clone 

func (node *Node) Clone() *Node

Clone node to avoid modifying it directly

func (*Node) Descriptor deprecated 

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

Deprecated: Use Node.ProtoReflect.Descriptor instead.

func (*Node) GetAppearsIn 

func (x *Node) GetAppearsIn() []*WorkspaceRelativePath

func (*Node) GetChildrenFiles 

func (node *Node) GetChildrenFiles() (s uint64, o bool)

func (*Node) GetChildrenFolders 

func (node *Node) GetChildrenFolders() (s uint64, o bool)

func (*Node) GetChildrenSize 

func (node *Node) GetChildrenSize() (s uint64, o bool)

func (*Node) GetCommits deprecated 

func (x *Node) GetCommits() []*ChangeLog

Deprecated: Marked as deprecated in cells-tree.proto.

func (*Node) GetEtag 

func (x *Node) GetEtag() string

func (*Node) GetMTime 

func (x *Node) GetMTime() int64

func (*Node) GetMeta 

func (node *Node) GetMeta(namespace string, jsonStruc interface{}) error

GetMeta retrieves a metadata and unmarshall it to JSON format

func (*Node) GetMetaBool 

func (node *Node) GetMetaBool(namespace string) bool

GetMetaBool looks for a meta to be present and bool value. Returns false is meta is not set.

func (*Node) GetMetaStore 

func (x *Node) GetMetaStore() map[string]string

func (*Node) GetModTime 

func (node *Node) GetModTime() time.Time

GetModTime returns the last modification timestamp

func (*Node) GetMode 

func (x *Node) GetMode() int32

func (*Node) GetModeString 

func (x *Node) GetModeString() string

func (*Node) GetPath 

func (x *Node) GetPath() string

func (*Node) GetSize 

func (x *Node) GetSize() int64

func (*Node) GetStringMeta 

func (node *Node) GetStringMeta(namespace string) string

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) GetType 

func (x *Node) GetType() NodeType

func (*Node) GetUuid 

func (x *Node) GetUuid() string

func (*Node) HasMetaKey 

func (node *Node) HasMetaKey(keyName string) bool

HasMetaKey checks if a metaData with this key has been defined

func (*Node) HasSource 

func (node *Node) HasSource() bool

HasSource checks if node has a DataSource and Object Service metadata set

func (*Node) IsLeaf 

func (node *Node) IsLeaf() bool

IsLeaf checks if node is of type NodeType_LEAF or NodeType_COLLECTION

func (*Node) IsLeafInt 

func (node *Node) IsLeafInt() int

IsLeafInt checks if node is of type NodeType_LEAF or NodeType_COLLECTION, return as 0/1 integer (for storing)

func (*Node) LegacyMeta 

func (node *Node) LegacyMeta(meta map[string]interface{})

LegacyMeta enrich metadata store for this node adding info for some legacy keys

func (*Node) ListRawMetadata 

func (node *Node) ListRawMetadata() map[string]string

func (*Node) MarshalLogObject 

func (node *Node) MarshalLogObject(encoder zapcore.ObjectEncoder) error

MarshalLogObject implements custom marshalling for logs

func (*Node) MustSetMeta 

func (node *Node) MustSetMeta(namespace string, jsonMeta interface{})

MustSetMeta sets a metadata by marshalling to JSON. It does not return error but panics instead.

func (*Node) ProtoMessage 

func (*Node) ProtoMessage()

func (*Node) ProtoReflect 

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

func (*Node) RenewUuidIfEmpty 

func (node *Node) RenewUuidIfEmpty(force bool)

RenewUuidIfEmpty generates a new UUID if it is currently empty or force is set to true

func (*Node) Reset 

func (x *Node) Reset()

func (*Node) SetAppearsIn 

func (x *Node) SetAppearsIn(v []*WorkspaceRelativePath)

func (*Node) SetChildrenFiles 

func (node *Node) SetChildrenFiles(s uint64)

func (*Node) SetChildrenFolders 

func (node *Node) SetChildrenFolders(s uint64)

func (*Node) SetChildrenSize 

func (node *Node) SetChildrenSize(s uint64)

func (*Node) SetCommits 

func (x *Node) SetCommits(v []*ChangeLog)

func (*Node) SetEtag 

func (x *Node) SetEtag(v string)

func (*Node) SetMTime 

func (x *Node) SetMTime(v int64)

func (*Node) SetMetaStore 

func (x *Node) SetMetaStore(v map[string]string)

func (*Node) SetMode 

func (x *Node) SetMode(v int32)

func (*Node) SetModeString 

func (x *Node) SetModeString(v string)

func (*Node) SetPath 

func (x *Node) SetPath(v string)

func (*Node) SetRawMetadata 

func (node *Node) SetRawMetadata(mm map[string]string)

SetRawMetadata append key/value directly to metastore (no json encoding)

func (*Node) SetSize 

func (x *Node) SetSize(v int64)

func (*Node) SetType 

func (x *Node) SetType(v NodeType)

func (*Node) SetUuid 

func (x *Node) SetUuid(v string)

func (*Node) String 

func (x *Node) String() string

func (*Node) WithoutReservedMetas 

func (node *Node) WithoutReservedMetas() *Node

WithoutReservedMetas returns a copy of this node, after removing all reserved meta

func (*Node) Zap 

func (node *Node) Zap(key ...string) zapcore.Field

Zap simply returns a zapcore.Field object populated with this node and with a standard key

func (*Node) ZapPath 

func (node *Node) ZapPath() zapcore.Field

ZapPath simply calls zap.String() with NodePath standard key and this node path

func (*Node) ZapSize 

func (node *Node) ZapSize() zapcore.Field

ZapSize calls zap.Int64 with node sizes

func (*Node) ZapUuid 

func (node *Node) ZapUuid() zapcore.Field

ZapUuid simply calls zap.String() with NodeUuid standard key and this node uuid

func (*Node) Zaps 

func (node *Node) Zaps(key ...string) []zapcore.Field

type NodeChangeEvent 

type NodeChangeEvent struct {
	Type       NodeChangeEvent_EventType `protobuf:"varint,1,opt,name=Type,proto3,enum=tree.NodeChangeEvent_EventType" json:"Type,omitempty"`
	Source     *Node                     `protobuf:"bytes,2,opt,name=Source,proto3" json:"Source,omitempty"`
	Target     *Node                     `protobuf:"bytes,3,opt,name=Target,proto3" json:"Target,omitempty"`
	Metadata   map[string]string         `` /* 157-byte string literal not displayed */
	Silent     bool                      `protobuf:"varint,4,opt,name=Silent,proto3" json:"Silent,omitempty"`
	Optimistic bool                      `protobuf:"varint,5,opt,name=Optimistic,proto3" json:"Optimistic,omitempty"`
	// contains filtered or unexported fields
}

func (*NodeChangeEvent) Descriptor deprecated 

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

Deprecated: Use NodeChangeEvent.ProtoReflect.Descriptor instead.

func (*NodeChangeEvent) GetMetadata 

func (x *NodeChangeEvent) GetMetadata() map[string]string

func (*NodeChangeEvent) GetOptimistic 

func (x *NodeChangeEvent) GetOptimistic() bool

func (*NodeChangeEvent) GetSilent 

func (x *NodeChangeEvent) GetSilent() bool

func (*NodeChangeEvent) GetSource 

func (x *NodeChangeEvent) GetSource() *Node

func (*NodeChangeEvent) GetTarget 

func (x *NodeChangeEvent) GetTarget() *Node

func (*NodeChangeEvent) GetType 

func (x *NodeChangeEvent) GetType() NodeChangeEvent_EventType

func (*NodeChangeEvent) ProtoMessage 

func (*NodeChangeEvent) ProtoMessage()

func (*NodeChangeEvent) ProtoReflect 

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

func (*NodeChangeEvent) Reset 

func (x *NodeChangeEvent) Reset()

func (*NodeChangeEvent) String 

func (x *NodeChangeEvent) String() string

func (*NodeChangeEvent) Zap 

func (msg *NodeChangeEvent) Zap() zapcore.Field

Zap simply returns a zapcore.Field object populated with this NodeChangeEvent under a standard key

type NodeChangeEvent_EventType 

type NodeChangeEvent_EventType int32
const (
	NodeChangeEvent_CREATE           NodeChangeEvent_EventType = 0
	NodeChangeEvent_READ             NodeChangeEvent_EventType = 1
	NodeChangeEvent_UPDATE_PATH      NodeChangeEvent_EventType = 2
	NodeChangeEvent_UPDATE_CONTENT   NodeChangeEvent_EventType = 3
	NodeChangeEvent_UPDATE_META      NodeChangeEvent_EventType = 4
	NodeChangeEvent_UPDATE_USER_META NodeChangeEvent_EventType = 6
	NodeChangeEvent_DELETE           NodeChangeEvent_EventType = 5
)

func (NodeChangeEvent_EventType) Descriptor 

func (NodeChangeEvent_EventType) Descriptor() protoreflect.EnumDescriptor

func (NodeChangeEvent_EventType) Enum 

func (x NodeChangeEvent_EventType) Enum() *NodeChangeEvent_EventType

func (NodeChangeEvent_EventType) EnumDescriptor deprecated 

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

Deprecated: Use NodeChangeEvent_EventType.Descriptor instead.

func (NodeChangeEvent_EventType) Number 

func (x NodeChangeEvent_EventType) Number() protoreflect.EnumNumber

func (NodeChangeEvent_EventType) String 

func (x NodeChangeEvent_EventType) String() string

func (NodeChangeEvent_EventType) Type 

func (NodeChangeEvent_EventType) Type() protoreflect.EnumType

type NodeChangesReceiverStreamerClient 

type NodeChangesReceiverStreamerClient interface {
	PostNodeChanges(ctx context.Context, opts ...grpc.CallOption) (NodeChangesReceiverStreamer_PostNodeChangesClient, error)
}

NodeChangesReceiverStreamerClient is the client API for NodeChangesReceiverStreamer service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewNodeChangesReceiverStreamerClient 

func NewNodeChangesReceiverStreamerClient(cc grpc.ClientConnInterface) NodeChangesReceiverStreamerClient

type NodeChangesReceiverStreamerServer 

type NodeChangesReceiverStreamerServer interface {
	PostNodeChanges(NodeChangesReceiverStreamer_PostNodeChangesServer) error
	// contains filtered or unexported methods
}

NodeChangesReceiverStreamerServer is the server API for NodeChangesReceiverStreamer service. All implementations must embed UnimplementedNodeChangesReceiverStreamerServer for forward compatibility

type NodeChangesReceiverStreamerStub 

type NodeChangesReceiverStreamerStub struct {
	NodeChangesReceiverStreamerServer
}

func (*NodeChangesReceiverStreamerStub) Invoke 

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

func (*NodeChangesReceiverStreamerStub) NewStream 

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

type NodeChangesReceiverStreamerStub_PostNodeChangesStreamer 

type NodeChangesReceiverStreamerStub_PostNodeChangesStreamer struct {
	stubs.BidirServerStreamerCore
}

func (*NodeChangesReceiverStreamerStub_PostNodeChangesStreamer) Recv 

func (s *NodeChangesReceiverStreamerStub_PostNodeChangesStreamer) Recv() (*NodeChangeEvent, error)

func (*NodeChangesReceiverStreamerStub_PostNodeChangesStreamer) Send 

func (s *NodeChangesReceiverStreamerStub_PostNodeChangesStreamer) Send(response *NodeChangeEvent) error

type NodeChangesReceiverStreamer_PostNodeChangesClient 

type NodeChangesReceiverStreamer_PostNodeChangesClient interface {
	Send(*NodeChangeEvent) error
	Recv() (*NodeChangeEvent, error)
	grpc.ClientStream
}

type NodeChangesReceiverStreamer_PostNodeChangesServer 

type NodeChangesReceiverStreamer_PostNodeChangesServer interface {
	Send(*NodeChangeEvent) error
	Recv() (*NodeChangeEvent, error)
	grpc.ServerStream
}

type NodeChangesStreamerClient 

type NodeChangesStreamerClient interface {
	StreamChanges(ctx context.Context, in *StreamChangesRequest, opts ...grpc.CallOption) (NodeChangesStreamer_StreamChangesClient, error)
}

NodeChangesStreamerClient is the client API for NodeChangesStreamer service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewNodeChangesStreamerClient 

func NewNodeChangesStreamerClient(cc grpc.ClientConnInterface) NodeChangesStreamerClient

type NodeChangesStreamerServer 

type NodeChangesStreamerServer interface {
	StreamChanges(*StreamChangesRequest, NodeChangesStreamer_StreamChangesServer) error
	// contains filtered or unexported methods
}

NodeChangesStreamerServer is the server API for NodeChangesStreamer service. All implementations must embed UnimplementedNodeChangesStreamerServer for forward compatibility

type NodeChangesStreamerStub 

type NodeChangesStreamerStub struct {
	NodeChangesStreamerServer
}

func (*NodeChangesStreamerStub) Invoke 

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

func (*NodeChangesStreamerStub) NewStream 

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

type NodeChangesStreamerStub_StreamChangesStreamer 

type NodeChangesStreamerStub_StreamChangesStreamer struct {
	stubs.ClientServerStreamerCore
}

func (*NodeChangesStreamerStub_StreamChangesStreamer) Send 

func (s *NodeChangesStreamerStub_StreamChangesStreamer) Send(response *NodeChangeEvent) error

type NodeChangesStreamer_StreamChangesClient 

type NodeChangesStreamer_StreamChangesClient interface {
	Recv() (*NodeChangeEvent, error)
	grpc.ClientStream
}

type NodeChangesStreamer_StreamChangesServer 

type NodeChangesStreamer_StreamChangesServer interface {
	Send(*NodeChangeEvent) error
	grpc.ServerStream
}

type NodeContentReaderClient 

type NodeContentReaderClient interface {
}

NodeContentReaderClient is the client API for NodeContentReader service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewNodeContentReaderClient 

func NewNodeContentReaderClient(cc grpc.ClientConnInterface) NodeContentReaderClient

type NodeContentReaderServer 

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

NodeContentReaderServer is the server API for NodeContentReader service. All implementations must embed UnimplementedNodeContentReaderServer for forward compatibility

type NodeContentReaderStub 

type NodeContentReaderStub struct {
	NodeContentReaderServer
}

func (*NodeContentReaderStub) Invoke 

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

func (*NodeContentReaderStub) NewStream 

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

type NodeContentWriterClient 

type NodeContentWriterClient interface {
}

NodeContentWriterClient is the client API for NodeContentWriter service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewNodeContentWriterClient 

func NewNodeContentWriterClient(cc grpc.ClientConnInterface) NodeContentWriterClient

type NodeContentWriterServer 

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

NodeContentWriterServer is the server API for NodeContentWriter service. All implementations must embed UnimplementedNodeContentWriterServer for forward compatibility

type NodeContentWriterStub 

type NodeContentWriterStub struct {
	NodeContentWriterServer
}

func (*NodeContentWriterStub) Invoke 

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

func (*NodeContentWriterStub) NewStream 

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

type NodeEventsProviderClient 

type NodeEventsProviderClient interface {
	WatchNode(ctx context.Context, in *WatchNodeRequest, opts ...grpc.CallOption) (NodeEventsProvider_WatchNodeClient, error)
}

NodeEventsProviderClient is the client API for NodeEventsProvider service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewNodeEventsProviderClient 

func NewNodeEventsProviderClient(cc grpc.ClientConnInterface) NodeEventsProviderClient

type NodeEventsProviderServer 

type NodeEventsProviderServer interface {
	WatchNode(*WatchNodeRequest, NodeEventsProvider_WatchNodeServer) error
	// contains filtered or unexported methods
}

NodeEventsProviderServer is the server API for NodeEventsProvider service. All implementations must embed UnimplementedNodeEventsProviderServer for forward compatibility

type NodeEventsProviderStub 

type NodeEventsProviderStub struct {
	NodeEventsProviderServer
}

func (*NodeEventsProviderStub) Invoke 

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

func (*NodeEventsProviderStub) NewStream 

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

type NodeEventsProviderStub_WatchNodeStreamer 

type NodeEventsProviderStub_WatchNodeStreamer struct {
	stubs.ClientServerStreamerCore
}

func (*NodeEventsProviderStub_WatchNodeStreamer) Send 

func (s *NodeEventsProviderStub_WatchNodeStreamer) Send(response *WatchNodeResponse) error

type NodeEventsProvider_WatchNodeClient 

type NodeEventsProvider_WatchNodeClient interface {
	Recv() (*WatchNodeResponse, error)
	grpc.ClientStream
}

type NodeEventsProvider_WatchNodeServer 

type NodeEventsProvider_WatchNodeServer interface {
	Send(*WatchNodeResponse) error
	grpc.ServerStream
}

type NodeGetter 

type NodeGetter interface {
	GetUuid() string
	GetPath() string
	GetType() NodeType
	GetSize() int64
	GetMTime() int64
	GetMode() int32
	GetModeString() string
	GetEtag() string
	GetCommits() []*ChangeLog
	GetMetaStore() map[string]string
	GetAppearsIn() []*WorkspaceRelativePath
}

type NodeProviderClient 

type NodeProviderClient interface {
	ReadNode(ctx context.Context, in *ReadNodeRequest, opts ...grpc.CallOption) (*ReadNodeResponse, error)
	ListNodes(ctx context.Context, in *ListNodesRequest, opts ...grpc.CallOption) (NodeProvider_ListNodesClient, error)
}

NodeProviderClient is the client API for NodeProvider service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewNodeProviderClient 

func NewNodeProviderClient(cc grpc.ClientConnInterface) NodeProviderClient

type NodeProviderMock 

type NodeProviderMock struct {
	Nodes map[string]Node
}

func NewNodeProviderMock 

func NewNodeProviderMock(n map[string]Node) *NodeProviderMock

func (*NodeProviderMock) ListNodes 

func (m *NodeProviderMock) ListNodes(ctx context.Context, in *ListNodesRequest, opts ...grpc.CallOption) (NodeProvider_ListNodesClient, error)

func (*NodeProviderMock) ReadNode 

func (m *NodeProviderMock) ReadNode(ctx context.Context, in *ReadNodeRequest, opts ...grpc.CallOption) (*ReadNodeResponse, error)

type NodeProviderServer 

type NodeProviderServer interface {
	ReadNode(context.Context, *ReadNodeRequest) (*ReadNodeResponse, error)
	ListNodes(*ListNodesRequest, NodeProvider_ListNodesServer) error
	// contains filtered or unexported methods
}

NodeProviderServer is the server API for NodeProvider service. All implementations must embed UnimplementedNodeProviderServer for forward compatibility

type NodeProviderStreamerClient 

type NodeProviderStreamerClient interface {
	ReadNodeStream(ctx context.Context, opts ...grpc.CallOption) (NodeProviderStreamer_ReadNodeStreamClient, error)
}

NodeProviderStreamerClient is the client API for NodeProviderStreamer service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewNodeProviderStreamerClient 

func NewNodeProviderStreamerClient(cc grpc.ClientConnInterface) NodeProviderStreamerClient

type NodeProviderStreamerServer 

type NodeProviderStreamerServer interface {
	ReadNodeStream(NodeProviderStreamer_ReadNodeStreamServer) error
	// contains filtered or unexported methods
}

NodeProviderStreamerServer is the server API for NodeProviderStreamer service. All implementations must embed UnimplementedNodeProviderStreamerServer for forward compatibility

type NodeProviderStreamerStub 

type NodeProviderStreamerStub struct {
	NodeProviderStreamerServer
}

func (*NodeProviderStreamerStub) Invoke 

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

func (*NodeProviderStreamerStub) NewStream 

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

type NodeProviderStreamerStub_ReadNodeStreamStreamer 

type NodeProviderStreamerStub_ReadNodeStreamStreamer struct {
	stubs.BidirServerStreamerCore
}

func (*NodeProviderStreamerStub_ReadNodeStreamStreamer) Recv 

func (s *NodeProviderStreamerStub_ReadNodeStreamStreamer) Recv() (*ReadNodeRequest, error)

func (*NodeProviderStreamerStub_ReadNodeStreamStreamer) Send 

func (s *NodeProviderStreamerStub_ReadNodeStreamStreamer) Send(response *ReadNodeResponse) error

type NodeProviderStreamer_ReadNodeStreamClient 

type NodeProviderStreamer_ReadNodeStreamClient interface {
	Send(*ReadNodeRequest) error
	Recv() (*ReadNodeResponse, error)
	grpc.ClientStream
}

type NodeProviderStreamer_ReadNodeStreamServer 

type NodeProviderStreamer_ReadNodeStreamServer interface {
	Send(*ReadNodeResponse) error
	Recv() (*ReadNodeRequest, error)
	grpc.ServerStream
}

type NodeProviderStub 

type NodeProviderStub struct {
	NodeProviderServer
}

func (*NodeProviderStub) Invoke 

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

func (*NodeProviderStub) NewStream 

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

type NodeProviderStub_ListNodesStreamer 

type NodeProviderStub_ListNodesStreamer struct {
	stubs.ClientServerStreamerCore
}

func (*NodeProviderStub_ListNodesStreamer) Send 

func (s *NodeProviderStub_ListNodesStreamer) Send(response *ListNodesResponse) error

type NodeProvider_ListNodesClient 

type NodeProvider_ListNodesClient interface {
	Recv() (*ListNodesResponse, error)
	grpc.ClientStream
}

type NodeProvider_ListNodesServer 

type NodeProvider_ListNodesServer interface {
	Send(*ListNodesResponse) error
	grpc.ServerStream
}

type NodeReceiverClient 

type NodeReceiverClient interface {
	CreateNode(ctx context.Context, in *CreateNodeRequest, opts ...grpc.CallOption) (*CreateNodeResponse, error)
	UpdateNode(ctx context.Context, in *UpdateNodeRequest, opts ...grpc.CallOption) (*UpdateNodeResponse, error)
	DeleteNode(ctx context.Context, in *DeleteNodeRequest, opts ...grpc.CallOption) (*DeleteNodeResponse, error)
}

NodeReceiverClient is the client API for NodeReceiver service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewNodeReceiverClient 

func NewNodeReceiverClient(cc grpc.ClientConnInterface) NodeReceiverClient

type NodeReceiverMock 

type NodeReceiverMock struct {
	Nodes map[string]Node
}

func (*NodeReceiverMock) CreateNode 

func (m *NodeReceiverMock) CreateNode(ctx context.Context, in *CreateNodeRequest, opts ...grpc.CallOption) (*CreateNodeResponse, error)

func (*NodeReceiverMock) DeleteNode 

func (m *NodeReceiverMock) DeleteNode(ctx context.Context, in *DeleteNodeRequest, opts ...grpc.CallOption) (*DeleteNodeResponse, error)

func (*NodeReceiverMock) UpdateNode 

func (m *NodeReceiverMock) UpdateNode(ctx context.Context, in *UpdateNodeRequest, opts ...grpc.CallOption) (*UpdateNodeResponse, error)

type NodeReceiverServer 

type NodeReceiverServer interface {
	CreateNode(context.Context, *CreateNodeRequest) (*CreateNodeResponse, error)
	UpdateNode(context.Context, *UpdateNodeRequest) (*UpdateNodeResponse, error)
	DeleteNode(context.Context, *DeleteNodeRequest) (*DeleteNodeResponse, error)
	// contains filtered or unexported methods
}

NodeReceiverServer is the server API for NodeReceiver service. All implementations must embed UnimplementedNodeReceiverServer for forward compatibility

type NodeReceiverStreamClient 

type NodeReceiverStreamClient interface {
	CreateNodeStream(ctx context.Context, opts ...grpc.CallOption) (NodeReceiverStream_CreateNodeStreamClient, error)
	UpdateNodeStream(ctx context.Context, opts ...grpc.CallOption) (NodeReceiverStream_UpdateNodeStreamClient, error)
	DeleteNodeStream(ctx context.Context, opts ...grpc.CallOption) (NodeReceiverStream_DeleteNodeStreamClient, error)
}

NodeReceiverStreamClient is the client API for NodeReceiverStream service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewNodeReceiverStreamClient 

func NewNodeReceiverStreamClient(cc grpc.ClientConnInterface) NodeReceiverStreamClient

type NodeReceiverStreamServer 

type NodeReceiverStreamServer interface {
	CreateNodeStream(NodeReceiverStream_CreateNodeStreamServer) error
	UpdateNodeStream(NodeReceiverStream_UpdateNodeStreamServer) error
	DeleteNodeStream(NodeReceiverStream_DeleteNodeStreamServer) error
	// contains filtered or unexported methods
}

NodeReceiverStreamServer is the server API for NodeReceiverStream service. All implementations must embed UnimplementedNodeReceiverStreamServer for forward compatibility

type NodeReceiverStreamStub 

type NodeReceiverStreamStub struct {
	NodeReceiverStreamServer
}

func (*NodeReceiverStreamStub) Invoke 

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

func (*NodeReceiverStreamStub) NewStream 

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

type NodeReceiverStreamStub_CreateNodeStreamStreamer 

type NodeReceiverStreamStub_CreateNodeStreamStreamer struct {
	stubs.BidirServerStreamerCore
}

func (*NodeReceiverStreamStub_CreateNodeStreamStreamer) Recv 

func (s *NodeReceiverStreamStub_CreateNodeStreamStreamer) Recv() (*CreateNodeRequest, error)

func (*NodeReceiverStreamStub_CreateNodeStreamStreamer) Send 

func (s *NodeReceiverStreamStub_CreateNodeStreamStreamer) Send(response *CreateNodeResponse) error

type NodeReceiverStreamStub_DeleteNodeStreamStreamer 

type NodeReceiverStreamStub_DeleteNodeStreamStreamer struct {
	stubs.BidirServerStreamerCore
}

func (*NodeReceiverStreamStub_DeleteNodeStreamStreamer) Recv 

func (s *NodeReceiverStreamStub_DeleteNodeStreamStreamer) Recv() (*DeleteNodeRequest, error)

func (*NodeReceiverStreamStub_DeleteNodeStreamStreamer) Send 

func (s *NodeReceiverStreamStub_DeleteNodeStreamStreamer) Send(response *DeleteNodeResponse) error

type NodeReceiverStreamStub_UpdateNodeStreamStreamer 

type NodeReceiverStreamStub_UpdateNodeStreamStreamer struct {
	stubs.BidirServerStreamerCore
}

func (*NodeReceiverStreamStub_UpdateNodeStreamStreamer) Recv 

func (s *NodeReceiverStreamStub_UpdateNodeStreamStreamer) Recv() (*UpdateNodeRequest, error)

func (*NodeReceiverStreamStub_UpdateNodeStreamStreamer) Send 

func (s *NodeReceiverStreamStub_UpdateNodeStreamStreamer) Send(response *UpdateNodeResponse) error

type NodeReceiverStream_CreateNodeStreamClient 

type NodeReceiverStream_CreateNodeStreamClient interface {
	Send(*CreateNodeRequest) error
	Recv() (*CreateNodeResponse, error)
	grpc.ClientStream
}

type NodeReceiverStream_CreateNodeStreamServer 

type NodeReceiverStream_CreateNodeStreamServer interface {
	Send(*CreateNodeResponse) error
	Recv() (*CreateNodeRequest, error)
	grpc.ServerStream
}

type NodeReceiverStream_DeleteNodeStreamClient 

type NodeReceiverStream_DeleteNodeStreamClient interface {
	Send(*DeleteNodeRequest) error
	Recv() (*DeleteNodeResponse, error)
	grpc.ClientStream
}

type NodeReceiverStream_DeleteNodeStreamServer 

type NodeReceiverStream_DeleteNodeStreamServer interface {
	Send(*DeleteNodeResponse) error
	Recv() (*DeleteNodeRequest, error)
	grpc.ServerStream
}

type NodeReceiverStream_UpdateNodeStreamClient 

type NodeReceiverStream_UpdateNodeStreamClient interface {
	Send(*UpdateNodeRequest) error
	Recv() (*UpdateNodeResponse, error)
	grpc.ClientStream
}

type NodeReceiverStream_UpdateNodeStreamServer 

type NodeReceiverStream_UpdateNodeStreamServer interface {
	Send(*UpdateNodeResponse) error
	Recv() (*UpdateNodeRequest, error)
	grpc.ServerStream
}

type NodeReceiverStub 

type NodeReceiverStub struct {
	NodeReceiverServer
}

func (*NodeReceiverStub) Invoke 

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

func (*NodeReceiverStub) NewStream 

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

type NodeSetter 

type NodeSetter interface {
	SetUuid(string)
	SetPath(string)
	SetType(NodeType)
	SetSize(int64)
	SetMTime(int64)
	SetMode(int32)
	SetModeString(string)
	SetEtag(string)
	SetCommits([]*ChangeLog)
	SetMetaStore(map[string]string)
	SetAppearsIn([]*WorkspaceRelativePath)
}

type NodeType 

type NodeType int32

========================================================== * Standard Messages ========================================================== 

const (
	NodeType_UNKNOWN    NodeType = 0
	NodeType_LEAF       NodeType = 1
	NodeType_COLLECTION NodeType = 2
)

func (NodeType) Descriptor 

func (NodeType) Descriptor() protoreflect.EnumDescriptor

func (NodeType) Enum 

func (x NodeType) Enum() *NodeType

func (NodeType) EnumDescriptor deprecated 

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

Deprecated: Use NodeType.Descriptor instead.

func (*NodeType) GormDBDataType 

func (n *NodeType) GormDBDataType(db *gorm.DB, _ *schema.Field) string

Resetting node type for postgresql

func (NodeType) Number 

func (x NodeType) Number() protoreflect.EnumNumber

func (NodeType) String 

func (x NodeType) String() string

func (NodeType) Type 

func (NodeType) Type() protoreflect.EnumType

type NodeVersionerClient 

type NodeVersionerClient interface {
	CreateVersion(ctx context.Context, in *CreateVersionRequest, opts ...grpc.CallOption) (*CreateVersionResponse, error)
	StoreVersion(ctx context.Context, in *StoreVersionRequest, opts ...grpc.CallOption) (*StoreVersionResponse, error)
	ListVersions(ctx context.Context, in *ListVersionsRequest, opts ...grpc.CallOption) (NodeVersioner_ListVersionsClient, error)
	HeadVersion(ctx context.Context, in *HeadVersionRequest, opts ...grpc.CallOption) (*HeadVersionResponse, error)
	PruneVersions(ctx context.Context, in *PruneVersionsRequest, opts ...grpc.CallOption) (*PruneVersionsResponse, error)
	ListVersioningPolicies(ctx context.Context, in *ListVersioningPoliciesRequest, opts ...grpc.CallOption) (NodeVersioner_ListVersioningPoliciesClient, error)
}

NodeVersionerClient is the client API for NodeVersioner service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewNodeVersionerClient 

func NewNodeVersionerClient(cc grpc.ClientConnInterface) NodeVersionerClient

type NodeVersionerServer 

type NodeVersionerServer interface {
	CreateVersion(context.Context, *CreateVersionRequest) (*CreateVersionResponse, error)
	StoreVersion(context.Context, *StoreVersionRequest) (*StoreVersionResponse, error)
	ListVersions(*ListVersionsRequest, NodeVersioner_ListVersionsServer) error
	HeadVersion(context.Context, *HeadVersionRequest) (*HeadVersionResponse, error)
	PruneVersions(context.Context, *PruneVersionsRequest) (*PruneVersionsResponse, error)
	ListVersioningPolicies(*ListVersioningPoliciesRequest, NodeVersioner_ListVersioningPoliciesServer) error
	// contains filtered or unexported methods
}

NodeVersionerServer is the server API for NodeVersioner service. All implementations must embed UnimplementedNodeVersionerServer for forward compatibility

type NodeVersionerStub 

type NodeVersionerStub struct {
	NodeVersionerServer
}

func (*NodeVersionerStub) Invoke 

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

func (*NodeVersionerStub) NewStream 

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

type NodeVersionerStub_ListVersioningPoliciesStreamer 

type NodeVersionerStub_ListVersioningPoliciesStreamer struct {
	stubs.ClientServerStreamerCore
}

func (*NodeVersionerStub_ListVersioningPoliciesStreamer) Send 

func (s *NodeVersionerStub_ListVersioningPoliciesStreamer) Send(response *VersioningPolicy) error

type NodeVersionerStub_ListVersionsStreamer 

type NodeVersionerStub_ListVersionsStreamer struct {
	stubs.ClientServerStreamerCore
}

func (*NodeVersionerStub_ListVersionsStreamer) Send 

func (s *NodeVersionerStub_ListVersionsStreamer) Send(response *ListVersionsResponse) error

type NodeVersioner_ListVersioningPoliciesClient 

type NodeVersioner_ListVersioningPoliciesClient interface {
	Recv() (*VersioningPolicy, error)
	grpc.ClientStream
}

type NodeVersioner_ListVersioningPoliciesServer 

type NodeVersioner_ListVersioningPoliciesServer interface {
	Send(*VersioningPolicy) error
	grpc.ServerStream
}

type NodeVersioner_ListVersionsClient 

type NodeVersioner_ListVersionsClient interface {
	Recv() (*ListVersionsResponse, error)
	grpc.ClientStream
}

type NodeVersioner_ListVersionsServer 

type NodeVersioner_ListVersionsServer interface {
	Send(*ListVersionsResponse) error
	grpc.ServerStream
}

type OpenSessionRequest 

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

func (*OpenSessionRequest) Descriptor deprecated 

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

Deprecated: Use OpenSessionRequest.ProtoReflect.Descriptor instead.

func (*OpenSessionRequest) GetSession 

func (x *OpenSessionRequest) GetSession() *IndexationSession

func (*OpenSessionRequest) ProtoMessage 

func (*OpenSessionRequest) ProtoMessage()

func (*OpenSessionRequest) ProtoReflect 

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

func (*OpenSessionRequest) Reset 

func (x *OpenSessionRequest) Reset()

func (*OpenSessionRequest) String 

func (x *OpenSessionRequest) String() string

type OpenSessionResponse 

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

func (*OpenSessionResponse) Descriptor deprecated 

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

Deprecated: Use OpenSessionResponse.ProtoReflect.Descriptor instead.

func (*OpenSessionResponse) GetSession 

func (x *OpenSessionResponse) GetSession() *IndexationSession

func (*OpenSessionResponse) ProtoMessage 

func (*OpenSessionResponse) ProtoMessage()

func (*OpenSessionResponse) ProtoReflect 

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

func (*OpenSessionResponse) Reset 

func (x *OpenSessionResponse) Reset()

func (*OpenSessionResponse) String 

func (x *OpenSessionResponse) String() string

type PruneVersionsRequest 

type PruneVersionsRequest struct {
	UniqueNode      *Node `protobuf:"bytes,1,opt,name=UniqueNode,proto3" json:"UniqueNode,omitempty"`
	AllDeletedNodes bool  `protobuf:"varint,2,opt,name=AllDeletedNodes,proto3" json:"AllDeletedNodes,omitempty"`
	// contains filtered or unexported fields
}

func (*PruneVersionsRequest) Descriptor deprecated 

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

Deprecated: Use PruneVersionsRequest.ProtoReflect.Descriptor instead.

func (*PruneVersionsRequest) GetAllDeletedNodes 

func (x *PruneVersionsRequest) GetAllDeletedNodes() bool

func (*PruneVersionsRequest) GetUniqueNode 

func (x *PruneVersionsRequest) GetUniqueNode() *Node

func (*PruneVersionsRequest) ProtoMessage 

func (*PruneVersionsRequest) ProtoMessage()

func (*PruneVersionsRequest) ProtoReflect 

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

func (*PruneVersionsRequest) Reset 

func (x *PruneVersionsRequest) Reset()

func (*PruneVersionsRequest) String 

func (x *PruneVersionsRequest) String() string

type PruneVersionsResponse 

type PruneVersionsResponse struct {
	DeletedVersions []*ChangeLog `protobuf:"bytes,1,rep,name=DeletedVersions,proto3" json:"DeletedVersions,omitempty"`
	// contains filtered or unexported fields
}

func (*PruneVersionsResponse) Descriptor deprecated 

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

Deprecated: Use PruneVersionsResponse.ProtoReflect.Descriptor instead.

func (*PruneVersionsResponse) GetDeletedVersions 

func (x *PruneVersionsResponse) GetDeletedVersions() []*ChangeLog

func (*PruneVersionsResponse) ProtoMessage 

func (*PruneVersionsResponse) ProtoMessage()

func (*PruneVersionsResponse) ProtoReflect 

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

func (*PruneVersionsResponse) Reset 

func (x *PruneVersionsResponse) Reset()

func (*PruneVersionsResponse) String 

func (x *PruneVersionsResponse) String() string

type PutSyncChangeResponse 

type PutSyncChangeResponse struct {
	Success bool   `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Msg     string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
	// contains filtered or unexported fields
}

func (*PutSyncChangeResponse) Descriptor deprecated 

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

Deprecated: Use PutSyncChangeResponse.ProtoReflect.Descriptor instead.

func (*PutSyncChangeResponse) GetMsg 

func (x *PutSyncChangeResponse) GetMsg() string

func (*PutSyncChangeResponse) GetSuccess 

func (x *PutSyncChangeResponse) GetSuccess() bool

func (*PutSyncChangeResponse) ProtoMessage 

func (*PutSyncChangeResponse) ProtoMessage()

func (*PutSyncChangeResponse) ProtoReflect 

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

func (*PutSyncChangeResponse) Reset 

func (x *PutSyncChangeResponse) Reset()

func (*PutSyncChangeResponse) String 

func (x *PutSyncChangeResponse) String() string

type Query 

type Query struct {

	// List of nodes paths, exactly matching
	Paths []string `protobuf:"bytes,13,rep,name=Paths,proto3" json:"Paths,omitempty"`
	// Recursive listing of nodes below a given path. Combine with the PathDepth parameter to limit request results
	PathPrefix []string `protobuf:"bytes,1,rep,name=PathPrefix,proto3" json:"PathPrefix,omitempty"`
	// Range for file size - size bigger than
	MinSize int64 `protobuf:"varint,2,opt,name=MinSize,proto3" json:"MinSize,omitempty"`
	// Range for file size - size is smaller than
	MaxSize int64 `protobuf:"varint,3,opt,name=MaxSize,proto3" json:"MaxSize,omitempty"`
	// Range for modification date - node was modified after this date
	MinDate int64 `protobuf:"varint,4,opt,name=MinDate,proto3" json:"MinDate,omitempty"`
	// Range for modification date - node was modified before this date
	MaxDate int64 `protobuf:"varint,5,opt,name=MaxDate,proto3" json:"MaxDate,omitempty"`
	// Compute MinDate/MaxDate with a Golang duration with a leading comparator (> or <)
	// Duration may contain "s" second, "m" minute, "d" day.
	// Example: ">10m" for files modified before 10minutes ago
	DurationDate string `protobuf:"bytes,16,opt,name=DurationDate,proto3" json:"DurationDate,omitempty"`
	// Limit to a given node type (file or folder)
	Type NodeType `protobuf:"varint,6,opt,name=Type,proto3,enum=tree.NodeType" json:"Type,omitempty"`
	// Lookup by file basename
	FileName string `protobuf:"bytes,7,opt,name=FileName,proto3" json:"FileName,omitempty"`
	// Search in textual content (if search engine has this feature enabled)
	Content string `protobuf:"bytes,8,opt,name=Content,proto3" json:"Content,omitempty"`
	// Search in either filename or content (if search engine has this feature enabled)
	FileNameOrContent string `protobuf:"bytes,17,opt,name=FileNameOrContent,proto3" json:"FileNameOrContent,omitempty"`
	// Bleve-like search query to search for a specific metadata value.
	// When querying nodes, this will redirect this query to the Search Engine. When filtering an input, this will load an in-memory bleve engine to evaluate the node.
	//
	// Bleve query string format is a space separated list of `[+-]key:value`, where node meta keys must be prepended with "Meta."
	// For Example, for tags: `+Meta.usermeta-tags:myvalue`
	FreeString string `protobuf:"bytes,9,opt,name=FreeString,proto3" json:"FreeString,omitempty"`
	// Look for a specific ETag value, may only be useful to lookup for files with __temporary__ ETag
	ETag string `protobuf:"bytes,18,opt,name=ETag,proto3" json:"ETag,omitempty"`
	// Search files by their extension, use pipe symbol | if you wish to allow many extensions.
	// Example png|pdf|jpg
	Extension string `protobuf:"bytes,10,opt,name=Extension,proto3" json:"Extension,omitempty"`
	// Search geographically
	GeoQuery *GeoQuery `protobuf:"bytes,11,opt,name=GeoQuery,proto3" json:"GeoQuery,omitempty"`
	// Restrict recursive listing to a given level of the tree starting from root.
	// Special value "-1" should list only one level in the folder defined by PathPrefix
	PathDepth int32 `protobuf:"varint,12,opt,name=PathDepth,proto3" json:"PathDepth,omitempty"`
	// Preset list of specific node defined by their UUIDs
	UUIDs []string `protobuf:"bytes,15,rep,name=UUIDs,proto3" json:"UUIDs,omitempty"`
	// Negate this query
	Not bool `protobuf:"varint,14,opt,name=Not,proto3" json:"Not,omitempty"`
	// contains filtered or unexported fields
}

Search Queries

func (*Query) Descriptor deprecated 

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

Deprecated: Use Query.ProtoReflect.Descriptor instead.

func (*Query) GetContent 

func (x *Query) GetContent() string

func (*Query) GetDurationDate 

func (x *Query) GetDurationDate() string

func (*Query) GetETag 

func (x *Query) GetETag() string

func (*Query) GetExtension 

func (x *Query) GetExtension() string

func (*Query) GetFileName 

func (x *Query) GetFileName() string

func (*Query) GetFileNameOrContent 

func (x *Query) GetFileNameOrContent() string

func (*Query) GetFreeString 

func (x *Query) GetFreeString() string

func (*Query) GetGeoQuery 

func (x *Query) GetGeoQuery() *GeoQuery

func (*Query) GetMaxDate 

func (x *Query) GetMaxDate() int64

func (*Query) GetMaxSize 

func (x *Query) GetMaxSize() int64

func (*Query) GetMinDate 

func (x *Query) GetMinDate() int64

func (*Query) GetMinSize 

func (x *Query) GetMinSize() int64

func (*Query) GetNot 

func (x *Query) GetNot() bool

func (*Query) GetPathDepth 

func (x *Query) GetPathDepth() int32

func (*Query) GetPathPrefix 

func (x *Query) GetPathPrefix() []string

func (*Query) GetPaths 

func (x *Query) GetPaths() []string

func (*Query) GetType 

func (x *Query) GetType() NodeType

func (*Query) GetUUIDs 

func (x *Query) GetUUIDs() []string

func (*Query) ParseDurationDate 

func (m *Query) ParseDurationDate(ref ...time.Time) error

ParseDurationDate transforms DurationDate field to proper MinDate/MaxDate values variadic ref is passed mostly for test, should normally use NOW for reference time

func (*Query) ProtoMessage 

func (*Query) ProtoMessage()

func (*Query) ProtoReflect 

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

func (*Query) Reset 

func (x *Query) Reset()

func (*Query) String 

func (x *Query) String() string

type ReadNodeRequest 

type ReadNodeRequest struct {

	// Input node
	Node *Node `protobuf:"bytes,1,opt,name=Node,proto3" json:"Node,omitempty"`
	// Used internally for the router ReadNode request, stat the datasource instead of index
	ObjectStats bool `protobuf:"varint,4,opt,name=ObjectStats,proto3" json:"ObjectStats,omitempty"`
	// Generic Details Flags
	StatFlags []uint32 `protobuf:"varint,5,rep,packed,name=StatFlags,proto3" json:"StatFlags,omitempty"`
	// Get extended stats - For folders, computes ChildrenCount - Depreacted, use StatFlags instead
	WithExtendedStats bool `protobuf:"varint,3,opt,name=WithExtendedStats,proto3" json:"WithExtendedStats,omitempty"`
	// Gather commit information - This is Deprecated
	WithCommits bool `protobuf:"varint,2,opt,name=WithCommits,proto3" json:"WithCommits,omitempty"`
	// contains filtered or unexported fields
}

Request / Responses Messages

func (*ReadNodeRequest) Descriptor deprecated 

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

Deprecated: Use ReadNodeRequest.ProtoReflect.Descriptor instead.

func (*ReadNodeRequest) GetNode 

func (x *ReadNodeRequest) GetNode() *Node

func (*ReadNodeRequest) GetObjectStats 

func (x *ReadNodeRequest) GetObjectStats() bool

func (*ReadNodeRequest) GetStatFlags 

func (x *ReadNodeRequest) GetStatFlags() []uint32

func (*ReadNodeRequest) GetWithCommits 

func (x *ReadNodeRequest) GetWithCommits() bool

func (*ReadNodeRequest) GetWithExtendedStats 

func (x *ReadNodeRequest) GetWithExtendedStats() bool

func (*ReadNodeRequest) ProtoMessage 

func (*ReadNodeRequest) ProtoMessage()

func (*ReadNodeRequest) ProtoReflect 

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

func (*ReadNodeRequest) Reset 

func (x *ReadNodeRequest) Reset()

func (*ReadNodeRequest) String 

func (x *ReadNodeRequest) String() string

type ReadNodeResponse 

type ReadNodeResponse struct {
	Success bool  `protobuf:"varint,1,opt,name=Success,proto3" json:"Success,omitempty"`
	Node    *Node `protobuf:"bytes,2,opt,name=Node,proto3" json:"Node,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadNodeResponse) Descriptor deprecated 

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

Deprecated: Use ReadNodeResponse.ProtoReflect.Descriptor instead.

func (*ReadNodeResponse) GetNode 

func (x *ReadNodeResponse) GetNode() *Node

func (*ReadNodeResponse) GetSuccess 

func (x *ReadNodeResponse) GetSuccess() bool

func (*ReadNodeResponse) ProtoMessage 

func (*ReadNodeResponse) ProtoMessage()

func (*ReadNodeResponse) ProtoReflect 

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

func (*ReadNodeResponse) Reset 

func (x *ReadNodeResponse) Reset()

func (*ReadNodeResponse) String 

func (x *ReadNodeResponse) String() string

type SearchFacet 

type SearchFacet struct {

	// Facet field name
	FieldName string `protobuf:"bytes,1,opt,name=FieldName,proto3" json:"FieldName,omitempty"`
	// Segment Label
	Label string `protobuf:"bytes,2,opt,name=Label,proto3" json:"Label,omitempty"`
	// Segment results count
	Count int32 `protobuf:"varint,3,opt,name=Count,proto3" json:"Count,omitempty"`
	// For string facets, term value
	Term string `protobuf:"bytes,4,opt,name=Term,proto3" json:"Term,omitempty"`
	// For NumericRange facets, min/max values
	Min int64 `protobuf:"varint,5,opt,name=Min,proto3" json:"Min,omitempty"`
	Max int64 `protobuf:"varint,6,opt,name=Max,proto3" json:"Max,omitempty"`
	// For DateRange facets, start/end values
	Start int32 `protobuf:"varint,7,opt,name=Start,proto3" json:"Start,omitempty"`
	End   int32 `protobuf:"varint,8,opt,name=End,proto3" json:"End,omitempty"`
	// contains filtered or unexported fields
}

func (*SearchFacet) Descriptor deprecated 

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

Deprecated: Use SearchFacet.ProtoReflect.Descriptor instead.

func (*SearchFacet) GetCount 

func (x *SearchFacet) GetCount() int32

func (*SearchFacet) GetEnd 

func (x *SearchFacet) GetEnd() int32

func (*SearchFacet) GetFieldName 

func (x *SearchFacet) GetFieldName() string

func (*SearchFacet) GetLabel 

func (x *SearchFacet) GetLabel() string

func (*SearchFacet) GetMax 

func (x *SearchFacet) GetMax() int64

func (*SearchFacet) GetMin 

func (x *SearchFacet) GetMin() int64

func (*SearchFacet) GetStart 

func (x *SearchFacet) GetStart() int32

func (*SearchFacet) GetTerm 

func (x *SearchFacet) GetTerm() string

func (*SearchFacet) ProtoMessage 

func (*SearchFacet) ProtoMessage()

func (*SearchFacet) ProtoReflect 

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

func (*SearchFacet) Reset 

func (x *SearchFacet) Reset()

func (*SearchFacet) String 

func (x *SearchFacet) String() string

type SearchRequest 

type SearchRequest struct {

	// The query object
	Query *Query `protobuf:"bytes,1,opt,name=Query,proto3" json:"Query,omitempty"`
	// Limit the number of results
	Size int32 `protobuf:"varint,2,opt,name=Size,proto3" json:"Size,omitempty"`
	// Start at given position
	From int32 `protobuf:"varint,3,opt,name=From,proto3" json:"From,omitempty"`
	// Load node details
	Details bool `protobuf:"varint,4,opt,name=Details,proto3" json:"Details,omitempty"`
	// Generic Details Flags
	StatFlags []uint32 `protobuf:"varint,5,rep,packed,name=StatFlags,proto3" json:"StatFlags,omitempty"`
	// Sort result using a specific field
	SortField string `protobuf:"bytes,6,opt,name=SortField,proto3" json:"SortField,omitempty"`
	// Sort direction (asc by default)
	SortDirDesc bool `protobuf:"varint,7,opt,name=SortDirDesc,proto3" json:"SortDirDesc,omitempty"`
	// contains filtered or unexported fields
}

func (*SearchRequest) Descriptor deprecated 

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

Deprecated: Use SearchRequest.ProtoReflect.Descriptor instead.

func (*SearchRequest) GetDetails 

func (x *SearchRequest) GetDetails() bool

func (*SearchRequest) GetFrom 

func (x *SearchRequest) GetFrom() int32

func (*SearchRequest) GetQuery 

func (x *SearchRequest) GetQuery() *Query

func (*SearchRequest) GetSize 

func (x *SearchRequest) GetSize() int32

func (*SearchRequest) GetSortDirDesc 

func (x *SearchRequest) GetSortDirDesc() bool

func (*SearchRequest) GetSortField 

func (x *SearchRequest) GetSortField() string

func (*SearchRequest) GetStatFlags 

func (x *SearchRequest) GetStatFlags() []uint32

func (*SearchRequest) ProtoMessage 

func (*SearchRequest) ProtoMessage()

func (*SearchRequest) ProtoReflect 

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

func (*SearchRequest) Reset 

func (x *SearchRequest) Reset()

func (*SearchRequest) String 

func (x *SearchRequest) String() string

type SearchResponse 

type SearchResponse struct {
	Node  *Node        `protobuf:"bytes,1,opt,name=Node,proto3" json:"Node,omitempty"`
	Facet *SearchFacet `protobuf:"bytes,2,opt,name=Facet,proto3" json:"Facet,omitempty"`
	// contains filtered or unexported fields
}

func (*SearchResponse) Descriptor deprecated 

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

Deprecated: Use SearchResponse.ProtoReflect.Descriptor instead.

func (*SearchResponse) GetFacet 

func (x *SearchResponse) GetFacet() *SearchFacet

func (*SearchResponse) GetNode 

func (x *SearchResponse) GetNode() *Node

func (*SearchResponse) ProtoMessage 

func (*SearchResponse) ProtoMessage()

func (*SearchResponse) ProtoReflect 

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

func (*SearchResponse) Reset 

func (x *SearchResponse) Reset()

func (*SearchResponse) String 

func (x *SearchResponse) String() string

type SearchSyncChangeRequest 

type SearchSyncChangeRequest struct {
	Seq         uint64 `protobuf:"varint,1,opt,name=seq,proto3" json:"seq,omitempty"`
	Flatten     bool   `protobuf:"varint,2,opt,name=flatten,proto3" json:"flatten,omitempty"`
	Prefix      string `protobuf:"bytes,3,opt,name=prefix,proto3" json:"prefix,omitempty"`
	LastSeqOnly bool   `protobuf:"varint,4,opt,name=lastSeqOnly,proto3" json:"lastSeqOnly,omitempty"`
	// contains filtered or unexported fields
}

func (*SearchSyncChangeRequest) Descriptor deprecated 

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

Deprecated: Use SearchSyncChangeRequest.ProtoReflect.Descriptor instead.

func (*SearchSyncChangeRequest) GetFlatten 

func (x *SearchSyncChangeRequest) GetFlatten() bool

func (*SearchSyncChangeRequest) GetLastSeqOnly 

func (x *SearchSyncChangeRequest) GetLastSeqOnly() bool

func (*SearchSyncChangeRequest) GetPrefix 

func (x *SearchSyncChangeRequest) GetPrefix() string

func (*SearchSyncChangeRequest) GetSeq 

func (x *SearchSyncChangeRequest) GetSeq() uint64

func (*SearchSyncChangeRequest) ProtoMessage 

func (*SearchSyncChangeRequest) ProtoMessage()

func (*SearchSyncChangeRequest) ProtoReflect 

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

func (*SearchSyncChangeRequest) Reset 

func (x *SearchSyncChangeRequest) Reset()

func (*SearchSyncChangeRequest) String 

func (x *SearchSyncChangeRequest) String() string

type SearcherClient 

type SearcherClient interface {
	Search(ctx context.Context, in *SearchRequest, opts ...grpc.CallOption) (Searcher_SearchClient, error)
}

SearcherClient is the client API for Searcher service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewSearcherClient 

func NewSearcherClient(cc grpc.ClientConnInterface) SearcherClient

type SearcherServer 

type SearcherServer interface {
	Search(*SearchRequest, Searcher_SearchServer) error
	// contains filtered or unexported methods
}

SearcherServer is the server API for Searcher service. All implementations must embed UnimplementedSearcherServer for forward compatibility

type SearcherStub 

type SearcherStub struct {
	SearcherServer
}

func (*SearcherStub) Invoke 

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

func (*SearcherStub) NewStream 

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

type SearcherStub_SearchStreamer 

type SearcherStub_SearchStreamer struct {
	stubs.ClientServerStreamerCore
}

func (*SearcherStub_SearchStreamer) Send 

func (s *SearcherStub_SearchStreamer) Send(response *SearchResponse) error

type Searcher_SearchClient 

type Searcher_SearchClient interface {
	Recv() (*SearchResponse, error)
	grpc.ClientStream
}

type Searcher_SearchServer 

type Searcher_SearchServer interface {
	Send(*SearchResponse) error
	grpc.ServerStream
}

type SessionIndexerClient 

type SessionIndexerClient interface {
	OpenSession(ctx context.Context, in *OpenSessionRequest, opts ...grpc.CallOption) (*OpenSessionResponse, error)
	FlushSession(ctx context.Context, in *FlushSessionRequest, opts ...grpc.CallOption) (*FlushSessionResponse, error)
	CloseSession(ctx context.Context, in *CloseSessionRequest, opts ...grpc.CallOption) (*CloseSessionResponse, error)
}

SessionIndexerClient is the client API for SessionIndexer service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewSessionIndexerClient 

func NewSessionIndexerClient(cc grpc.ClientConnInterface) SessionIndexerClient

type SessionIndexerMock 

type SessionIndexerMock struct {
}

func (*SessionIndexerMock) CloseSession 

func (s *SessionIndexerMock) CloseSession(ctx context.Context, in *CloseSessionRequest, opts ...grpc.CallOption) (*CloseSessionResponse, error)

func (*SessionIndexerMock) FlushSession 

func (s *SessionIndexerMock) FlushSession(ctx context.Context, in *FlushSessionRequest, opts ...grpc.CallOption) (*FlushSessionResponse, error)

func (*SessionIndexerMock) OpenSession 

func (s *SessionIndexerMock) OpenSession(ctx context.Context, in *OpenSessionRequest, opts ...grpc.CallOption) (*OpenSessionResponse, error)

type SessionIndexerServer 

type SessionIndexerServer interface {
	OpenSession(context.Context, *OpenSessionRequest) (*OpenSessionResponse, error)
	FlushSession(context.Context, *FlushSessionRequest) (*FlushSessionResponse, error)
	CloseSession(context.Context, *CloseSessionRequest) (*CloseSessionResponse, error)
	// contains filtered or unexported methods
}

SessionIndexerServer is the server API for SessionIndexer service. All implementations must embed UnimplementedSessionIndexerServer for forward compatibility

type SessionIndexerStub 

type SessionIndexerStub struct {
	SessionIndexerServer
}

func (*SessionIndexerStub) Invoke 

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

func (*SessionIndexerStub) NewStream 

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

type StoreVersionRequest 

type StoreVersionRequest struct {
	Node    *Node      `protobuf:"bytes,1,opt,name=Node,proto3" json:"Node,omitempty"`
	Version *ChangeLog `protobuf:"bytes,2,opt,name=Version,proto3" json:"Version,omitempty"`
	// contains filtered or unexported fields
}

func (*StoreVersionRequest) Descriptor deprecated 

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

Deprecated: Use StoreVersionRequest.ProtoReflect.Descriptor instead.

func (*StoreVersionRequest) GetNode 

func (x *StoreVersionRequest) GetNode() *Node

func (*StoreVersionRequest) GetVersion 

func (x *StoreVersionRequest) GetVersion() *ChangeLog

func (*StoreVersionRequest) ProtoMessage 

func (*StoreVersionRequest) ProtoMessage()

func (*StoreVersionRequest) ProtoReflect 

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

func (*StoreVersionRequest) Reset 

func (x *StoreVersionRequest) Reset()

func (*StoreVersionRequest) String 

func (x *StoreVersionRequest) String() string

type StoreVersionResponse 

type StoreVersionResponse struct {
	Success       bool         `protobuf:"varint,1,opt,name=Success,proto3" json:"Success,omitempty"`
	PruneVersions []*ChangeLog `protobuf:"bytes,2,rep,name=PruneVersions,proto3" json:"PruneVersions,omitempty"`
	// contains filtered or unexported fields
}

func (*StoreVersionResponse) Descriptor deprecated 

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

Deprecated: Use StoreVersionResponse.ProtoReflect.Descriptor instead.

func (*StoreVersionResponse) GetPruneVersions 

func (x *StoreVersionResponse) GetPruneVersions() []*ChangeLog

func (*StoreVersionResponse) GetSuccess 

func (x *StoreVersionResponse) GetSuccess() bool

func (*StoreVersionResponse) ProtoMessage 

func (*StoreVersionResponse) ProtoMessage()

func (*StoreVersionResponse) ProtoReflect 

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

func (*StoreVersionResponse) Reset 

func (x *StoreVersionResponse) Reset()

func (*StoreVersionResponse) String 

func (x *StoreVersionResponse) String() string

type StreamChangesRequest 

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

func (*StreamChangesRequest) Descriptor deprecated 

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

Deprecated: Use StreamChangesRequest.ProtoReflect.Descriptor instead.

func (*StreamChangesRequest) GetRootPath 

func (x *StreamChangesRequest) GetRootPath() string

func (*StreamChangesRequest) ProtoMessage 

func (*StreamChangesRequest) ProtoMessage()

func (*StreamChangesRequest) ProtoReflect 

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

func (*StreamChangesRequest) Reset 

func (x *StreamChangesRequest) Reset()

func (*StreamChangesRequest) String 

func (x *StreamChangesRequest) String() string

type StreamerMock 

type StreamerMock struct {
	// contains filtered or unexported fields
}

func (*StreamerMock) Close 

func (m *StreamerMock) Close() error

func (*StreamerMock) CloseSend 

func (m *StreamerMock) CloseSend() error

func (*StreamerMock) Context 

func (m *StreamerMock) Context() context.Context

func (*StreamerMock) Error 

func (m *StreamerMock) Error() error

func (*StreamerMock) Header 

func (m *StreamerMock) Header() (metadata.MD, error)

func (*StreamerMock) Recv 

func (m *StreamerMock) Recv(v interface{}) error

func (*StreamerMock) RecvMsg 

func (m *StreamerMock) RecvMsg(msg interface{}) error

func (*StreamerMock) Send 

func (m *StreamerMock) Send(v interface{}) error

func (*StreamerMock) SendMsg 

func (m *StreamerMock) SendMsg(msg interface{}) error

func (*StreamerMock) Trailer 

func (m *StreamerMock) Trailer() metadata.MD

type SyncChange 

type SyncChange struct {
	Seq    uint64          `protobuf:"varint,1,opt,name=seq,proto3" json:"seq,omitempty"`
	NodeId string          `protobuf:"bytes,2,opt,name=nodeId,json=node_id,proto3" json:"nodeId,omitempty"`
	Type   SyncChange_Type `protobuf:"varint,3,opt,name=type,proto3,enum=tree.SyncChange_Type" json:"type,omitempty"`
	Source string          `protobuf:"bytes,4,opt,name=source,proto3" json:"source,omitempty"`
	Target string          `protobuf:"bytes,5,opt,name=target,proto3" json:"target,omitempty"`
	Node   *SyncChangeNode `protobuf:"bytes,6,opt,name=node,proto3" json:"node,omitempty"`
	// contains filtered or unexported fields
}

func (*SyncChange) Descriptor deprecated 

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

Deprecated: Use SyncChange.ProtoReflect.Descriptor instead.

func (*SyncChange) GetNode 

func (x *SyncChange) GetNode() *SyncChangeNode

func (*SyncChange) GetNodeId 

func (x *SyncChange) GetNodeId() string

func (*SyncChange) GetSeq 

func (x *SyncChange) GetSeq() uint64

func (*SyncChange) GetSource 

func (x *SyncChange) GetSource() string

func (*SyncChange) GetTarget 

func (x *SyncChange) GetTarget() string

func (*SyncChange) GetType 

func (x *SyncChange) GetType() SyncChange_Type

func (*SyncChange) ProtoMessage 

func (*SyncChange) ProtoMessage()

func (*SyncChange) ProtoReflect 

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

func (*SyncChange) Reset 

func (x *SyncChange) Reset()

func (*SyncChange) String 

func (x *SyncChange) String() string

type SyncChangeNode 

type SyncChangeNode struct {
	Bytesize             int64  `protobuf:"varint,1,opt,name=bytesize,proto3" json:"bytesize,omitempty"`
	Md5                  string `protobuf:"bytes,2,opt,name=md5,proto3" json:"md5,omitempty"`
	Mtime                int64  `protobuf:"varint,3,opt,name=mtime,proto3" json:"mtime,omitempty"`
	NodePath             string `protobuf:"bytes,4,opt,name=nodePath,json=node_path,proto3" json:"nodePath,omitempty"`
	RepositoryIdentifier string `protobuf:"bytes,5,opt,name=repositoryIdentifier,json=repository_identifier,proto3" json:"repositoryIdentifier,omitempty"`
	// contains filtered or unexported fields
}

func (*SyncChangeNode) Descriptor deprecated 

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

Deprecated: Use SyncChangeNode.ProtoReflect.Descriptor instead.

func (*SyncChangeNode) GetBytesize 

func (x *SyncChangeNode) GetBytesize() int64

func (*SyncChangeNode) GetMd5 

func (x *SyncChangeNode) GetMd5() string

func (*SyncChangeNode) GetMtime 

func (x *SyncChangeNode) GetMtime() int64

func (*SyncChangeNode) GetNodePath 

func (x *SyncChangeNode) GetNodePath() string

func (*SyncChangeNode) GetRepositoryIdentifier 

func (x *SyncChangeNode) GetRepositoryIdentifier() string

func (*SyncChangeNode) ProtoMessage 

func (*SyncChangeNode) ProtoMessage()

func (*SyncChangeNode) ProtoReflect 

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

func (*SyncChangeNode) Reset 

func (x *SyncChangeNode) Reset()

func (*SyncChangeNode) String 

func (x *SyncChangeNode) String() string

type SyncChange_Type 

type SyncChange_Type int32
const (
	SyncChange_unknown SyncChange_Type = 0
	SyncChange_create  SyncChange_Type = 1
	SyncChange_delete  SyncChange_Type = 2
	SyncChange_path    SyncChange_Type = 3
	SyncChange_content SyncChange_Type = 4
)

func (SyncChange_Type) Descriptor 

func (SyncChange_Type) Descriptor() protoreflect.EnumDescriptor

func (SyncChange_Type) Enum 

func (x SyncChange_Type) Enum() *SyncChange_Type

func (SyncChange_Type) EnumDescriptor deprecated 

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

Deprecated: Use SyncChange_Type.Descriptor instead.

func (SyncChange_Type) Number 

func (x SyncChange_Type) Number() protoreflect.EnumNumber

func (SyncChange_Type) String 

func (x SyncChange_Type) String() string

func (SyncChange_Type) Type 

func (SyncChange_Type) Type() protoreflect.EnumType

type SyncChangesClient 

type SyncChangesClient interface {
	Put(ctx context.Context, opts ...grpc.CallOption) (SyncChanges_PutClient, error)
	Search(ctx context.Context, in *SearchSyncChangeRequest, opts ...grpc.CallOption) (SyncChanges_SearchClient, error)
}

SyncChangesClient is the client API for SyncChanges service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewSyncChangesClient 

func NewSyncChangesClient(cc grpc.ClientConnInterface) SyncChangesClient

type SyncChangesServer 

type SyncChangesServer interface {
	Put(SyncChanges_PutServer) error
	Search(*SearchSyncChangeRequest, SyncChanges_SearchServer) error
	// contains filtered or unexported methods
}

SyncChangesServer is the server API for SyncChanges service. All implementations must embed UnimplementedSyncChangesServer for forward compatibility

type SyncChangesStub 

type SyncChangesStub struct {
	SyncChangesServer
}

func (*SyncChangesStub) Invoke 

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

func (*SyncChangesStub) NewStream 

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

type SyncChangesStub_PutStreamer 

type SyncChangesStub_PutStreamer struct {
	stubs.BidirServerStreamerCore
}

func (*SyncChangesStub_PutStreamer) Recv 

func (s *SyncChangesStub_PutStreamer) Recv() (*SyncChange, error)

func (*SyncChangesStub_PutStreamer) Send 

func (s *SyncChangesStub_PutStreamer) Send(response *PutSyncChangeResponse) error

func (*SyncChangesStub_PutStreamer) SendAndClose 

func (s *SyncChangesStub_PutStreamer) SendAndClose(*PutSyncChangeResponse) error

type SyncChangesStub_SearchStreamer 

type SyncChangesStub_SearchStreamer struct {
	stubs.ClientServerStreamerCore
}

func (*SyncChangesStub_SearchStreamer) Send 

func (s *SyncChangesStub_SearchStreamer) Send(response *SyncChange) error

type SyncChanges_PutClient 

type SyncChanges_PutClient interface {
	Send(*SyncChange) error
	CloseAndRecv() (*PutSyncChangeResponse, error)
	grpc.ClientStream
}

type SyncChanges_PutServer 

type SyncChanges_PutServer interface {
	SendAndClose(*PutSyncChangeResponse) error
	Recv() (*SyncChange, error)
	grpc.ServerStream
}

type SyncChanges_SearchClient 

type SyncChanges_SearchClient interface {
	Recv() (*SyncChange, error)
	grpc.ClientStream
}

type SyncChanges_SearchServer 

type SyncChanges_SearchServer interface {
	Send(*SyncChange) error
	grpc.ServerStream
}

type TreeNode 

type TreeNode struct {
	Node  *Node  `protobuf:"bytes,1,opt,name=Node,proto3" json:"Node,omitempty" gorm:"embedded;"`
	Name  string `` /* 141-byte string literal not displayed */
	Level int64  `` /* 131-byte string literal not displayed */
	MPath *MPath `protobuf:"bytes,4,opt,name=MPath,proto3" json:"MPath,omitempty" gorm:"embedded;"`
	Hash  string `protobuf:"bytes,5,opt,name=Hash,proto3" json:"Hash,omitempty" gorm:"column:hash;type:VARCHAR(40) NOT NULL;unique;"`
	Hash2 string `protobuf:"bytes,6,opt,name=Hash2,proto3" json:"Hash2,omitempty" gorm:"column:hash2;type:VARCHAR(50) NOT NULL;unique;"`
	// contains filtered or unexported fields
}

func (*TreeNode) AfterFind 

func (tn *TreeNode) AfterFind(*gorm.DB) error

func (*TreeNode) BeforeCreate 

func (tn *TreeNode) BeforeCreate(*gorm.DB) error

func (*TreeNode) BeforeSave 

func (tn *TreeNode) BeforeSave(*gorm.DB) error

func (*TreeNode) Descriptor deprecated 

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

Deprecated: Use TreeNode.ProtoReflect.Descriptor instead.

func (*TreeNode) GetHash 

func (x *TreeNode) GetHash() string

func (*TreeNode) GetHash2 

func (x *TreeNode) GetHash2() string

func (*TreeNode) GetLevel 

func (x *TreeNode) GetLevel() int64

func (*TreeNode) GetMPath 

func (x *TreeNode) GetMPath() *MPath

func (*TreeNode) GetName 

func (x *TreeNode) GetName() string

func (*TreeNode) GetNode 

func (x *TreeNode) GetNode() *Node

func (*TreeNode) ProtoMessage 

func (*TreeNode) ProtoMessage()

func (*TreeNode) ProtoReflect 

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

func (*TreeNode) Reset 

func (x *TreeNode) Reset()

func (*TreeNode) SetHash 

func (x *TreeNode) SetHash(v string)

func (*TreeNode) SetHash2 

func (x *TreeNode) SetHash2(v string)

func (*TreeNode) SetLevel 

func (x *TreeNode) SetLevel(v int64)

func (*TreeNode) SetMPath 

func (x *TreeNode) SetMPath(v *MPath)

func (*TreeNode) SetName 

func (x *TreeNode) SetName(v string)

func (*TreeNode) SetNode 

func (x *TreeNode) SetNode(v *Node)

func (*TreeNode) String 

func (x *TreeNode) String() string

func (*TreeNode) TableName 

func (tn *TreeNode) TableName(namer schema.Namer) string

type TreeNodeGetter 

type TreeNodeGetter interface {
	GetNode() *Node
	GetName() string
	GetLevel() int64
	GetMPath() *MPath
	GetHash() string
	GetHash2() string
}

type TreeNodeSetter 

type TreeNodeSetter interface {
	SetNode(*Node)
	SetName(string)
	SetLevel(int64)
	SetMPath(*MPath)
	SetHash(string)
	SetHash2(string)
}

type UnimplementedFileKeyManagerServer 

type UnimplementedFileKeyManagerServer struct {
}

UnimplementedFileKeyManagerServer must be embedded to have forward compatible implementations.

func (UnimplementedFileKeyManagerServer) GetEncryptionKey 

func (UnimplementedFileKeyManagerServer) GetEncryptionKey(context.Context, *GetEncryptionKeyRequest) (*GetEncryptionKeyResponse, error)

type UnimplementedNodeChangesReceiverStreamerServer 

type UnimplementedNodeChangesReceiverStreamerServer struct {
}

UnimplementedNodeChangesReceiverStreamerServer must be embedded to have forward compatible implementations.

func (UnimplementedNodeChangesReceiverStreamerServer) PostNodeChanges 

func (UnimplementedNodeChangesReceiverStreamerServer) PostNodeChanges(NodeChangesReceiverStreamer_PostNodeChangesServer) error

type UnimplementedNodeChangesStreamerServer 

type UnimplementedNodeChangesStreamerServer struct {
}

UnimplementedNodeChangesStreamerServer must be embedded to have forward compatible implementations.

func (UnimplementedNodeChangesStreamerServer) StreamChanges 

func (UnimplementedNodeChangesStreamerServer) StreamChanges(*StreamChangesRequest, NodeChangesStreamer_StreamChangesServer) error

type UnimplementedNodeContentReaderServer 

type UnimplementedNodeContentReaderServer struct {
}

UnimplementedNodeContentReaderServer must be embedded to have forward compatible implementations.

type UnimplementedNodeContentWriterServer 

type UnimplementedNodeContentWriterServer struct {
}

UnimplementedNodeContentWriterServer must be embedded to have forward compatible implementations.

type UnimplementedNodeEventsProviderServer 

type UnimplementedNodeEventsProviderServer struct {
}

UnimplementedNodeEventsProviderServer must be embedded to have forward compatible implementations.

func (UnimplementedNodeEventsProviderServer) WatchNode 

func (UnimplementedNodeEventsProviderServer) WatchNode(*WatchNodeRequest, NodeEventsProvider_WatchNodeServer) error

type UnimplementedNodeProviderServer 

type UnimplementedNodeProviderServer struct {
}

UnimplementedNodeProviderServer must be embedded to have forward compatible implementations.

func (UnimplementedNodeProviderServer) ListNodes 

func (UnimplementedNodeProviderServer) ListNodes(*ListNodesRequest, NodeProvider_ListNodesServer) error

func (UnimplementedNodeProviderServer) ReadNode 

func (UnimplementedNodeProviderServer) ReadNode(context.Context, *ReadNodeRequest) (*ReadNodeResponse, error)

type UnimplementedNodeProviderStreamerServer 

type UnimplementedNodeProviderStreamerServer struct {
}

UnimplementedNodeProviderStreamerServer must be embedded to have forward compatible implementations.

func (UnimplementedNodeProviderStreamerServer) ReadNodeStream 

func (UnimplementedNodeProviderStreamerServer) ReadNodeStream(NodeProviderStreamer_ReadNodeStreamServer) error

type UnimplementedNodeReceiverServer 

type UnimplementedNodeReceiverServer struct {
}

UnimplementedNodeReceiverServer must be embedded to have forward compatible implementations.

func (UnimplementedNodeReceiverServer) CreateNode 

func (UnimplementedNodeReceiverServer) CreateNode(context.Context, *CreateNodeRequest) (*CreateNodeResponse, error)

func (UnimplementedNodeReceiverServer) DeleteNode 

func (UnimplementedNodeReceiverServer) DeleteNode(context.Context, *DeleteNodeRequest) (*DeleteNodeResponse, error)

func (UnimplementedNodeReceiverServer) UpdateNode 

func (UnimplementedNodeReceiverServer) UpdateNode(context.Context, *UpdateNodeRequest) (*UpdateNodeResponse, error)

type UnimplementedNodeReceiverStreamServer 

type UnimplementedNodeReceiverStreamServer struct {
}

UnimplementedNodeReceiverStreamServer must be embedded to have forward compatible implementations.

func (UnimplementedNodeReceiverStreamServer) CreateNodeStream 

func (UnimplementedNodeReceiverStreamServer) CreateNodeStream(NodeReceiverStream_CreateNodeStreamServer) error

func (UnimplementedNodeReceiverStreamServer) DeleteNodeStream 

func (UnimplementedNodeReceiverStreamServer) DeleteNodeStream(NodeReceiverStream_DeleteNodeStreamServer) error

func (UnimplementedNodeReceiverStreamServer) UpdateNodeStream 

func (UnimplementedNodeReceiverStreamServer) UpdateNodeStream(NodeReceiverStream_UpdateNodeStreamServer) error

type UnimplementedNodeVersionerServer 

type UnimplementedNodeVersionerServer struct {
}

UnimplementedNodeVersionerServer must be embedded to have forward compatible implementations.

func (UnimplementedNodeVersionerServer) CreateVersion 

func (UnimplementedNodeVersionerServer) CreateVersion(context.Context, *CreateVersionRequest) (*CreateVersionResponse, error)

func (UnimplementedNodeVersionerServer) HeadVersion 

func (UnimplementedNodeVersionerServer) HeadVersion(context.Context, *HeadVersionRequest) (*HeadVersionResponse, error)

func (UnimplementedNodeVersionerServer) ListVersioningPolicies 

func (UnimplementedNodeVersionerServer) ListVersioningPolicies(*ListVersioningPoliciesRequest, NodeVersioner_ListVersioningPoliciesServer) error

func (UnimplementedNodeVersionerServer) ListVersions 

func (UnimplementedNodeVersionerServer) ListVersions(*ListVersionsRequest, NodeVersioner_ListVersionsServer) error

func (UnimplementedNodeVersionerServer) PruneVersions 

func (UnimplementedNodeVersionerServer) PruneVersions(context.Context, *PruneVersionsRequest) (*PruneVersionsResponse, error)

func (UnimplementedNodeVersionerServer) StoreVersion 

func (UnimplementedNodeVersionerServer) StoreVersion(context.Context, *StoreVersionRequest) (*StoreVersionResponse, error)

type UnimplementedSearcherServer 

type UnimplementedSearcherServer struct {
}

UnimplementedSearcherServer must be embedded to have forward compatible implementations.

func (UnimplementedSearcherServer) Search 

func (UnimplementedSearcherServer) Search(*SearchRequest, Searcher_SearchServer) error

type UnimplementedSessionIndexerServer 

type UnimplementedSessionIndexerServer struct {
}

UnimplementedSessionIndexerServer must be embedded to have forward compatible implementations.

func (UnimplementedSessionIndexerServer) CloseSession 

func (UnimplementedSessionIndexerServer) CloseSession(context.Context, *CloseSessionRequest) (*CloseSessionResponse, error)

func (UnimplementedSessionIndexerServer) FlushSession 

func (UnimplementedSessionIndexerServer) FlushSession(context.Context, *FlushSessionRequest) (*FlushSessionResponse, error)

func (UnimplementedSessionIndexerServer) OpenSession 

func (UnimplementedSessionIndexerServer) OpenSession(context.Context, *OpenSessionRequest) (*OpenSessionResponse, error)

type UnimplementedSyncChangesServer 

type UnimplementedSyncChangesServer struct {
}

UnimplementedSyncChangesServer must be embedded to have forward compatible implementations.

func (UnimplementedSyncChangesServer) Put 

func (UnimplementedSyncChangesServer) Put(SyncChanges_PutServer) error

func (UnimplementedSyncChangesServer) Search 

func (UnimplementedSyncChangesServer) Search(*SearchSyncChangeRequest, SyncChanges_SearchServer) error

type UnsafeFileKeyManagerServer 

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

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

type UnsafeNodeChangesReceiverStreamerServer 

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

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

type UnsafeNodeChangesStreamerServer 

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

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

type UnsafeNodeContentReaderServer 

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

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

type UnsafeNodeContentWriterServer 

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

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

type UnsafeNodeEventsProviderServer 

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

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

type UnsafeNodeProviderServer 

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

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

type UnsafeNodeProviderStreamerServer 

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

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

type UnsafeNodeReceiverServer 

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

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

type UnsafeNodeReceiverStreamServer 

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

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

type UnsafeNodeVersionerServer 

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

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

type UnsafeSearcherServer 

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

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

type UnsafeSessionIndexerServer 

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

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

type UnsafeSyncChangesServer 

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

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

type UpdateNodeRequest 

type UpdateNodeRequest struct {
	From              *Node  `protobuf:"bytes,1,opt,name=From,proto3" json:"From,omitempty"`
	To                *Node  `protobuf:"bytes,2,opt,name=To,proto3" json:"To,omitempty"`
	IndexationSession string `protobuf:"bytes,3,opt,name=IndexationSession,proto3" json:"IndexationSession,omitempty"`
	Silent            bool   `protobuf:"varint,4,opt,name=Silent,proto3" json:"Silent,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateNodeRequest) Descriptor deprecated 

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

Deprecated: Use UpdateNodeRequest.ProtoReflect.Descriptor instead.

func (*UpdateNodeRequest) GetFrom 

func (x *UpdateNodeRequest) GetFrom() *Node

func (*UpdateNodeRequest) GetIndexationSession 

func (x *UpdateNodeRequest) GetIndexationSession() string

func (*UpdateNodeRequest) GetSilent 

func (x *UpdateNodeRequest) GetSilent() bool

func (*UpdateNodeRequest) GetTo 

func (x *UpdateNodeRequest) GetTo() *Node

func (*UpdateNodeRequest) ProtoMessage 

func (*UpdateNodeRequest) ProtoMessage()

func (*UpdateNodeRequest) ProtoReflect 

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

func (*UpdateNodeRequest) Reset 

func (x *UpdateNodeRequest) Reset()

func (*UpdateNodeRequest) String 

func (x *UpdateNodeRequest) String() string

type UpdateNodeResponse 

type UpdateNodeResponse struct {
	Success bool  `protobuf:"varint,1,opt,name=Success,proto3" json:"Success,omitempty"`
	Node    *Node `protobuf:"bytes,2,opt,name=Node,proto3" json:"Node,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateNodeResponse) Descriptor deprecated 

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

Deprecated: Use UpdateNodeResponse.ProtoReflect.Descriptor instead.

func (*UpdateNodeResponse) GetNode 

func (x *UpdateNodeResponse) GetNode() *Node

func (*UpdateNodeResponse) GetSuccess 

func (x *UpdateNodeResponse) GetSuccess() bool

func (*UpdateNodeResponse) ProtoMessage 

func (*UpdateNodeResponse) ProtoMessage()

func (*UpdateNodeResponse) ProtoReflect 

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

func (*UpdateNodeResponse) Reset 

func (x *UpdateNodeResponse) Reset()

func (*UpdateNodeResponse) String 

func (x *UpdateNodeResponse) String() string

type VersioningKeepPeriod 

type VersioningKeepPeriod struct {
	IntervalStart string `protobuf:"bytes,1,opt,name=IntervalStart,proto3" json:"IntervalStart,omitempty"`
	MaxNumber     int32  `protobuf:"varint,3,opt,name=MaxNumber,proto3" json:"MaxNumber,omitempty"`
	// contains filtered or unexported fields
}

func (*VersioningKeepPeriod) Descriptor deprecated 

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

Deprecated: Use VersioningKeepPeriod.ProtoReflect.Descriptor instead.

func (*VersioningKeepPeriod) GetIntervalStart 

func (x *VersioningKeepPeriod) GetIntervalStart() string

func (*VersioningKeepPeriod) GetMaxNumber 

func (x *VersioningKeepPeriod) GetMaxNumber() int32

func (*VersioningKeepPeriod) ProtoMessage 

func (*VersioningKeepPeriod) ProtoMessage()

func (*VersioningKeepPeriod) ProtoReflect 

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

func (*VersioningKeepPeriod) Reset 

func (x *VersioningKeepPeriod) Reset()

func (*VersioningKeepPeriod) String 

func (x *VersioningKeepPeriod) String() string

type VersioningNodeDeletedStrategy 

type VersioningNodeDeletedStrategy int32
const (
	VersioningNodeDeletedStrategy_KeepAll  VersioningNodeDeletedStrategy = 0
	VersioningNodeDeletedStrategy_KeepLast VersioningNodeDeletedStrategy = 1
	VersioningNodeDeletedStrategy_KeepNone VersioningNodeDeletedStrategy = 2
)

func (VersioningNodeDeletedStrategy) Descriptor 

func (VersioningNodeDeletedStrategy) Descriptor() protoreflect.EnumDescriptor

func (VersioningNodeDeletedStrategy) Enum 

func (x VersioningNodeDeletedStrategy) Enum() *VersioningNodeDeletedStrategy

func (VersioningNodeDeletedStrategy) EnumDescriptor deprecated 

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

Deprecated: Use VersioningNodeDeletedStrategy.Descriptor instead.

func (VersioningNodeDeletedStrategy) Number 

func (x VersioningNodeDeletedStrategy) Number() protoreflect.EnumNumber

func (VersioningNodeDeletedStrategy) String 

func (x VersioningNodeDeletedStrategy) String() string

func (VersioningNodeDeletedStrategy) Type 

func (VersioningNodeDeletedStrategy) Type() protoreflect.EnumType

type VersioningPolicy 

type VersioningPolicy struct {
	Uuid                     string                        `protobuf:"bytes,1,opt,name=Uuid,proto3" json:"Uuid,omitempty"`
	Name                     string                        `protobuf:"bytes,2,opt,name=Name,proto3" json:"Name,omitempty"`
	Description              string                        `protobuf:"bytes,3,opt,name=Description,proto3" json:"Description,omitempty"`
	VersionsDataSourceName   string                        `protobuf:"bytes,4,opt,name=VersionsDataSourceName,proto3" json:"VersionsDataSourceName,omitempty"`
	VersionsDataSourceBucket string                        `protobuf:"bytes,5,opt,name=VersionsDataSourceBucket,proto3" json:"VersionsDataSourceBucket,omitempty"`
	MaxTotalSize             int64                         `protobuf:"varint,6,opt,name=MaxTotalSize,proto3" json:"MaxTotalSize,omitempty"`
	MaxSizePerFile           int64                         `protobuf:"varint,7,opt,name=MaxSizePerFile,proto3" json:"MaxSizePerFile,omitempty"`
	IgnoreFilesGreaterThan   int64                         `protobuf:"varint,8,opt,name=IgnoreFilesGreaterThan,proto3" json:"IgnoreFilesGreaterThan,omitempty"`
	KeepPeriods              []*VersioningKeepPeriod       `protobuf:"bytes,9,rep,name=KeepPeriods,proto3" json:"KeepPeriods,omitempty"`
	NodeDeletedStrategy      VersioningNodeDeletedStrategy `` /* 133-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*VersioningPolicy) Descriptor deprecated 

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

Deprecated: Use VersioningPolicy.ProtoReflect.Descriptor instead.

func (*VersioningPolicy) GetDescription 

func (x *VersioningPolicy) GetDescription() string

func (*VersioningPolicy) GetIgnoreFilesGreaterThan 

func (x *VersioningPolicy) GetIgnoreFilesGreaterThan() int64

func (*VersioningPolicy) GetKeepPeriods 

func (x *VersioningPolicy) GetKeepPeriods() []*VersioningKeepPeriod

func (*VersioningPolicy) GetMaxSizePerFile 

func (x *VersioningPolicy) GetMaxSizePerFile() int64

func (*VersioningPolicy) GetMaxTotalSize 

func (x *VersioningPolicy) GetMaxTotalSize() int64

func (*VersioningPolicy) GetName 

func (x *VersioningPolicy) GetName() string

func (*VersioningPolicy) GetNodeDeletedStrategy 

func (x *VersioningPolicy) GetNodeDeletedStrategy() VersioningNodeDeletedStrategy

func (*VersioningPolicy) GetUuid 

func (x *VersioningPolicy) GetUuid() string

func (*VersioningPolicy) GetVersionsDataSourceBucket 

func (x *VersioningPolicy) GetVersionsDataSourceBucket() string

func (*VersioningPolicy) GetVersionsDataSourceName 

func (x *VersioningPolicy) GetVersionsDataSourceName() string

func (*VersioningPolicy) MarshalLogObject 

func (policy *VersioningPolicy) MarshalLogObject(encoder zapcore.ObjectEncoder) error

MarshalLogObject implements custom marshalling for logs

func (*VersioningPolicy) ProtoMessage 

func (*VersioningPolicy) ProtoMessage()

func (*VersioningPolicy) ProtoReflect 

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

func (*VersioningPolicy) Reset 

func (x *VersioningPolicy) Reset()

func (*VersioningPolicy) String 

func (x *VersioningPolicy) String() string

func (*VersioningPolicy) Zap 

func (policy *VersioningPolicy) Zap() zapcore.Field

Zap simply returns a zapcore.Field object populated with this VersioningPolicy under a standard key

type WatchNodeRequest 

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

Request / Responses Messages

func (*WatchNodeRequest) Descriptor deprecated 

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

Deprecated: Use WatchNodeRequest.ProtoReflect.Descriptor instead.

func (*WatchNodeRequest) GetNode 

func (x *WatchNodeRequest) GetNode() *Node

func (*WatchNodeRequest) ProtoMessage 

func (*WatchNodeRequest) ProtoMessage()

func (*WatchNodeRequest) ProtoReflect 

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

func (*WatchNodeRequest) Reset 

func (x *WatchNodeRequest) Reset()

func (*WatchNodeRequest) String 

func (x *WatchNodeRequest) String() string

type WatchNodeResponse 

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

func (*WatchNodeResponse) Descriptor deprecated 

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

Deprecated: Use WatchNodeResponse.ProtoReflect.Descriptor instead.

func (*WatchNodeResponse) GetNode 

func (x *WatchNodeResponse) GetNode() *Node

func (*WatchNodeResponse) ProtoMessage 

func (*WatchNodeResponse) ProtoMessage()

func (*WatchNodeResponse) ProtoReflect 

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

func (*WatchNodeResponse) Reset 

func (x *WatchNodeResponse) Reset()

func (*WatchNodeResponse) String 

func (x *WatchNodeResponse) String() string

type WorkspaceRelativePath 

type WorkspaceRelativePath struct {

	// Workspace Id
	WsUuid string `protobuf:"bytes,1,opt,name=WsUuid,proto3" json:"WsUuid,omitempty"`
	// Workspace Label
	WsLabel string `protobuf:"bytes,2,opt,name=WsLabel,proto3" json:"WsLabel,omitempty"`
	// Relative Path inside workspace
	Path string `protobuf:"bytes,3,opt,name=Path,proto3" json:"Path,omitempty"`
	// Workspace slug
	WsSlug string `protobuf:"bytes,4,opt,name=WsSlug,proto3" json:"WsSlug,omitempty"`
	// Workspace Scope
	WsScope string `protobuf:"bytes,5,opt,name=WsScope,proto3" json:"WsScope,omitempty"`
	// contains filtered or unexported fields
}

Used in AppearsIn to signal a node is appearing in multiple workspaces in the current context

func (*WorkspaceRelativePath) Descriptor deprecated 

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

Deprecated: Use WorkspaceRelativePath.ProtoReflect.Descriptor instead.

func (*WorkspaceRelativePath) GetPath 

func (x *WorkspaceRelativePath) GetPath() string

func (*WorkspaceRelativePath) GetWsLabel 

func (x *WorkspaceRelativePath) GetWsLabel() string

func (*WorkspaceRelativePath) GetWsScope 

func (x *WorkspaceRelativePath) GetWsScope() string

func (*WorkspaceRelativePath) GetWsSlug 

func (x *WorkspaceRelativePath) GetWsSlug() string

func (*WorkspaceRelativePath) GetWsUuid 

func (x *WorkspaceRelativePath) GetWsUuid() string

func (*WorkspaceRelativePath) ProtoMessage 

func (*WorkspaceRelativePath) ProtoMessage()

func (*WorkspaceRelativePath) ProtoReflect 

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

func (*WorkspaceRelativePath) Reset 

func (x *WorkspaceRelativePath) Reset()

func (*WorkspaceRelativePath) String 

func (x *WorkspaceRelativePath) String() string

type WrappingStreamerResponse 

type WrappingStreamerResponse struct {

	// Types that are assignable to Data:
	//
	//	*WrappingStreamerResponse_ListNodesResponse
	//	*WrappingStreamerResponse_NodeChangeEvent
	Data  isWrappingStreamerResponse_Data `protobuf_oneof:"Data"`
	Error string                          `protobuf:"bytes,3,opt,name=Error,proto3" json:"Error,omitempty"`
	// contains filtered or unexported fields
}

func (*WrappingStreamerResponse) Descriptor deprecated 

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

Deprecated: Use WrappingStreamerResponse.ProtoReflect.Descriptor instead.

func (*WrappingStreamerResponse) GetData 

func (m *WrappingStreamerResponse) GetData() isWrappingStreamerResponse_Data

func (*WrappingStreamerResponse) GetError 

func (x *WrappingStreamerResponse) GetError() string

func (*WrappingStreamerResponse) GetListNodesResponse 

func (x *WrappingStreamerResponse) GetListNodesResponse() *ListNodesResponse

func (*WrappingStreamerResponse) GetNodeChangeEvent 

func (x *WrappingStreamerResponse) GetNodeChangeEvent() *NodeChangeEvent

func (*WrappingStreamerResponse) ProtoMessage 

func (*WrappingStreamerResponse) ProtoMessage()

func (*WrappingStreamerResponse) ProtoReflect 

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

func (*WrappingStreamerResponse) Reset 

func (x *WrappingStreamerResponse) Reset()

func (*WrappingStreamerResponse) String 

func (x *WrappingStreamerResponse) String() string

type WrappingStreamerResponse_ListNodesResponse 

type WrappingStreamerResponse_ListNodesResponse struct {
	ListNodesResponse *ListNodesResponse `protobuf:"bytes,1,opt,name=ListNodesResponse,proto3,oneof"`
}

type WrappingStreamerResponse_NodeChangeEvent 

type WrappingStreamerResponse_NodeChangeEvent struct {
	NodeChangeEvent *NodeChangeEvent `protobuf:"bytes,2,opt,name=NodeChangeEvent,proto3,oneof"`
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.