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.

type FileKeyManagerEnhancedServer

type FileKeyManagerEnhancedServer map[string]NamedFileKeyManagerServer

func (FileKeyManagerEnhancedServer) GetEncryptionKey

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 (*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) Enum

func (NodeChangeEvent_EventType) EnumDescriptor deprecated

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

Deprecated: Use NodeChangeEvent_EventType.Descriptor instead.

func (NodeChangeEvent_EventType) Number

func (NodeChangeEvent_EventType) String

func (x NodeChangeEvent_EventType) String() string

func (NodeChangeEvent_EventType) Type

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

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

type NodeChangesReceiverStreamerStub_PostNodeChangesStreamer added in v4.0.1

type NodeChangesReceiverStreamerStub_PostNodeChangesStreamer struct {
	stubs.BidirServerStreamerCore
}

func (*NodeChangesReceiverStreamerStub_PostNodeChangesStreamer) Recv added in v4.0.1

func (*NodeChangesReceiverStreamerStub_PostNodeChangesStreamer) Send added in v4.0.1

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.

type NodeChangesStreamerEnhancedServer

type NodeChangesStreamerEnhancedServer map[string]NamedNodeChangesStreamerServer

func (NodeChangesStreamerEnhancedServer) StreamChanges

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

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.

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.

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.

type NodeEventsProviderEnhancedServer

type NodeEventsProviderEnhancedServer map[string]NamedNodeEventsProviderServer

func (NodeEventsProviderEnhancedServer) WatchNode

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

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.

type NodeProviderEnhancedServer

type NodeProviderEnhancedServer map[string]NamedNodeProviderServer

func (NodeProviderEnhancedServer) ListNodes

func (NodeProviderEnhancedServer) ReadNode

type NodeProviderMock

type NodeProviderMock struct {
	Nodes map[string]Node
}

func NewNodeProviderMock

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

func (*NodeProviderMock) ListNodes

func (*NodeProviderMock) ReadNode

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.

type NodeProviderStreamerEnhancedServer

type NodeProviderStreamerEnhancedServer map[string]NamedNodeProviderStreamerServer

func (NodeProviderStreamerEnhancedServer) ReadNodeStream

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 (*NodeProviderStreamerStub_ReadNodeStreamStreamer) Send

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

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.

type NodeReceiverEnhancedServer

type NodeReceiverEnhancedServer map[string]NamedNodeReceiverServer

func (NodeReceiverEnhancedServer) CreateNode

func (NodeReceiverEnhancedServer) DeleteNode

func (NodeReceiverEnhancedServer) UpdateNode

type NodeReceiverMock

type NodeReceiverMock struct {
	Nodes map[string]Node
}

func (*NodeReceiverMock) CreateNode

func (*NodeReceiverMock) DeleteNode

func (*NodeReceiverMock) UpdateNode

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.

type NodeReceiverStreamEnhancedServer

type NodeReceiverStreamEnhancedServer map[string]NamedNodeReceiverStreamServer

func (NodeReceiverStreamEnhancedServer) CreateNodeStream

func (NodeReceiverStreamEnhancedServer) DeleteNodeStream

func (NodeReceiverStreamEnhancedServer) UpdateNodeStream

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 (*NodeReceiverStreamStub_CreateNodeStreamStreamer) Send

type NodeReceiverStreamStub_DeleteNodeStreamStreamer

type NodeReceiverStreamStub_DeleteNodeStreamStreamer struct {
	stubs.BidirServerStreamerCore
}

func (*NodeReceiverStreamStub_DeleteNodeStreamStreamer) Recv

func (*NodeReceiverStreamStub_DeleteNodeStreamStreamer) Send

type NodeReceiverStreamStub_UpdateNodeStreamStreamer

type NodeReceiverStreamStub_UpdateNodeStreamStreamer struct {
	stubs.BidirServerStreamerCore
}

func (*NodeReceiverStreamStub_UpdateNodeStreamStreamer) Recv

func (*NodeReceiverStreamStub_UpdateNodeStreamStreamer) Send

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

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.

type NodeVersionerEnhancedServer

type NodeVersionerEnhancedServer map[string]NamedNodeVersionerServer

func (NodeVersionerEnhancedServer) CreateVersion

func (NodeVersionerEnhancedServer) HeadVersion

func (NodeVersionerEnhancedServer) ListVersions

func (NodeVersionerEnhancedServer) PruneVersions

func (NodeVersionerEnhancedServer) StoreVersion

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

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

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

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.

type SessionIndexerEnhancedServer

type SessionIndexerEnhancedServer map[string]NamedSessionIndexerServer

func (SessionIndexerEnhancedServer) CloseSession

func (SessionIndexerEnhancedServer) FlushSession

func (SessionIndexerEnhancedServer) OpenSession

type SessionIndexerMock

type SessionIndexerMock struct {
}

func (*SessionIndexerMock) CloseSession

func (*SessionIndexerMock) FlushSession

func (*SessionIndexerMock) OpenSession

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

func (x SyncChange_Type) String() string

func (SyncChange_Type) Type

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.

type SyncChangesEnhancedServer

type SyncChangesEnhancedServer map[string]NamedSyncChangesServer

func (SyncChangesEnhancedServer) Put

func (SyncChangesEnhancedServer) Search

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 (*SyncChangesStub_PutStreamer) Send

func (*SyncChangesStub_PutStreamer) SendAndClose

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

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

type UnimplementedNodeChangesStreamerServer

type UnimplementedNodeChangesStreamerServer struct {
}

UnimplementedNodeChangesStreamerServer must be embedded to have forward compatible implementations.

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

type UnimplementedNodeProviderServer

type UnimplementedNodeProviderServer struct {
}

UnimplementedNodeProviderServer must be embedded to have forward compatible implementations.

func (UnimplementedNodeProviderServer) ListNodes

func (UnimplementedNodeProviderServer) ReadNode

type UnimplementedNodeProviderStreamerServer

type UnimplementedNodeProviderStreamerServer struct {
}

UnimplementedNodeProviderStreamerServer must be embedded to have forward compatible implementations.

func (UnimplementedNodeProviderStreamerServer) ReadNodeStream

type UnimplementedNodeReceiverServer

type UnimplementedNodeReceiverServer struct {
}

UnimplementedNodeReceiverServer must be embedded to have forward compatible implementations.

func (UnimplementedNodeReceiverServer) CreateNode

func (UnimplementedNodeReceiverServer) DeleteNode

func (UnimplementedNodeReceiverServer) UpdateNode

type UnimplementedNodeReceiverStreamServer

type UnimplementedNodeReceiverStreamServer struct {
}

UnimplementedNodeReceiverStreamServer must be embedded to have forward compatible implementations.

func (UnimplementedNodeReceiverStreamServer) CreateNodeStream

func (UnimplementedNodeReceiverStreamServer) DeleteNodeStream

func (UnimplementedNodeReceiverStreamServer) UpdateNodeStream

type UnimplementedNodeVersionerServer

type UnimplementedNodeVersionerServer struct {
}

UnimplementedNodeVersionerServer must be embedded to have forward compatible implementations.

func (UnimplementedNodeVersionerServer) CreateVersion

func (UnimplementedNodeVersionerServer) HeadVersion

func (UnimplementedNodeVersionerServer) ListVersions

func (UnimplementedNodeVersionerServer) PruneVersions

func (UnimplementedNodeVersionerServer) StoreVersion

type UnimplementedSearcherServer

type UnimplementedSearcherServer struct {
}

UnimplementedSearcherServer must be embedded to have forward compatible implementations.

func (UnimplementedSearcherServer) Search

type UnimplementedSessionIndexerServer

type UnimplementedSessionIndexerServer struct {
}

UnimplementedSessionIndexerServer must be embedded to have forward compatible implementations.

func (UnimplementedSessionIndexerServer) CloseSession

func (UnimplementedSessionIndexerServer) FlushSession

func (UnimplementedSessionIndexerServer) OpenSession

type UnimplementedSyncChangesServer

type UnimplementedSyncChangesServer struct {
}

UnimplementedSyncChangesServer must be embedded to have forward compatible implementations.

func (UnimplementedSyncChangesServer) Put

func (UnimplementedSyncChangesServer) Search

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

func (VersioningNodeDeletedStrategy) EnumDescriptor deprecated

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

Deprecated: Use VersioningNodeDeletedStrategy.Descriptor instead.

func (VersioningNodeDeletedStrategy) Number

func (VersioningNodeDeletedStrategy) String

func (VersioningNodeDeletedStrategy) Type

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"`
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL