tree

package
v4.1.1 Latest Latest
Warning

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

 Go to latest Published: Mar 6, 2023 License: AGPL-3.0 Imports: 29 Imported by: 1

Documentation

Index

Constants

View Source 
const (
	MetaFilterGrep      = "grep"
	MetaFilterNoGrep    = "no-grep"
	MetaFilterForceGrep = "force-grep"
	MetaFilterTime      = "time"
	MetaFilterSize      = "size"
	MetaFilterETag      = "etag"
	MetaFilterDepth     = "depth"
)
View Source 
const (
	StatFlagDefault uint32 = iota
	StatFlagNone
	StatFlagFolderSize
	StatFlagFolderCounts
	StatFlagMetaMinimal

	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,
		},
	},
	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 DeregisterFileKeyManagerEnhancedServer 

func DeregisterFileKeyManagerEnhancedServer(s grpc.ServiceRegistrar, name string)

func DeregisterNodeChangesReceiverStreamerEnhancedServer added in v4.0.1 

func DeregisterNodeChangesReceiverStreamerEnhancedServer(s grpc.ServiceRegistrar, name string)

func DeregisterNodeChangesStreamerEnhancedServer 

func DeregisterNodeChangesStreamerEnhancedServer(s grpc.ServiceRegistrar, name string)

func DeregisterNodeContentReaderEnhancedServer 

func DeregisterNodeContentReaderEnhancedServer(s grpc.ServiceRegistrar, name string)

func DeregisterNodeContentWriterEnhancedServer 

func DeregisterNodeContentWriterEnhancedServer(s grpc.ServiceRegistrar, name string)

func DeregisterNodeEventsProviderEnhancedServer 

func DeregisterNodeEventsProviderEnhancedServer(s grpc.ServiceRegistrar, name string)

func DeregisterNodeProviderEnhancedServer 

func DeregisterNodeProviderEnhancedServer(s grpc.ServiceRegistrar, name string)

func DeregisterNodeProviderStreamerEnhancedServer 

func DeregisterNodeProviderStreamerEnhancedServer(s grpc.ServiceRegistrar, name string)

func DeregisterNodeReceiverEnhancedServer 

func DeregisterNodeReceiverEnhancedServer(s grpc.ServiceRegistrar, name string)

func DeregisterNodeReceiverStreamEnhancedServer 

func DeregisterNodeReceiverStreamEnhancedServer(s grpc.ServiceRegistrar, name string)

func DeregisterNodeVersionerEnhancedServer 

func DeregisterNodeVersionerEnhancedServer(s grpc.ServiceRegistrar, name string)

func DeregisterSearcherEnhancedServer 

func DeregisterSearcherEnhancedServer(s grpc.ServiceRegistrar, name string)

func DeregisterSessionIndexerEnhancedServer 

func DeregisterSessionIndexerEnhancedServer(s grpc.ServiceRegistrar, name string)

func DeregisterSyncChangesEnhancedServer 

func DeregisterSyncChangesEnhancedServer(s grpc.ServiceRegistrar, name string)

func IgnoreNodeForOutput 

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 NewStreamerMock 

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

func PredefineError 

func PredefineError(f ErrorThrower)

func RegisterFileKeyManagerEnhancedServer 

func RegisterFileKeyManagerEnhancedServer(s grpc.ServiceRegistrar, srv NamedFileKeyManagerServer)

func RegisterFileKeyManagerServer 

func RegisterFileKeyManagerServer(s grpc.ServiceRegistrar, srv FileKeyManagerServer)

func RegisterNodeChangesReceiverStreamerEnhancedServer added in v4.0.1 

func RegisterNodeChangesReceiverStreamerEnhancedServer(s grpc.ServiceRegistrar, srv NamedNodeChangesReceiverStreamerServer)

func RegisterNodeChangesReceiverStreamerServer added in v4.0.1 

func RegisterNodeChangesReceiverStreamerServer(s grpc.ServiceRegistrar, srv NodeChangesReceiverStreamerServer)

func RegisterNodeChangesStreamerEnhancedServer 

func RegisterNodeChangesStreamerEnhancedServer(s grpc.ServiceRegistrar, srv NamedNodeChangesStreamerServer)

func RegisterNodeChangesStreamerServer 

func RegisterNodeChangesStreamerServer(s grpc.ServiceRegistrar, srv NodeChangesStreamerServer)

func RegisterNodeContentReaderEnhancedServer 

func RegisterNodeContentReaderEnhancedServer(s grpc.ServiceRegistrar, srv NamedNodeContentReaderServer)

func RegisterNodeContentReaderServer 

func RegisterNodeContentReaderServer(s grpc.ServiceRegistrar, srv NodeContentReaderServer)

func RegisterNodeContentWriterEnhancedServer 

func RegisterNodeContentWriterEnhancedServer(s grpc.ServiceRegistrar, srv NamedNodeContentWriterServer)

func RegisterNodeContentWriterServer 

func RegisterNodeContentWriterServer(s grpc.ServiceRegistrar, srv NodeContentWriterServer)

func RegisterNodeEventsProviderEnhancedServer 

func RegisterNodeEventsProviderEnhancedServer(s grpc.ServiceRegistrar, srv NamedNodeEventsProviderServer)

func RegisterNodeEventsProviderServer 

func RegisterNodeEventsProviderServer(s grpc.ServiceRegistrar, srv NodeEventsProviderServer)

func RegisterNodeProviderEnhancedServer 

func RegisterNodeProviderEnhancedServer(s grpc.ServiceRegistrar, srv NamedNodeProviderServer)

func RegisterNodeProviderServer 

func RegisterNodeProviderServer(s grpc.ServiceRegistrar, srv NodeProviderServer)

func RegisterNodeProviderStreamerEnhancedServer 

func RegisterNodeProviderStreamerEnhancedServer(s grpc.ServiceRegistrar, srv NamedNodeProviderStreamerServer)

func RegisterNodeProviderStreamerServer 

func RegisterNodeProviderStreamerServer(s grpc.ServiceRegistrar, srv NodeProviderStreamerServer)

func RegisterNodeReceiverEnhancedServer 

func RegisterNodeReceiverEnhancedServer(s grpc.ServiceRegistrar, srv NamedNodeReceiverServer)

func RegisterNodeReceiverServer 

func RegisterNodeReceiverServer(s grpc.ServiceRegistrar, srv NodeReceiverServer)

func RegisterNodeReceiverStreamEnhancedServer 

func RegisterNodeReceiverStreamEnhancedServer(s grpc.ServiceRegistrar, srv NamedNodeReceiverStreamServer)

func RegisterNodeReceiverStreamServer 

func RegisterNodeReceiverStreamServer(s grpc.ServiceRegistrar, srv NodeReceiverStreamServer)

func RegisterNodeVersionerEnhancedServer 

func RegisterNodeVersionerEnhancedServer(s grpc.ServiceRegistrar, srv NamedNodeVersionerServer)

func RegisterNodeVersionerServer 

func RegisterNodeVersionerServer(s grpc.ServiceRegistrar, srv NodeVersionerServer)

func RegisterSearcherEnhancedServer 

func RegisterSearcherEnhancedServer(s grpc.ServiceRegistrar, srv NamedSearcherServer)

func RegisterSearcherServer 

func RegisterSearcherServer(s grpc.ServiceRegistrar, srv SearcherServer)

func RegisterSessionIndexerEnhancedServer 

func RegisterSessionIndexerEnhancedServer(s grpc.ServiceRegistrar, srv NamedSessionIndexerServer)

func RegisterSessionIndexerServer 

func RegisterSessionIndexerServer(s grpc.ServiceRegistrar, srv SessionIndexerServer)

func RegisterSyncChangesEnhancedServer 

func RegisterSyncChangesEnhancedServer(s grpc.ServiceRegistrar, srv NamedSyncChangesServer)

func RegisterSyncChangesServer 

func RegisterSyncChangesServer(s grpc.ServiceRegistrar, srv SyncChangesServer)

func ShouldError 

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

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

func (this *ChangeLog) Validate() error

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

func (*CloseSessionRequest) Validate 

func (this *CloseSessionRequest) Validate() error

type CloseSessionResponse 

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

func (*CloseSessionResponse) Descriptor deprecated 

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

Deprecated: Use CloseSessionResponse.ProtoReflect.Descriptor instead.

func (*CloseSessionResponse) GetSession 

func (x *CloseSessionResponse) GetSession() *IndexationSession

func (*CloseSessionResponse) ProtoMessage 

func (*CloseSessionResponse) ProtoMessage()

func (*CloseSessionResponse) ProtoReflect 

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

func (*CloseSessionResponse) Reset 

func (x *CloseSessionResponse) Reset()

func (*CloseSessionResponse) String 

func (x *CloseSessionResponse) String() string

func (*CloseSessionResponse) Validate 

func (this *CloseSessionResponse) Validate() error

type CreateNodeRequest 

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

Request / Responses Messages

func (*CreateNodeRequest) Descriptor deprecated 

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

Deprecated: Use CreateNodeRequest.ProtoReflect.Descriptor instead.

func (*CreateNodeRequest) GetIndexationSession 

func (x *CreateNodeRequest) GetIndexationSession() string

func (*CreateNodeRequest) GetNode 

func (x *CreateNodeRequest) GetNode() *Node

func (*CreateNodeRequest) GetSilent 

func (x *CreateNodeRequest) GetSilent() bool

func (*CreateNodeRequest) GetUpdateIfExists 

func (x *CreateNodeRequest) GetUpdateIfExists() bool

func (*CreateNodeRequest) ProtoMessage 

func (*CreateNodeRequest) ProtoMessage()

func (*CreateNodeRequest) ProtoReflect 

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

func (*CreateNodeRequest) Reset 

func (x *CreateNodeRequest) Reset()

func (*CreateNodeRequest) String 

func (x *CreateNodeRequest) String() string

func (*CreateNodeRequest) Validate 

func (this *CreateNodeRequest) Validate() error

type CreateNodeResponse 

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

func (*CreateNodeResponse) Descriptor deprecated 

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

Deprecated: Use CreateNodeResponse.ProtoReflect.Descriptor instead.

func (*CreateNodeResponse) GetNode 

func (x *CreateNodeResponse) GetNode() *Node

func (*CreateNodeResponse) GetSuccess 

func (x *CreateNodeResponse) GetSuccess() bool

func (*CreateNodeResponse) ProtoMessage 

func (*CreateNodeResponse) ProtoMessage()

func (*CreateNodeResponse) ProtoReflect 

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

func (*CreateNodeResponse) Reset 

func (x *CreateNodeResponse) Reset()

func (*CreateNodeResponse) String 

func (x *CreateNodeResponse) String() string

func (*CreateNodeResponse) Validate 

func (this *CreateNodeResponse) Validate() error

type CreateVersionRequest 

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

func (*CreateVersionRequest) Descriptor deprecated 

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

Deprecated: Use CreateVersionRequest.ProtoReflect.Descriptor instead.

func (*CreateVersionRequest) GetNode 

func (x *CreateVersionRequest) GetNode() *Node

func (*CreateVersionRequest) GetTriggerEvent 

func (x *CreateVersionRequest) GetTriggerEvent() *NodeChangeEvent

func (*CreateVersionRequest) ProtoMessage 

func (*CreateVersionRequest) ProtoMessage()

func (*CreateVersionRequest) ProtoReflect 

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

func (*CreateVersionRequest) Reset 

func (x *CreateVersionRequest) Reset()

func (*CreateVersionRequest) String 

func (x *CreateVersionRequest) String() string

func (*CreateVersionRequest) Validate 

func (this *CreateVersionRequest) Validate() error

type CreateVersionResponse 

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

func (*CreateVersionResponse) Descriptor deprecated 

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

Deprecated: Use CreateVersionResponse.ProtoReflect.Descriptor instead.

func (*CreateVersionResponse) GetVersion 

func (x *CreateVersionResponse) GetVersion() *ChangeLog

func (*CreateVersionResponse) ProtoMessage 

func (*CreateVersionResponse) ProtoMessage()

func (*CreateVersionResponse) ProtoReflect 

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

func (*CreateVersionResponse) Reset 

func (x *CreateVersionResponse) Reset()

func (*CreateVersionResponse) String 

func (x *CreateVersionResponse) String() string

func (*CreateVersionResponse) Validate 

func (this *CreateVersionResponse) Validate() error

type DeleteNodeRequest 

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

func (*DeleteNodeRequest) Descriptor deprecated 

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

Deprecated: Use DeleteNodeRequest.ProtoReflect.Descriptor instead.

func (*DeleteNodeRequest) GetIndexationSession 

func (x *DeleteNodeRequest) GetIndexationSession() string

func (*DeleteNodeRequest) GetNode 

func (x *DeleteNodeRequest) GetNode() *Node

func (*DeleteNodeRequest) GetSilent 

func (x *DeleteNodeRequest) GetSilent() bool

func (*DeleteNodeRequest) ProtoMessage 

func (*DeleteNodeRequest) ProtoMessage()

func (*DeleteNodeRequest) ProtoReflect 

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

func (*DeleteNodeRequest) Reset 

func (x *DeleteNodeRequest) Reset()

func (*DeleteNodeRequest) String 

func (x *DeleteNodeRequest) String() string

func (*DeleteNodeRequest) Validate 

func (this *DeleteNodeRequest) Validate() error

type DeleteNodeResponse 

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

func (*DeleteNodeResponse) Descriptor deprecated 

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

Deprecated: Use DeleteNodeResponse.ProtoReflect.Descriptor instead.

func (*DeleteNodeResponse) GetSuccess 

func (x *DeleteNodeResponse) GetSuccess() bool

func (*DeleteNodeResponse) ProtoMessage 

func (*DeleteNodeResponse) ProtoMessage()

func (*DeleteNodeResponse) ProtoReflect 

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

func (*DeleteNodeResponse) Reset 

func (x *DeleteNodeResponse) Reset()

func (*DeleteNodeResponse) String 

func (x *DeleteNodeResponse) String() string

func (*DeleteNodeResponse) Validate 

func (this *DeleteNodeResponse) Validate() error

type ErrorThrower 

type 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 FileKeyManagerEnhancedServer 

type FileKeyManagerEnhancedServer map[string]NamedFileKeyManagerServer

func (FileKeyManagerEnhancedServer) GetEncryptionKey 

func (m FileKeyManagerEnhancedServer) GetEncryptionKey(ctx context.Context, r *GetEncryptionKeyRequest) (*GetEncryptionKeyResponse, error)

type FileKeyManagerServer 

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

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

type FileKeyManagerStub 

type FileKeyManagerStub struct {
	FileKeyManagerServer
}

func (*FileKeyManagerStub) Invoke 

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

func (*FileKeyManagerStub) NewStream 

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

type Flags added in v4.0.1 

type Flags []uint32

func StatFlags added in v4.0.1 

func StatFlags(flags []uint32) Flags

func StatFlagsFromString added in v4.1.1 

func StatFlagsFromString(s string) Flags

StatFlagsFromString parses a string of flags separated by dashes

func (Flags) AsMeta added in v4.1.1 

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

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

func (Flags) FolderCounts added in v4.0.1 

func (f Flags) FolderCounts() bool

func (Flags) Metas added in v4.0.1 

func (f Flags) Metas() bool

func (Flags) MinimalMetas added in v4.1.1 

func (f Flags) MinimalMetas() bool

func (Flags) String added in v4.1.1 

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

func (*FlushSessionRequest) Validate 

func (this *FlushSessionRequest) Validate() error

type FlushSessionResponse 

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

func (*FlushSessionResponse) Descriptor deprecated 

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

Deprecated: Use FlushSessionResponse.ProtoReflect.Descriptor instead.

func (*FlushSessionResponse) GetSession 

func (x *FlushSessionResponse) GetSession() *IndexationSession

func (*FlushSessionResponse) ProtoMessage 

func (*FlushSessionResponse) ProtoMessage()

func (*FlushSessionResponse) ProtoReflect 

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

func (*FlushSessionResponse) Reset 

func (x *FlushSessionResponse) Reset()

func (*FlushSessionResponse) String 

func (x *FlushSessionResponse) String() string

func (*FlushSessionResponse) Validate 

func (this *FlushSessionResponse) Validate() error

type 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

func (*GeoPoint) Validate 

func (this *GeoPoint) Validate() error

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

func (*GeoQuery) Validate 

func (this *GeoQuery) Validate() error

type GetEncryptionKeyRequest 

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

func (*GetEncryptionKeyRequest) Descriptor deprecated 

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

Deprecated: Use GetEncryptionKeyRequest.ProtoReflect.Descriptor instead.

func (*GetEncryptionKeyRequest) GetCreate 

func (x *GetEncryptionKeyRequest) GetCreate() bool

func (*GetEncryptionKeyRequest) GetNode 

func (x *GetEncryptionKeyRequest) GetNode() *Node

func (*GetEncryptionKeyRequest) GetPassword 

func (x *GetEncryptionKeyRequest) GetPassword() string

func (*GetEncryptionKeyRequest) GetUser 

func (x *GetEncryptionKeyRequest) GetUser() string

func (*GetEncryptionKeyRequest) ProtoMessage 

func (*GetEncryptionKeyRequest) ProtoMessage()

func (*GetEncryptionKeyRequest) ProtoReflect 

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

func (*GetEncryptionKeyRequest) Reset 

func (x *GetEncryptionKeyRequest) Reset()

func (*GetEncryptionKeyRequest) String 

func (x *GetEncryptionKeyRequest) String() string

func (*GetEncryptionKeyRequest) Validate 

func (this *GetEncryptionKeyRequest) Validate() error

type GetEncryptionKeyResponse 

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

func (*GetEncryptionKeyResponse) Descriptor deprecated 

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

Deprecated: Use GetEncryptionKeyResponse.ProtoReflect.Descriptor instead.

func (*GetEncryptionKeyResponse) GetKey 

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

func (*GetEncryptionKeyResponse) ProtoMessage 

func (*GetEncryptionKeyResponse) ProtoMessage()

func (*GetEncryptionKeyResponse) ProtoReflect 

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

func (*GetEncryptionKeyResponse) Reset 

func (x *GetEncryptionKeyResponse) Reset()

func (*GetEncryptionKeyResponse) String 

func (x *GetEncryptionKeyResponse) String() string

func (*GetEncryptionKeyResponse) Validate 

func (this *GetEncryptionKeyResponse) Validate() error

type HeadVersionRequest 

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

func (*HeadVersionRequest) Descriptor deprecated 

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

Deprecated: Use HeadVersionRequest.ProtoReflect.Descriptor instead.

func (*HeadVersionRequest) GetNode 

func (x *HeadVersionRequest) GetNode() *Node

func (*HeadVersionRequest) GetVersionId 

func (x *HeadVersionRequest) GetVersionId() string

func (*HeadVersionRequest) ProtoMessage 

func (*HeadVersionRequest) ProtoMessage()

func (*HeadVersionRequest) ProtoReflect 

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

func (*HeadVersionRequest) Reset 

func (x *HeadVersionRequest) Reset()

func (*HeadVersionRequest) String 

func (x *HeadVersionRequest) String() string

func (*HeadVersionRequest) Validate 

func (this *HeadVersionRequest) Validate() error

type HeadVersionResponse 

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

func (*HeadVersionResponse) Descriptor deprecated 

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

Deprecated: Use HeadVersionResponse.ProtoReflect.Descriptor instead.

func (*HeadVersionResponse) GetVersion 

func (x *HeadVersionResponse) GetVersion() *ChangeLog

func (*HeadVersionResponse) ProtoMessage 

func (*HeadVersionResponse) ProtoMessage()

func (*HeadVersionResponse) ProtoReflect 

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

func (*HeadVersionResponse) Reset 

func (x *HeadVersionResponse) Reset()

func (*HeadVersionResponse) String 

func (x *HeadVersionResponse) String() string

func (*HeadVersionResponse) Validate 

func (this *HeadVersionResponse) Validate() error

type IndexEvent 

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

func (*IndexEvent) Descriptor deprecated 

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

Deprecated: Use IndexEvent.ProtoReflect.Descriptor instead.

func (*IndexEvent) GetDataSourceName 

func (x *IndexEvent) GetDataSourceName() string

func (*IndexEvent) GetErrorDetected 

func (x *IndexEvent) GetErrorDetected() bool

func (*IndexEvent) GetErrorPath 

func (x *IndexEvent) GetErrorPath() string

func (*IndexEvent) GetSessionForceClose 

func (x *IndexEvent) GetSessionForceClose() string

func (*IndexEvent) ProtoMessage 

func (*IndexEvent) ProtoMessage()

func (*IndexEvent) ProtoReflect 

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

func (*IndexEvent) Reset 

func (x *IndexEvent) Reset()

func (*IndexEvent) String 

func (x *IndexEvent) String() string

func (*IndexEvent) Validate 

func (this *IndexEvent) Validate() error

type IndexableNode 

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

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

func NewMemIndexableNode 

func NewMemIndexableNode(n *Node) *IndexableNode

func (*IndexableNode) BleveType 

func (i *IndexableNode) BleveType() string

func (*IndexableNode) IndexID 

func (i *IndexableNode) IndexID() string

IndexID implements IndexIDProvider interface

func (*IndexableNode) MemLoad 

func (i *IndexableNode) MemLoad()

type IndexationOperation 

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

func (*IndexationOperation) Descriptor deprecated 

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

Deprecated: Use IndexationOperation.ProtoReflect.Descriptor instead.

func (*IndexationOperation) GetCursor 

func (x *IndexationOperation) GetCursor() int64

func (*IndexationOperation) GetDescription 

func (x *IndexationOperation) GetDescription() string

func (*IndexationOperation) GetSessionUuid 

func (x *IndexationOperation) GetSessionUuid() string

func (*IndexationOperation) ProtoMessage 

func (*IndexationOperation) ProtoMessage()

func (*IndexationOperation) ProtoReflect 

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

func (*IndexationOperation) Reset 

func (x *IndexationOperation) Reset()

func (*IndexationOperation) String 

func (x *IndexationOperation) String() string

func (*IndexationOperation) Validate 

func (this *IndexationOperation) Validate() error

type IndexationSession 

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

func (*IndexationSession) Descriptor deprecated 

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

Deprecated: Use IndexationSession.ProtoReflect.Descriptor instead.

func (*IndexationSession) GetCurrentOperationCount 

func (x *IndexationSession) GetCurrentOperationCount() int64

func (*IndexationSession) GetDescription 

func (x *IndexationSession) GetDescription() string

func (*IndexationSession) GetExpectedOperationsCount 

func (x *IndexationSession) GetExpectedOperationsCount() int64

func (*IndexationSession) GetRootNode 

func (x *IndexationSession) GetRootNode() *Node

func (*IndexationSession) GetSilent 

func (x *IndexationSession) GetSilent() bool

func (*IndexationSession) GetUuid 

func (x *IndexationSession) GetUuid() string

func (*IndexationSession) ProtoMessage 

func (*IndexationSession) ProtoMessage()

func (*IndexationSession) ProtoReflect 

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

func (*IndexationSession) Reset 

func (x *IndexationSession) Reset()

func (*IndexationSession) String 

func (x *IndexationSession) String() string

func (*IndexationSession) Validate 

func (this *IndexationSession) Validate() error

type ListNodesRequest 

type ListNodesRequest struct {

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

func (*ListNodesRequest) Descriptor deprecated 

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

Deprecated: Use ListNodesRequest.ProtoReflect.Descriptor instead.

func (*ListNodesRequest) GetAncestors 

func (x *ListNodesRequest) GetAncestors() bool

func (*ListNodesRequest) GetFilterType 

func (x *ListNodesRequest) GetFilterType() NodeType

func (*ListNodesRequest) GetLimit 

func (x *ListNodesRequest) GetLimit() int64

func (*ListNodesRequest) GetNode 

func (x *ListNodesRequest) GetNode() *Node

func (*ListNodesRequest) GetOffset 

func (x *ListNodesRequest) GetOffset() int64

func (*ListNodesRequest) GetRecursive 

func (x *ListNodesRequest) GetRecursive() bool

func (*ListNodesRequest) GetStatFlags added in v4.0.1 

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

func (*ListNodesRequest) GetWithCommits 

func (x *ListNodesRequest) GetWithCommits() bool

func (*ListNodesRequest) GetWithVersions 

func (x *ListNodesRequest) GetWithVersions() bool

func (*ListNodesRequest) ProtoMessage 

func (*ListNodesRequest) ProtoMessage()

func (*ListNodesRequest) ProtoReflect 

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

func (*ListNodesRequest) Reset 

func (x *ListNodesRequest) Reset()

func (*ListNodesRequest) String 

func (x *ListNodesRequest) String() string

func (*ListNodesRequest) Validate 

func (this *ListNodesRequest) Validate() error

type ListNodesResponse 

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

func (*ListNodesResponse) Descriptor deprecated 

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

Deprecated: Use ListNodesResponse.ProtoReflect.Descriptor instead.

func (*ListNodesResponse) GetNode 

func (x *ListNodesResponse) GetNode() *Node

func (*ListNodesResponse) ProtoMessage 

func (*ListNodesResponse) ProtoMessage()

func (*ListNodesResponse) ProtoReflect 

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

func (*ListNodesResponse) Reset 

func (x *ListNodesResponse) Reset()

func (*ListNodesResponse) String 

func (x *ListNodesResponse) String() string

func (*ListNodesResponse) Validate 

func (this *ListNodesResponse) Validate() error

type ListVersionsRequest 

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

func (*ListVersionsRequest) Descriptor deprecated 

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

Deprecated: Use ListVersionsRequest.ProtoReflect.Descriptor instead.

func (*ListVersionsRequest) GetNode 

func (x *ListVersionsRequest) GetNode() *Node

func (*ListVersionsRequest) ProtoMessage 

func (*ListVersionsRequest) ProtoMessage()

func (*ListVersionsRequest) ProtoReflect 

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

func (*ListVersionsRequest) Reset 

func (x *ListVersionsRequest) Reset()

func (*ListVersionsRequest) String 

func (x *ListVersionsRequest) String() string

func (*ListVersionsRequest) Validate 

func (this *ListVersionsRequest) Validate() error

type ListVersionsResponse 

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

func (*ListVersionsResponse) Descriptor deprecated 

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

Deprecated: Use ListVersionsResponse.ProtoReflect.Descriptor instead.

func (*ListVersionsResponse) GetVersion 

func (x *ListVersionsResponse) GetVersion() *ChangeLog

func (*ListVersionsResponse) ProtoMessage 

func (*ListVersionsResponse) ProtoMessage()

func (*ListVersionsResponse) ProtoReflect 

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

func (*ListVersionsResponse) Reset 

func (x *ListVersionsResponse) Reset()

func (*ListVersionsResponse) String 

func (x *ListVersionsResponse) String() string

func (*ListVersionsResponse) Validate 

func (this *ListVersionsResponse) Validate() error

type MetaFilter 

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

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

func NewMetaFilter 

func NewMetaFilter(node *Node) *MetaFilter

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

func (*MetaFilter) HasSQLFilters added in v4.0.1 

func (m *MetaFilter) HasSQLFilters() bool

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

func (*MetaFilter) LimitDepth 

func (m *MetaFilter) LimitDepth() int

LimitDepth returns an optional depth limitation.

func (*MetaFilter) Match 

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

Match checks node results against conditions.

func (*MetaFilter) MatchForceGrep added in v4.0.1 

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

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

func (*MetaFilter) Parse 

func (m *MetaFilter) Parse() bool

Parse loads the filter keys.

func (*MetaFilter) ParseType added in v4.0.1 

func (m *MetaFilter) ParseType(t NodeType)

ParseType register a node filter type

func (*MetaFilter) Where added in v4.0.1 

func (m *MetaFilter) Where() (where string, args []interface{})

Where transforms registered conditions into a set of SQL statement (joined by AND).

type NamedFileKeyManagerServer 

type NamedFileKeyManagerServer interface {
	FileKeyManagerServer
	Name() string
}

type NamedNodeChangesReceiverStreamerServer added in v4.0.1 

type NamedNodeChangesReceiverStreamerServer interface {
	NodeChangesReceiverStreamerServer
	Name() string
}

type NamedNodeChangesStreamerServer 

type NamedNodeChangesStreamerServer interface {
	NodeChangesStreamerServer
	Name() string
}

type NamedNodeContentReaderServer 

type NamedNodeContentReaderServer interface {
	NodeContentReaderServer
	Name() string
}

type NamedNodeContentWriterServer 

type NamedNodeContentWriterServer interface {
	NodeContentWriterServer
	Name() string
}

type NamedNodeEventsProviderServer 

type NamedNodeEventsProviderServer interface {
	NodeEventsProviderServer
	Name() string
}

type NamedNodeProviderServer 

type NamedNodeProviderServer interface {
	NodeProviderServer
	Name() string
}

type NamedNodeProviderStreamerServer 

type NamedNodeProviderStreamerServer interface {
	NodeProviderStreamerServer
	Name() string
}

type NamedNodeReceiverServer 

type NamedNodeReceiverServer interface {
	NodeReceiverServer
	Name() string
}

type NamedNodeReceiverStreamServer 

type NamedNodeReceiverStreamServer interface {
	NodeReceiverStreamServer
	Name() string
}

type NamedNodeVersionerServer 

type NamedNodeVersionerServer interface {
	NodeVersionerServer
	Name() string
}

type NamedSearcherServer 

type NamedSearcherServer interface {
	SearcherServer
	Name() string
}

type NamedSessionIndexerServer 

type NamedSessionIndexerServer interface {
	SessionIndexerServer
	Name() string
}

type NamedSyncChangesServer 

type NamedSyncChangesServer interface {
	SyncChangesServer
	Name() string
}

type Node 

type Node struct {

	// ------------------------------------
	// Core identification of the node
	// ------------------------------------
	Uuid string   `protobuf:"bytes,1,opt,name=Uuid,proto3" json:"Uuid,omitempty"`
	Path string   `protobuf:"bytes,2,opt,name=Path,proto3" json:"Path,omitempty"`
	Type NodeType `protobuf:"varint,3,opt,name=Type,proto3,enum=tree.NodeType" json:"Type,omitempty"`
	// Size of the file, or cumulated size of folder
	Size int64 `protobuf:"varint,4,opt,name=Size,proto3" json:"Size,omitempty"`
	// Last modification Timestamp
	MTime int64 `protobuf:"varint,5,opt,name=MTime,proto3" json:"MTime,omitempty"`
	// Permission mode, like 0777
	Mode int32 `protobuf:"varint,6,opt,name=Mode,proto3" json:"Mode,omitempty"`
	// Hash of the content if node is a LEAF, Uuid or
	Etag string `protobuf:"bytes,7,opt,name=Etag,proto3" json:"Etag,omitempty"`
	// List of successive commits
	Commits []*ChangeLog `protobuf:"bytes,9,rep,name=Commits,proto3" json:"Commits,omitempty"`
	// ------------------------------------
	// Then a free K => V representation of any kind of metadata
	// ------------------------------------
	MetaStore map[string]string `` /* 159-byte string literal not displayed */
	// Can be used for output when node is appearing in multiple workspaces
	AppearsIn []*WorkspaceRelativePath `protobuf:"bytes,10,rep,name=AppearsIn,proto3" json:"AppearsIn,omitempty"`
	// contains filtered or unexported fields
}

func (*Node) AllMetaDeserialized 

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

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

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

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

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

func (x *Node) String() string

func (*Node) Validate 

func (this *Node) Validate() error

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

func (this *NodeChangeEvent) Validate() error

func (*NodeChangeEvent) Zap 

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

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

type NodeChangeEvent_EventType 

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

func (NodeChangeEvent_EventType) Descriptor 

func (NodeChangeEvent_EventType) Descriptor() protoreflect.EnumDescriptor

func (NodeChangeEvent_EventType) Enum 

func (x NodeChangeEvent_EventType) Enum() *NodeChangeEvent_EventType

func (NodeChangeEvent_EventType) EnumDescriptor deprecated 

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

Deprecated: Use NodeChangeEvent_EventType.Descriptor instead.

func (NodeChangeEvent_EventType) Number 

func (x NodeChangeEvent_EventType) Number() protoreflect.EnumNumber

func (NodeChangeEvent_EventType) String 

func (x NodeChangeEvent_EventType) String() string

func (NodeChangeEvent_EventType) Type 

func (NodeChangeEvent_EventType) Type() protoreflect.EnumType

type NodeChangesReceiverStreamerClient added in v4.0.1 

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 added in v4.0.1 

func NewNodeChangesReceiverStreamerClient(cc grpc.ClientConnInterface) NodeChangesReceiverStreamerClient

type NodeChangesReceiverStreamerEnhancedServer added in v4.0.1 

type NodeChangesReceiverStreamerEnhancedServer map[string]NamedNodeChangesReceiverStreamerServer

func (NodeChangesReceiverStreamerEnhancedServer) PostNodeChanges added in v4.0.1 

func (m NodeChangesReceiverStreamerEnhancedServer) PostNodeChanges(s NodeChangesReceiverStreamer_PostNodeChangesServer) error

type NodeChangesReceiverStreamerServer added in v4.0.1 

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 added in v4.0.1 

type NodeChangesReceiverStreamerStub struct {
	NodeChangesReceiverStreamerServer
}

func (*NodeChangesReceiverStreamerStub) Invoke added in v4.0.1 

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

func (*NodeChangesReceiverStreamerStub) NewStream added in v4.0.1 

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

type NodeChangesReceiverStreamerStub_PostNodeChangesStreamer added in v4.0.1 

type NodeChangesReceiverStreamerStub_PostNodeChangesStreamer struct {
	stubs.BidirServerStreamerCore
}

func (*NodeChangesReceiverStreamerStub_PostNodeChangesStreamer) Recv added in v4.0.1 

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

func (*NodeChangesReceiverStreamerStub_PostNodeChangesStreamer) Send added in v4.0.1 

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

type NodeChangesReceiverStreamer_PostNodeChangesClient added in v4.0.1 

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

type NodeChangesReceiverStreamer_PostNodeChangesServer added in v4.0.1 

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 NodeChangesStreamerEnhancedServer 

type NodeChangesStreamerEnhancedServer map[string]NamedNodeChangesStreamerServer

func (NodeChangesStreamerEnhancedServer) StreamChanges 

func (m NodeChangesStreamerEnhancedServer) StreamChanges(r *StreamChangesRequest, s NodeChangesStreamer_StreamChangesServer) error

type NodeChangesStreamerServer 

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

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

type NodeChangesStreamerStub 

type NodeChangesStreamerStub struct {
	NodeChangesStreamerServer
}

func (*NodeChangesStreamerStub) Invoke 

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

func (*NodeChangesStreamerStub) NewStream 

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

type NodeChangesStreamerStub_StreamChangesStreamer 

type NodeChangesStreamerStub_StreamChangesStreamer struct {
	stubs.ClientServerStreamerCore
}

func (*NodeChangesStreamerStub_StreamChangesStreamer) Send 

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

type NodeChangesStreamer_StreamChangesClient 

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

type NodeChangesStreamer_StreamChangesServer 

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

type NodeContentReaderClient 

type NodeContentReaderClient interface {
}

NodeContentReaderClient is the client API for NodeContentReader service.

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

func NewNodeContentReaderClient 

func NewNodeContentReaderClient(cc grpc.ClientConnInterface) NodeContentReaderClient

type NodeContentReaderEnhancedServer 

type NodeContentReaderEnhancedServer map[string]NamedNodeContentReaderServer

type NodeContentReaderServer 

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

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

type NodeContentReaderStub 

type NodeContentReaderStub struct {
	NodeContentReaderServer
}

func (*NodeContentReaderStub) Invoke 

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

func (*NodeContentReaderStub) NewStream 

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

type NodeContentWriterClient 

type NodeContentWriterClient interface {
}

NodeContentWriterClient is the client API for NodeContentWriter service.

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

func NewNodeContentWriterClient 

func NewNodeContentWriterClient(cc grpc.ClientConnInterface) NodeContentWriterClient

type NodeContentWriterEnhancedServer 

type NodeContentWriterEnhancedServer map[string]NamedNodeContentWriterServer

type NodeContentWriterServer 

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

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

type NodeContentWriterStub 

type NodeContentWriterStub struct {
	NodeContentWriterServer
}

func (*NodeContentWriterStub) Invoke 

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

func (*NodeContentWriterStub) NewStream 

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

type NodeEventsProviderClient 

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

NodeEventsProviderClient is the client API for NodeEventsProvider service.

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

func NewNodeEventsProviderClient 

func NewNodeEventsProviderClient(cc grpc.ClientConnInterface) NodeEventsProviderClient

type NodeEventsProviderEnhancedServer 

type NodeEventsProviderEnhancedServer map[string]NamedNodeEventsProviderServer

func (NodeEventsProviderEnhancedServer) WatchNode 

func (m NodeEventsProviderEnhancedServer) WatchNode(r *WatchNodeRequest, s NodeEventsProvider_WatchNodeServer) error

type NodeEventsProviderServer 

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

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

type NodeEventsProviderStub 

type NodeEventsProviderStub struct {
	NodeEventsProviderServer
}

func (*NodeEventsProviderStub) Invoke 

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

func (*NodeEventsProviderStub) NewStream 

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

type NodeEventsProviderStub_WatchNodeStreamer 

type NodeEventsProviderStub_WatchNodeStreamer struct {
	stubs.ClientServerStreamerCore
}

func (*NodeEventsProviderStub_WatchNodeStreamer) Send 

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

type NodeEventsProvider_WatchNodeClient 

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

type NodeEventsProvider_WatchNodeServer 

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

type NodeProviderClient 

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

NodeProviderClient is the client API for NodeProvider service.

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

func NewNodeProviderClient 

func NewNodeProviderClient(cc grpc.ClientConnInterface) NodeProviderClient

type NodeProviderEnhancedServer 

type NodeProviderEnhancedServer map[string]NamedNodeProviderServer

func (NodeProviderEnhancedServer) ListNodes 

func (m NodeProviderEnhancedServer) ListNodes(r *ListNodesRequest, s NodeProvider_ListNodesServer) error

func (NodeProviderEnhancedServer) ReadNode 

func (m NodeProviderEnhancedServer) ReadNode(ctx context.Context, r *ReadNodeRequest) (*ReadNodeResponse, error)

type NodeProviderMock 

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 NodeProviderStreamerEnhancedServer 

type NodeProviderStreamerEnhancedServer map[string]NamedNodeProviderStreamerServer

func (NodeProviderStreamerEnhancedServer) ReadNodeStream 

func (m NodeProviderStreamerEnhancedServer) ReadNodeStream(s NodeProviderStreamer_ReadNodeStreamServer) error

type NodeProviderStreamerServer 

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

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

type NodeProviderStreamerStub 

type NodeProviderStreamerStub struct {
	NodeProviderStreamerServer
}

func (*NodeProviderStreamerStub) Invoke 

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

func (*NodeProviderStreamerStub) NewStream 

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

type NodeProviderStreamerStub_ReadNodeStreamStreamer 

type NodeProviderStreamerStub_ReadNodeStreamStreamer struct {
	stubs.BidirServerStreamerCore
}

func (*NodeProviderStreamerStub_ReadNodeStreamStreamer) Recv 

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

func (*NodeProviderStreamerStub_ReadNodeStreamStreamer) Send 

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

type NodeProviderStreamer_ReadNodeStreamClient 

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

type NodeProviderStreamer_ReadNodeStreamServer 

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

type NodeProviderStub 

type NodeProviderStub struct {
	NodeProviderServer
}

func (*NodeProviderStub) Invoke 

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

func (*NodeProviderStub) NewStream 

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

type NodeProviderStub_ListNodesStreamer 

type NodeProviderStub_ListNodesStreamer struct {
	stubs.ClientServerStreamerCore
}

func (*NodeProviderStub_ListNodesStreamer) Send 

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

type NodeProvider_ListNodesClient 

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

type NodeProvider_ListNodesServer 

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

type NodeReceiverClient 

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

NodeReceiverClient is the client API for NodeReceiver service.

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

func NewNodeReceiverClient 

func NewNodeReceiverClient(cc grpc.ClientConnInterface) NodeReceiverClient

type NodeReceiverEnhancedServer 

type NodeReceiverEnhancedServer map[string]NamedNodeReceiverServer

func (NodeReceiverEnhancedServer) CreateNode 

func (m NodeReceiverEnhancedServer) CreateNode(ctx context.Context, r *CreateNodeRequest) (*CreateNodeResponse, error)

func (NodeReceiverEnhancedServer) DeleteNode 

func (m NodeReceiverEnhancedServer) DeleteNode(ctx context.Context, r *DeleteNodeRequest) (*DeleteNodeResponse, error)

func (NodeReceiverEnhancedServer) UpdateNode 

func (m NodeReceiverEnhancedServer) UpdateNode(ctx context.Context, r *UpdateNodeRequest) (*UpdateNodeResponse, error)

type NodeReceiverMock 

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 NodeReceiverStreamEnhancedServer 

type NodeReceiverStreamEnhancedServer map[string]NamedNodeReceiverStreamServer

func (NodeReceiverStreamEnhancedServer) CreateNodeStream 

func (m NodeReceiverStreamEnhancedServer) CreateNodeStream(s NodeReceiverStream_CreateNodeStreamServer) error

func (NodeReceiverStreamEnhancedServer) DeleteNodeStream 

func (m NodeReceiverStreamEnhancedServer) DeleteNodeStream(s NodeReceiverStream_DeleteNodeStreamServer) error

func (NodeReceiverStreamEnhancedServer) UpdateNodeStream 

func (m NodeReceiverStreamEnhancedServer) UpdateNodeStream(s NodeReceiverStream_UpdateNodeStreamServer) error

type NodeReceiverStreamServer 

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

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

type NodeReceiverStreamStub 

type NodeReceiverStreamStub struct {
	NodeReceiverStreamServer
}

func (*NodeReceiverStreamStub) Invoke 

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

func (*NodeReceiverStreamStub) NewStream 

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

type NodeReceiverStreamStub_CreateNodeStreamStreamer 

type NodeReceiverStreamStub_CreateNodeStreamStreamer struct {
	stubs.BidirServerStreamerCore
}

func (*NodeReceiverStreamStub_CreateNodeStreamStreamer) Recv 

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

func (*NodeReceiverStreamStub_CreateNodeStreamStreamer) Send 

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

type NodeReceiverStreamStub_DeleteNodeStreamStreamer 

type NodeReceiverStreamStub_DeleteNodeStreamStreamer struct {
	stubs.BidirServerStreamerCore
}

func (*NodeReceiverStreamStub_DeleteNodeStreamStreamer) Recv 

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

func (*NodeReceiverStreamStub_DeleteNodeStreamStreamer) Send 

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

type NodeReceiverStreamStub_UpdateNodeStreamStreamer 

type NodeReceiverStreamStub_UpdateNodeStreamStreamer struct {
	stubs.BidirServerStreamerCore
}

func (*NodeReceiverStreamStub_UpdateNodeStreamStreamer) Recv 

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

func (*NodeReceiverStreamStub_UpdateNodeStreamStreamer) Send 

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

type NodeReceiverStream_CreateNodeStreamClient 

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

type NodeReceiverStream_CreateNodeStreamServer 

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

type NodeReceiverStream_DeleteNodeStreamClient 

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

type NodeReceiverStream_DeleteNodeStreamServer 

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

type NodeReceiverStream_UpdateNodeStreamClient 

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

type NodeReceiverStream_UpdateNodeStreamServer 

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

type NodeReceiverStub 

type NodeReceiverStub struct {
	NodeReceiverServer
}

func (*NodeReceiverStub) Invoke 

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

func (*NodeReceiverStub) NewStream 

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

type NodeType 

type NodeType int32

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

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

NodeVersionerClient is the client API for NodeVersioner service.

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

func NewNodeVersionerClient 

func NewNodeVersionerClient(cc grpc.ClientConnInterface) NodeVersionerClient

type NodeVersionerEnhancedServer 

type NodeVersionerEnhancedServer map[string]NamedNodeVersionerServer

func (NodeVersionerEnhancedServer) CreateVersion 

func (m NodeVersionerEnhancedServer) CreateVersion(ctx context.Context, r *CreateVersionRequest) (*CreateVersionResponse, error)

func (NodeVersionerEnhancedServer) HeadVersion 

func (m NodeVersionerEnhancedServer) HeadVersion(ctx context.Context, r *HeadVersionRequest) (*HeadVersionResponse, error)

func (NodeVersionerEnhancedServer) ListVersions 

func (m NodeVersionerEnhancedServer) ListVersions(r *ListVersionsRequest, s NodeVersioner_ListVersionsServer) error

func (NodeVersionerEnhancedServer) PruneVersions 

func (m NodeVersionerEnhancedServer) PruneVersions(ctx context.Context, r *PruneVersionsRequest) (*PruneVersionsResponse, error)

func (NodeVersionerEnhancedServer) StoreVersion 

func (m NodeVersionerEnhancedServer) StoreVersion(ctx context.Context, r *StoreVersionRequest) (*StoreVersionResponse, error)

type NodeVersionerServer 

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

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

type NodeVersionerStub 

type NodeVersionerStub struct {
	NodeVersionerServer
}

func (*NodeVersionerStub) Invoke 

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

func (*NodeVersionerStub) NewStream 

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

type NodeVersionerStub_ListVersionsStreamer 

type NodeVersionerStub_ListVersionsStreamer struct {
	stubs.ClientServerStreamerCore
}

func (*NodeVersionerStub_ListVersionsStreamer) Send 

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

type NodeVersioner_ListVersionsClient 

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

type NodeVersioner_ListVersionsServer 

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

type OpenSessionRequest 

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

func (*OpenSessionRequest) Descriptor deprecated 

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

Deprecated: Use OpenSessionRequest.ProtoReflect.Descriptor instead.

func (*OpenSessionRequest) GetSession 

func (x *OpenSessionRequest) GetSession() *IndexationSession

func (*OpenSessionRequest) ProtoMessage 

func (*OpenSessionRequest) ProtoMessage()

func (*OpenSessionRequest) ProtoReflect 

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

func (*OpenSessionRequest) Reset 

func (x *OpenSessionRequest) Reset()

func (*OpenSessionRequest) String 

func (x *OpenSessionRequest) String() string

func (*OpenSessionRequest) Validate 

func (this *OpenSessionRequest) Validate() error

type OpenSessionResponse 

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

func (*OpenSessionResponse) Descriptor deprecated 

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

Deprecated: Use OpenSessionResponse.ProtoReflect.Descriptor instead.

func (*OpenSessionResponse) GetSession 

func (x *OpenSessionResponse) GetSession() *IndexationSession

func (*OpenSessionResponse) ProtoMessage 

func (*OpenSessionResponse) ProtoMessage()

func (*OpenSessionResponse) ProtoReflect 

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

func (*OpenSessionResponse) Reset 

func (x *OpenSessionResponse) Reset()

func (*OpenSessionResponse) String 

func (x *OpenSessionResponse) String() string

func (*OpenSessionResponse) Validate 

func (this *OpenSessionResponse) Validate() error

type PruneVersionsRequest 

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

func (*PruneVersionsRequest) Descriptor deprecated 

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

Deprecated: Use PruneVersionsRequest.ProtoReflect.Descriptor instead.

func (*PruneVersionsRequest) GetAllDeletedNodes 

func (x *PruneVersionsRequest) GetAllDeletedNodes() bool

func (*PruneVersionsRequest) GetUniqueNode 

func (x *PruneVersionsRequest) GetUniqueNode() *Node

func (*PruneVersionsRequest) ProtoMessage 

func (*PruneVersionsRequest) ProtoMessage()

func (*PruneVersionsRequest) ProtoReflect 

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

func (*PruneVersionsRequest) Reset 

func (x *PruneVersionsRequest) Reset()

func (*PruneVersionsRequest) String 

func (x *PruneVersionsRequest) String() string

func (*PruneVersionsRequest) Validate 

func (this *PruneVersionsRequest) Validate() error

type PruneVersionsResponse 

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

func (*PruneVersionsResponse) Descriptor deprecated 

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

Deprecated: Use PruneVersionsResponse.ProtoReflect.Descriptor instead.

func (*PruneVersionsResponse) GetDeletedVersions 

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

func (*PruneVersionsResponse) ProtoMessage 

func (*PruneVersionsResponse) ProtoMessage()

func (*PruneVersionsResponse) ProtoReflect 

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

func (*PruneVersionsResponse) Reset 

func (x *PruneVersionsResponse) Reset()

func (*PruneVersionsResponse) String 

func (x *PruneVersionsResponse) String() string

func (*PruneVersionsResponse) Validate 

func (this *PruneVersionsResponse) Validate() error

type PutSyncChangeResponse 

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

func (*PutSyncChangeResponse) Descriptor deprecated 

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

Deprecated: Use PutSyncChangeResponse.ProtoReflect.Descriptor instead.

func (*PutSyncChangeResponse) GetMsg 

func (x *PutSyncChangeResponse) GetMsg() string

func (*PutSyncChangeResponse) GetSuccess 

func (x *PutSyncChangeResponse) GetSuccess() bool

func (*PutSyncChangeResponse) ProtoMessage 

func (*PutSyncChangeResponse) ProtoMessage()

func (*PutSyncChangeResponse) ProtoReflect 

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

func (*PutSyncChangeResponse) Reset 

func (x *PutSyncChangeResponse) Reset()

func (*PutSyncChangeResponse) String 

func (x *PutSyncChangeResponse) String() string

func (*PutSyncChangeResponse) Validate 

func (this *PutSyncChangeResponse) Validate() error

type Query 

type Query struct {

	// Preset list of nodes by Path
	Paths []string `protobuf:"bytes,13,rep,name=Paths,proto3" json:"Paths,omitempty"`
	// Limit to a given subtree
	PathPrefix []string `protobuf:"bytes,1,rep,name=PathPrefix,proto3" json:"PathPrefix,omitempty"`
	// Range for size
	MinSize int64 `protobuf:"varint,2,opt,name=MinSize,proto3" json:"MinSize,omitempty"`
	MaxSize int64 `protobuf:"varint,3,opt,name=MaxSize,proto3" json:"MaxSize,omitempty"`
	// Range for date
	MinDate int64 `protobuf:"varint,4,opt,name=MinDate,proto3" json:"MinDate,omitempty"`
	MaxDate int64 `protobuf:"varint,5,opt,name=MaxDate,proto3" json:"MaxDate,omitempty"`
	// Pass a duration with > or < to compute MinDate / MaxDate
	DurationDate string `protobuf:"bytes,16,opt,name=DurationDate,proto3" json:"DurationDate,omitempty"`
	// Limit to a given node type
	Type NodeType `protobuf:"varint,6,opt,name=Type,proto3,enum=tree.NodeType" json:"Type,omitempty"`
	// Search in filename
	FileName string `protobuf:"bytes,7,opt,name=FileName,proto3" json:"FileName,omitempty"`
	// Search in content
	Content string `protobuf:"bytes,8,opt,name=Content,proto3" json:"Content,omitempty"`
	// Search in either filename or content (but at least one of them)
	FileNameOrContent string `protobuf:"bytes,17,opt,name=FileNameOrContent,proto3" json:"FileNameOrContent,omitempty"`
	// Free Query String (for metadata)
	FreeString string `protobuf:"bytes,9,opt,name=FreeString,proto3" json:"FreeString,omitempty"`
	// Look for a specific eTag value
	ETag string `protobuf:"bytes,18,opt,name=ETag,proto3" json:"ETag,omitempty"`
	// Search files by extension
	Extension string `protobuf:"bytes,10,opt,name=Extension,proto3" json:"Extension,omitempty"`
	// Search geographically
	GeoQuery *GeoQuery `protobuf:"bytes,11,opt,name=GeoQuery,proto3" json:"GeoQuery,omitempty"`
	// Limit to a given level of the tree - can be used in filters
	PathDepth int32 `protobuf:"varint,12,opt,name=PathDepth,proto3" json:"PathDepth,omitempty"`
	// Preset list of Node by UUIDs
	UUIDs []string `protobuf:"bytes,15,rep,name=UUIDs,proto3" json:"UUIDs,omitempty"`
	// Negate this query
	Not bool `protobuf:"varint,14,opt,name=Not,proto3" json:"Not,omitempty"`
	// contains filtered or unexported fields
}

Search Queries

func (*Query) Descriptor deprecated 

func (*Query) 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 added in v4.0.1 

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

func (*Query) Validate 

func (this *Query) Validate() error

type ReadNodeRequest 

type ReadNodeRequest struct {

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

Request / Responses Messages

func (*ReadNodeRequest) Descriptor deprecated 

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

Deprecated: Use ReadNodeRequest.ProtoReflect.Descriptor instead.

func (*ReadNodeRequest) GetNode 

func (x *ReadNodeRequest) GetNode() *Node

func (*ReadNodeRequest) GetObjectStats 

func (x *ReadNodeRequest) GetObjectStats() bool

func (*ReadNodeRequest) GetStatFlags added in v4.0.1 

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

func (*ReadNodeRequest) GetWithCommits 

func (x *ReadNodeRequest) GetWithCommits() bool

func (*ReadNodeRequest) GetWithExtendedStats 

func (x *ReadNodeRequest) GetWithExtendedStats() bool

func (*ReadNodeRequest) ProtoMessage 

func (*ReadNodeRequest) ProtoMessage()

func (*ReadNodeRequest) ProtoReflect 

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

func (*ReadNodeRequest) Reset 

func (x *ReadNodeRequest) Reset()

func (*ReadNodeRequest) String 

func (x *ReadNodeRequest) String() string

func (*ReadNodeRequest) Validate 

func (this *ReadNodeRequest) Validate() error

type ReadNodeResponse 

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

func (*ReadNodeResponse) Descriptor deprecated 

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

Deprecated: Use ReadNodeResponse.ProtoReflect.Descriptor instead.

func (*ReadNodeResponse) GetNode 

func (x *ReadNodeResponse) GetNode() *Node

func (*ReadNodeResponse) GetSuccess 

func (x *ReadNodeResponse) GetSuccess() bool

func (*ReadNodeResponse) ProtoMessage 

func (*ReadNodeResponse) ProtoMessage()

func (*ReadNodeResponse) ProtoReflect 

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

func (*ReadNodeResponse) Reset 

func (x *ReadNodeResponse) Reset()

func (*ReadNodeResponse) String 

func (x *ReadNodeResponse) String() string

func (*ReadNodeResponse) Validate 

func (this *ReadNodeResponse) Validate() error

type SearchFacet 

type SearchFacet struct {

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

func (*SearchFacet) Descriptor deprecated 

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

Deprecated: Use SearchFacet.ProtoReflect.Descriptor instead.

func (*SearchFacet) GetCount 

func (x *SearchFacet) GetCount() int32

func (*SearchFacet) GetEnd 

func (x *SearchFacet) GetEnd() int32

func (*SearchFacet) GetFieldName 

func (x *SearchFacet) GetFieldName() string

func (*SearchFacet) GetLabel 

func (x *SearchFacet) GetLabel() string

func (*SearchFacet) GetMax 

func (x *SearchFacet) GetMax() int64

func (*SearchFacet) GetMin 

func (x *SearchFacet) GetMin() int64

func (*SearchFacet) GetStart 

func (x *SearchFacet) GetStart() int32

func (*SearchFacet) GetTerm 

func (x *SearchFacet) GetTerm() string

func (*SearchFacet) ProtoMessage 

func (*SearchFacet) ProtoMessage()

func (*SearchFacet) ProtoReflect 

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

func (*SearchFacet) Reset 

func (x *SearchFacet) Reset()

func (*SearchFacet) String 

func (x *SearchFacet) String() string

func (*SearchFacet) Validate 

func (this *SearchFacet) Validate() error

type SearchRequest 

type SearchRequest struct {

	// The query object
	Query *Query `protobuf:"bytes,1,opt,name=Query,proto3" json:"Query,omitempty"`
	// Limit the number of results
	Size int32 `protobuf:"varint,2,opt,name=Size,proto3" json:"Size,omitempty"`
	// Start at given position
	From int32 `protobuf:"varint,3,opt,name=From,proto3" json:"From,omitempty"`
	// Load node details
	Details bool `protobuf:"varint,4,opt,name=Details,proto3" json:"Details,omitempty"`
	// Generic Details Flags
	StatFlags []uint32 `protobuf:"varint,5,rep,packed,name=StatFlags,proto3" json:"StatFlags,omitempty"`
	// contains filtered or unexported fields
}

func (*SearchRequest) Descriptor deprecated 

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

Deprecated: Use SearchRequest.ProtoReflect.Descriptor instead.

func (*SearchRequest) GetDetails 

func (x *SearchRequest) GetDetails() bool

func (*SearchRequest) GetFrom 

func (x *SearchRequest) GetFrom() int32

func (*SearchRequest) GetQuery 

func (x *SearchRequest) GetQuery() *Query

func (*SearchRequest) GetSize 

func (x *SearchRequest) GetSize() int32

func (*SearchRequest) GetStatFlags added in v4.0.1 

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

func (*SearchRequest) ProtoMessage 

func (*SearchRequest) ProtoMessage()

func (*SearchRequest) ProtoReflect 

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

func (*SearchRequest) Reset 

func (x *SearchRequest) Reset()

func (*SearchRequest) String 

func (x *SearchRequest) String() string

func (*SearchRequest) Validate 

func (this *SearchRequest) Validate() error

type SearchResponse 

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

func (*SearchResponse) Descriptor deprecated 

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

Deprecated: Use SearchResponse.ProtoReflect.Descriptor instead.

func (*SearchResponse) GetFacet 

func (x *SearchResponse) GetFacet() *SearchFacet

func (*SearchResponse) GetNode 

func (x *SearchResponse) GetNode() *Node

func (*SearchResponse) ProtoMessage 

func (*SearchResponse) ProtoMessage()

func (*SearchResponse) ProtoReflect 

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

func (*SearchResponse) Reset 

func (x *SearchResponse) Reset()

func (*SearchResponse) String 

func (x *SearchResponse) String() string

func (*SearchResponse) Validate 

func (this *SearchResponse) Validate() error

type SearchSyncChangeRequest 

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

func (*SearchSyncChangeRequest) Descriptor deprecated 

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

Deprecated: Use SearchSyncChangeRequest.ProtoReflect.Descriptor instead.

func (*SearchSyncChangeRequest) GetFlatten 

func (x *SearchSyncChangeRequest) GetFlatten() bool

func (*SearchSyncChangeRequest) GetLastSeqOnly 

func (x *SearchSyncChangeRequest) GetLastSeqOnly() bool

func (*SearchSyncChangeRequest) GetPrefix 

func (x *SearchSyncChangeRequest) GetPrefix() string

func (*SearchSyncChangeRequest) GetSeq 

func (x *SearchSyncChangeRequest) GetSeq() uint64

func (*SearchSyncChangeRequest) ProtoMessage 

func (*SearchSyncChangeRequest) ProtoMessage()

func (*SearchSyncChangeRequest) ProtoReflect 

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

func (*SearchSyncChangeRequest) Reset 

func (x *SearchSyncChangeRequest) Reset()

func (*SearchSyncChangeRequest) String 

func (x *SearchSyncChangeRequest) String() string

func (*SearchSyncChangeRequest) Validate 

func (this *SearchSyncChangeRequest) Validate() error

type SearcherClient 

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

SearcherClient is the client API for Searcher service.

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

func NewSearcherClient 

func NewSearcherClient(cc grpc.ClientConnInterface) SearcherClient

type SearcherEnhancedServer 

type SearcherEnhancedServer map[string]NamedSearcherServer

func (SearcherEnhancedServer) Search 

func (m SearcherEnhancedServer) Search(r *SearchRequest, s Searcher_SearchServer) error

type SearcherServer 

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

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

type SearcherStub 

type SearcherStub struct {
	SearcherServer
}

func (*SearcherStub) Invoke 

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

func (*SearcherStub) NewStream 

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

type SearcherStub_SearchStreamer 

type SearcherStub_SearchStreamer struct {
	stubs.ClientServerStreamerCore
}

func (*SearcherStub_SearchStreamer) Send 

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

type Searcher_SearchClient 

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

type Searcher_SearchServer 

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

type SessionIndexerClient 

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

SessionIndexerClient is the client API for SessionIndexer service.

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

func NewSessionIndexerClient 

func NewSessionIndexerClient(cc grpc.ClientConnInterface) SessionIndexerClient

type SessionIndexerEnhancedServer 

type SessionIndexerEnhancedServer map[string]NamedSessionIndexerServer

func (SessionIndexerEnhancedServer) CloseSession 

func (m SessionIndexerEnhancedServer) CloseSession(ctx context.Context, r *CloseSessionRequest) (*CloseSessionResponse, error)

func (SessionIndexerEnhancedServer) FlushSession 

func (m SessionIndexerEnhancedServer) FlushSession(ctx context.Context, r *FlushSessionRequest) (*FlushSessionResponse, error)

func (SessionIndexerEnhancedServer) OpenSession 

func (m SessionIndexerEnhancedServer) OpenSession(ctx context.Context, r *OpenSessionRequest) (*OpenSessionResponse, error)

type SessionIndexerMock 

type SessionIndexerMock struct {
}

func (*SessionIndexerMock) CloseSession 

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

func (*SessionIndexerMock) FlushSession 

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

func (*SessionIndexerMock) OpenSession 

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

type SessionIndexerServer 

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

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

type SessionIndexerStub 

type SessionIndexerStub struct {
	SessionIndexerServer
}

func (*SessionIndexerStub) Invoke 

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

func (*SessionIndexerStub) NewStream 

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

type StoreVersionRequest 

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

func (*StoreVersionRequest) Descriptor deprecated 

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

Deprecated: Use StoreVersionRequest.ProtoReflect.Descriptor instead.

func (*StoreVersionRequest) GetNode 

func (x *StoreVersionRequest) GetNode() *Node

func (*StoreVersionRequest) GetVersion 

func (x *StoreVersionRequest) GetVersion() *ChangeLog

func (*StoreVersionRequest) ProtoMessage 

func (*StoreVersionRequest) ProtoMessage()

func (*StoreVersionRequest) ProtoReflect 

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

func (*StoreVersionRequest) Reset 

func (x *StoreVersionRequest) Reset()

func (*StoreVersionRequest) String 

func (x *StoreVersionRequest) String() string

func (*StoreVersionRequest) Validate 

func (this *StoreVersionRequest) Validate() error

type StoreVersionResponse 

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

func (*StoreVersionResponse) Descriptor deprecated 

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

Deprecated: Use StoreVersionResponse.ProtoReflect.Descriptor instead.

func (*StoreVersionResponse) GetPruneVersions 

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

func (*StoreVersionResponse) GetSuccess 

func (x *StoreVersionResponse) GetSuccess() bool

func (*StoreVersionResponse) ProtoMessage 

func (*StoreVersionResponse) ProtoMessage()

func (*StoreVersionResponse) ProtoReflect 

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

func (*StoreVersionResponse) Reset 

func (x *StoreVersionResponse) Reset()

func (*StoreVersionResponse) String 

func (x *StoreVersionResponse) String() string

func (*StoreVersionResponse) Validate 

func (this *StoreVersionResponse) Validate() error

type StreamChangesRequest 

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

func (*StreamChangesRequest) Descriptor deprecated 

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

Deprecated: Use StreamChangesRequest.ProtoReflect.Descriptor instead.

func (*StreamChangesRequest) GetRootPath 

func (x *StreamChangesRequest) GetRootPath() string

func (*StreamChangesRequest) ProtoMessage 

func (*StreamChangesRequest) ProtoMessage()

func (*StreamChangesRequest) ProtoReflect 

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

func (*StreamChangesRequest) Reset 

func (x *StreamChangesRequest) Reset()

func (*StreamChangesRequest) String 

func (x *StreamChangesRequest) String() string

func (*StreamChangesRequest) Validate 

func (this *StreamChangesRequest) Validate() error

type StreamerMock 

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

func (*StreamerMock) Close 

func (m *StreamerMock) Close() error

func (*StreamerMock) CloseSend 

func (m *StreamerMock) CloseSend() error

func (*StreamerMock) Context 

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

func (*StreamerMock) Error 

func (m *StreamerMock) Error() error

func (*StreamerMock) 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

func (*SyncChange) Validate 

func (this *SyncChange) Validate() error

type SyncChangeNode 

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

func (*SyncChangeNode) Descriptor deprecated 

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

Deprecated: Use SyncChangeNode.ProtoReflect.Descriptor instead.

func (*SyncChangeNode) GetBytesize 

func (x *SyncChangeNode) GetBytesize() int64

func (*SyncChangeNode) GetMd5 

func (x *SyncChangeNode) GetMd5() string

func (*SyncChangeNode) GetMtime 

func (x *SyncChangeNode) GetMtime() int64

func (*SyncChangeNode) GetNodePath 

func (x *SyncChangeNode) GetNodePath() string

func (*SyncChangeNode) GetRepositoryIdentifier 

func (x *SyncChangeNode) GetRepositoryIdentifier() string

func (*SyncChangeNode) ProtoMessage 

func (*SyncChangeNode) ProtoMessage()

func (*SyncChangeNode) ProtoReflect 

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

func (*SyncChangeNode) Reset 

func (x *SyncChangeNode) Reset()

func (*SyncChangeNode) String 

func (x *SyncChangeNode) String() string

func (*SyncChangeNode) Validate 

func (this *SyncChangeNode) Validate() error

type SyncChange_Type 

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

func (SyncChange_Type) Descriptor 

func (SyncChange_Type) Descriptor() protoreflect.EnumDescriptor

func (SyncChange_Type) Enum 

func (x SyncChange_Type) Enum() *SyncChange_Type

func (SyncChange_Type) EnumDescriptor deprecated 

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

Deprecated: Use SyncChange_Type.Descriptor instead.

func (SyncChange_Type) Number 

func (x SyncChange_Type) Number() protoreflect.EnumNumber

func (SyncChange_Type) String 

func (x SyncChange_Type) String() string

func (SyncChange_Type) Type 

func (SyncChange_Type) Type() protoreflect.EnumType

type SyncChangesClient 

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

SyncChangesClient is the client API for SyncChanges service.

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

func NewSyncChangesClient 

func NewSyncChangesClient(cc grpc.ClientConnInterface) SyncChangesClient

type SyncChangesEnhancedServer 

type SyncChangesEnhancedServer map[string]NamedSyncChangesServer

func (SyncChangesEnhancedServer) Put 

func (m SyncChangesEnhancedServer) Put(s SyncChanges_PutServer) error

func (SyncChangesEnhancedServer) Search 

func (m SyncChangesEnhancedServer) Search(r *SearchSyncChangeRequest, s SyncChanges_SearchServer) error

type SyncChangesServer 

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

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

type SyncChangesStub 

type SyncChangesStub struct {
	SyncChangesServer
}

func (*SyncChangesStub) Invoke 

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

func (*SyncChangesStub) NewStream 

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

type SyncChangesStub_PutStreamer 

type SyncChangesStub_PutStreamer struct {
	stubs.BidirServerStreamerCore
}

func (*SyncChangesStub_PutStreamer) Recv 

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

func (*SyncChangesStub_PutStreamer) Send 

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

func (*SyncChangesStub_PutStreamer) SendAndClose 

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

type SyncChangesStub_SearchStreamer 

type SyncChangesStub_SearchStreamer struct {
	stubs.ClientServerStreamerCore
}

func (*SyncChangesStub_SearchStreamer) Send 

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

type SyncChanges_PutClient 

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

type SyncChanges_PutServer 

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

type SyncChanges_SearchClient 

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

type SyncChanges_SearchServer 

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

type UnimplementedFileKeyManagerServer 

type UnimplementedFileKeyManagerServer struct {
}

UnimplementedFileKeyManagerServer must be embedded to have forward compatible implementations.

func (UnimplementedFileKeyManagerServer) GetEncryptionKey 

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

type UnimplementedNodeChangesReceiverStreamerServer added in v4.0.1 

type UnimplementedNodeChangesReceiverStreamerServer struct {
}

UnimplementedNodeChangesReceiverStreamerServer must be embedded to have forward compatible implementations.

func (UnimplementedNodeChangesReceiverStreamerServer) PostNodeChanges added in v4.0.1 

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) 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 added in v4.0.1 

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

func (*UpdateNodeRequest) Validate 

func (this *UpdateNodeRequest) Validate() error

type UpdateNodeResponse 

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

func (*UpdateNodeResponse) Descriptor deprecated 

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

Deprecated: Use UpdateNodeResponse.ProtoReflect.Descriptor instead.

func (*UpdateNodeResponse) GetNode 

func (x *UpdateNodeResponse) GetNode() *Node

func (*UpdateNodeResponse) GetSuccess 

func (x *UpdateNodeResponse) GetSuccess() bool

func (*UpdateNodeResponse) ProtoMessage 

func (*UpdateNodeResponse) ProtoMessage()

func (*UpdateNodeResponse) ProtoReflect 

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

func (*UpdateNodeResponse) Reset 

func (x *UpdateNodeResponse) Reset()

func (*UpdateNodeResponse) String 

func (x *UpdateNodeResponse) String() string

func (*UpdateNodeResponse) Validate 

func (this *UpdateNodeResponse) Validate() error

type VersioningKeepPeriod 

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

func (*VersioningKeepPeriod) Descriptor deprecated 

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

Deprecated: Use VersioningKeepPeriod.ProtoReflect.Descriptor instead.

func (*VersioningKeepPeriod) GetIntervalStart 

func (x *VersioningKeepPeriod) GetIntervalStart() string

func (*VersioningKeepPeriod) GetMaxNumber 

func (x *VersioningKeepPeriod) GetMaxNumber() int32

func (*VersioningKeepPeriod) ProtoMessage 

func (*VersioningKeepPeriod) ProtoMessage()

func (*VersioningKeepPeriod) ProtoReflect 

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

func (*VersioningKeepPeriod) Reset 

func (x *VersioningKeepPeriod) Reset()

func (*VersioningKeepPeriod) String 

func (x *VersioningKeepPeriod) String() string

func (*VersioningKeepPeriod) Validate 

func (this *VersioningKeepPeriod) Validate() error

type VersioningNodeDeletedStrategy 

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

func (VersioningNodeDeletedStrategy) Descriptor 

func (VersioningNodeDeletedStrategy) Descriptor() protoreflect.EnumDescriptor

func (VersioningNodeDeletedStrategy) Enum 

func (x VersioningNodeDeletedStrategy) Enum() *VersioningNodeDeletedStrategy

func (VersioningNodeDeletedStrategy) EnumDescriptor deprecated 

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

Deprecated: Use VersioningNodeDeletedStrategy.Descriptor instead.

func (VersioningNodeDeletedStrategy) Number 

func (x VersioningNodeDeletedStrategy) Number() protoreflect.EnumNumber

func (VersioningNodeDeletedStrategy) String 

func (x VersioningNodeDeletedStrategy) String() string

func (VersioningNodeDeletedStrategy) Type 

func (VersioningNodeDeletedStrategy) Type() protoreflect.EnumType

type VersioningPolicy 

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

func (*VersioningPolicy) Descriptor deprecated 

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

Deprecated: Use VersioningPolicy.ProtoReflect.Descriptor instead.

func (*VersioningPolicy) GetDescription 

func (x *VersioningPolicy) GetDescription() string

func (*VersioningPolicy) GetIgnoreFilesGreaterThan 

func (x *VersioningPolicy) GetIgnoreFilesGreaterThan() int64

func (*VersioningPolicy) GetKeepPeriods 

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

func (*VersioningPolicy) GetMaxSizePerFile 

func (x *VersioningPolicy) GetMaxSizePerFile() int64

func (*VersioningPolicy) GetMaxTotalSize 

func (x *VersioningPolicy) GetMaxTotalSize() int64

func (*VersioningPolicy) GetName 

func (x *VersioningPolicy) GetName() string

func (*VersioningPolicy) GetNodeDeletedStrategy 

func (x *VersioningPolicy) GetNodeDeletedStrategy() VersioningNodeDeletedStrategy

func (*VersioningPolicy) GetUuid 

func (x *VersioningPolicy) GetUuid() string

func (*VersioningPolicy) GetVersionsDataSourceBucket 

func (x *VersioningPolicy) GetVersionsDataSourceBucket() string

func (*VersioningPolicy) GetVersionsDataSourceName 

func (x *VersioningPolicy) GetVersionsDataSourceName() string

func (*VersioningPolicy) MarshalLogObject 

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

MarshalLogObject implements custom marshalling for logs

func (*VersioningPolicy) ProtoMessage 

func (*VersioningPolicy) ProtoMessage()

func (*VersioningPolicy) ProtoReflect 

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

func (*VersioningPolicy) Reset 

func (x *VersioningPolicy) Reset()

func (*VersioningPolicy) String 

func (x *VersioningPolicy) String() string

func (*VersioningPolicy) Validate 

func (this *VersioningPolicy) Validate() error

func (*VersioningPolicy) Zap 

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

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

type WatchNodeRequest 

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

Request / Responses Messages

func (*WatchNodeRequest) Descriptor deprecated 

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

Deprecated: Use WatchNodeRequest.ProtoReflect.Descriptor instead.

func (*WatchNodeRequest) GetNode 

func (x *WatchNodeRequest) GetNode() *Node

func (*WatchNodeRequest) ProtoMessage 

func (*WatchNodeRequest) ProtoMessage()

func (*WatchNodeRequest) ProtoReflect 

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

func (*WatchNodeRequest) Reset 

func (x *WatchNodeRequest) Reset()

func (*WatchNodeRequest) String 

func (x *WatchNodeRequest) String() string

func (*WatchNodeRequest) Validate 

func (this *WatchNodeRequest) Validate() error

type WatchNodeResponse 

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

func (*WatchNodeResponse) Descriptor deprecated 

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

Deprecated: Use WatchNodeResponse.ProtoReflect.Descriptor instead.

func (*WatchNodeResponse) GetNode 

func (x *WatchNodeResponse) GetNode() *Node

func (*WatchNodeResponse) ProtoMessage 

func (*WatchNodeResponse) ProtoMessage()

func (*WatchNodeResponse) ProtoReflect 

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

func (*WatchNodeResponse) Reset 

func (x *WatchNodeResponse) Reset()

func (*WatchNodeResponse) String 

func (x *WatchNodeResponse) String() string

func (*WatchNodeResponse) Validate 

func (this *WatchNodeResponse) Validate() error

type WorkspaceRelativePath 

type WorkspaceRelativePath struct {

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

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

func (*WorkspaceRelativePath) Descriptor deprecated 

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

Deprecated: Use WorkspaceRelativePath.ProtoReflect.Descriptor instead.

func (*WorkspaceRelativePath) GetPath 

func (x *WorkspaceRelativePath) GetPath() string

func (*WorkspaceRelativePath) GetWsLabel 

func (x *WorkspaceRelativePath) GetWsLabel() string

func (*WorkspaceRelativePath) GetWsScope 

func (x *WorkspaceRelativePath) GetWsScope() string

func (*WorkspaceRelativePath) GetWsSlug 

func (x *WorkspaceRelativePath) GetWsSlug() string

func (*WorkspaceRelativePath) GetWsUuid 

func (x *WorkspaceRelativePath) GetWsUuid() string

func (*WorkspaceRelativePath) ProtoMessage 

func (*WorkspaceRelativePath) ProtoMessage()

func (*WorkspaceRelativePath) ProtoReflect 

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

func (*WorkspaceRelativePath) Reset 

func (x *WorkspaceRelativePath) Reset()

func (*WorkspaceRelativePath) String 

func (x *WorkspaceRelativePath) String() string

func (*WorkspaceRelativePath) Validate 

func (this *WorkspaceRelativePath) Validate() error

type WrappingStreamerResponse 

type WrappingStreamerResponse struct {

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

func (*WrappingStreamerResponse) Descriptor deprecated 

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

Deprecated: Use WrappingStreamerResponse.ProtoReflect.Descriptor instead.

func (*WrappingStreamerResponse) GetData 

func (m *WrappingStreamerResponse) GetData() isWrappingStreamerResponse_Data

func (*WrappingStreamerResponse) GetError 

func (x *WrappingStreamerResponse) GetError() string

func (*WrappingStreamerResponse) GetListNodesResponse 

func (x *WrappingStreamerResponse) GetListNodesResponse() *ListNodesResponse

func (*WrappingStreamerResponse) GetNodeChangeEvent 

func (x *WrappingStreamerResponse) GetNodeChangeEvent() *NodeChangeEvent

func (*WrappingStreamerResponse) ProtoMessage 

func (*WrappingStreamerResponse) ProtoMessage()

func (*WrappingStreamerResponse) ProtoReflect 

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

func (*WrappingStreamerResponse) Reset 

func (x *WrappingStreamerResponse) Reset()

func (*WrappingStreamerResponse) String 

func (x *WrappingStreamerResponse) String() string

func (*WrappingStreamerResponse) Validate 

func (this *WrappingStreamerResponse) Validate() error

type WrappingStreamerResponse_ListNodesResponse 

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

type WrappingStreamerResponse_NodeChangeEvent 

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

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.