tree

package
v2.0.7+incompatible Latest Latest
Warning

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

 Go to latest Published: May 25, 2020 License: AGPL-3.0 Imports: 18 Imported by: 0

Documentation

Overview

Package tree is a generated protocol buffer package.

It is generated from these files: 

tree.proto

It has these top-level messages: 

ReadNodeRequest
ReadNodeResponse
ListNodesRequest
ListNodesResponse
CreateNodeRequest
CreateNodeResponse
UpdateNodeRequest
UpdateNodeResponse
DeleteNodeRequest
DeleteNodeResponse
IndexationSession
IndexationOperation
OpenSessionRequest
OpenSessionResponse
FlushSessionRequest
FlushSessionResponse
CloseSessionRequest
CloseSessionResponse
WatchNodeRequest
WatchNodeResponse
SearchRequest
SearchResponse
CreateVersionRequest
CreateVersionResponse
ListVersionsRequest
ListVersionsResponse
HeadVersionRequest
HeadVersionResponse
StoreVersionRequest
StoreVersionResponse
PruneVersionsRequest
PruneVersionsResponse
VersioningPolicy
VersioningKeepPeriod
Node
WorkspaceRelativePath
ChangeLog
Query
GeoQuery
GeoPoint
StreamChangesRequest
NodeChangeEvent
IndexEvent
GetEncryptionKeyRequest
GetEncryptionKeyResponse
SyncChange
SyncChangeNode
PutSyncChangeResponse
SearchSyncChangeRequest

Package tree is a generated protocol buffer package.

It is generated from these files: 

tree.proto

It has these top-level messages: 

ReadNodeRequest
ReadNodeResponse
ListNodesRequest
ListNodesResponse
WrappingStreamerResponse
CreateNodeRequest
CreateNodeResponse
UpdateNodeRequest
UpdateNodeResponse
DeleteNodeRequest
DeleteNodeResponse
IndexationSession
IndexationOperation
OpenSessionRequest
OpenSessionResponse
FlushSessionRequest
FlushSessionResponse
CloseSessionRequest
CloseSessionResponse
WatchNodeRequest
WatchNodeResponse
SearchRequest
SearchResponse
CreateVersionRequest
CreateVersionResponse
ListVersionsRequest
ListVersionsResponse
HeadVersionRequest
HeadVersionResponse
StoreVersionRequest
StoreVersionResponse
PruneVersionsRequest
PruneVersionsResponse
VersioningPolicy
VersioningKeepPeriod
Node
WorkspaceRelativePath
ChangeLog
Query
GeoQuery
GeoPoint
StreamChangesRequest
NodeChangeEvent
IndexEvent
GetEncryptionKeyRequest
GetEncryptionKeyResponse
SyncChange
SyncChangeNode
PutSyncChangeResponse
SearchSyncChangeRequest

Index

Constants

This section is empty.

Variables

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",
}
View Source 
var NodeChangeEvent_EventType_value = map[string]int32{
	"CREATE":           0,
	"READ":             1,
	"UPDATE_PATH":      2,
	"UPDATE_CONTENT":   3,
	"UPDATE_META":      4,
	"UPDATE_USER_META": 6,
	"DELETE":           5,
}
View Source 
var NodeType_name = map[int32]string{
	0: "UNKNOWN",
	1: "LEAF",
	2: "COLLECTION",
}
View Source 
var NodeType_value = map[string]int32{
	"UNKNOWN":    0,
	"LEAF":       1,
	"COLLECTION": 2,
}
View Source 
var SyncChange_Type_name = map[int32]string{
	0: "unknown",
	1: "create",
	2: "delete",
	3: "path",
	4: "content",
}
View Source 
var SyncChange_Type_value = map[string]int32{
	"unknown": 0,
	"create":  1,
	"delete":  2,
	"path":    3,
	"content": 4,
}

Functions

func IgnoreNodeForOutput added in v1.4.1 

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 PredefineError 

func PredefineError(f ErrorThrower)

func RegisterFileKeyManagerHandler 

func RegisterFileKeyManagerHandler(s server.Server, hdlr FileKeyManagerHandler, opts ...server.HandlerOption)

func RegisterNodeChangesStreamerHandler 

func RegisterNodeChangesStreamerHandler(s server.Server, hdlr NodeChangesStreamerHandler, opts ...server.HandlerOption)

func RegisterNodeContentReaderHandler 

func RegisterNodeContentReaderHandler(s server.Server, hdlr NodeContentReaderHandler, opts ...server.HandlerOption)

func RegisterNodeContentWriterHandler 

func RegisterNodeContentWriterHandler(s server.Server, hdlr NodeContentWriterHandler, opts ...server.HandlerOption)

func RegisterNodeEventsProviderHandler 

func RegisterNodeEventsProviderHandler(s server.Server, hdlr NodeEventsProviderHandler, opts ...server.HandlerOption)

func RegisterNodeProviderHandler 

func RegisterNodeProviderHandler(s server.Server, hdlr NodeProviderHandler, opts ...server.HandlerOption)

func RegisterNodeProviderStreamerHandler 

func RegisterNodeProviderStreamerHandler(s server.Server, hdlr NodeProviderStreamerHandler, opts ...server.HandlerOption)

func RegisterNodeReceiverHandler 

func RegisterNodeReceiverHandler(s server.Server, hdlr NodeReceiverHandler, opts ...server.HandlerOption)

func RegisterNodeReceiverStreamHandler 

func RegisterNodeReceiverStreamHandler(s server.Server, hdlr NodeReceiverStreamHandler, opts ...server.HandlerOption)

func RegisterNodeVersionerHandler 

func RegisterNodeVersionerHandler(s server.Server, hdlr NodeVersionerHandler, opts ...server.HandlerOption)

func RegisterSearcherHandler 

func RegisterSearcherHandler(s server.Server, hdlr SearcherHandler, opts ...server.HandlerOption)

func RegisterSessionIndexerHandler 

func RegisterSessionIndexerHandler(s server.Server, hdlr SessionIndexerHandler, opts ...server.HandlerOption)

func RegisterSyncChangesHandler 

func RegisterSyncChangesHandler(s server.Server, hdlr SyncChangesHandler, opts ...server.HandlerOption)

func ShouldError 

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" json:"Uuid,omitempty"`
	// Human-readable description of what happened
	Description string `protobuf:"bytes,2,opt,name=Description" json:"Description,omitempty"`
	// Unix Timestamp
	MTime int64 `protobuf:"varint,3,opt,name=MTime" json:"MTime,omitempty"`
	// Content Size at that moment
	Size int64 `protobuf:"varint,4,opt,name=Size" json:"Size,omitempty"`
	// Arbitrary additional data
	Data []byte `protobuf:"bytes,5,opt,name=Data,proto3" json:"Data,omitempty"`
	// Who performed this action
	OwnerUuid string `protobuf:"bytes,6,opt,name=OwnerUuid" json:"OwnerUuid,omitempty"`
	// Event that triggered this change
	Event *NodeChangeEvent `protobuf:"bytes,7,opt,name=Event" json:"Event,omitempty"`
}

func (*ChangeLog) Descriptor 

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

func (*ChangeLog) GetData 

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

func (*ChangeLog) GetDescription 

func (m *ChangeLog) GetDescription() string

func (*ChangeLog) GetEvent 

func (m *ChangeLog) GetEvent() *NodeChangeEvent

func (*ChangeLog) GetMTime 

func (m *ChangeLog) GetMTime() int64

func (*ChangeLog) GetOwnerUuid 

func (m *ChangeLog) GetOwnerUuid() string

func (*ChangeLog) GetSize 

func (m *ChangeLog) GetSize() int64

func (*ChangeLog) GetUuid 

func (m *ChangeLog) GetUuid() string

func (*ChangeLog) MarshalLogObject added in v1.5.0 

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

MarshalLogObject implements custom marshalling for logs

func (*ChangeLog) ProtoMessage 

func (*ChangeLog) ProtoMessage()

func (*ChangeLog) Reset 

func (m *ChangeLog) Reset()

func (*ChangeLog) String 

func (m *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" json:"Session,omitempty"`
}

func (*CloseSessionRequest) Descriptor 

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

func (*CloseSessionRequest) GetSession 

func (m *CloseSessionRequest) GetSession() *IndexationSession

func (*CloseSessionRequest) ProtoMessage 

func (*CloseSessionRequest) ProtoMessage()

func (*CloseSessionRequest) Reset 

func (m *CloseSessionRequest) Reset()

func (*CloseSessionRequest) String 

func (m *CloseSessionRequest) String() string

func (*CloseSessionRequest) Validate 

func (this *CloseSessionRequest) Validate() error

type CloseSessionResponse 

type CloseSessionResponse struct {
	Session *IndexationSession `protobuf:"bytes,1,opt,name=Session" json:"Session,omitempty"`
}

func (*CloseSessionResponse) Descriptor 

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

func (*CloseSessionResponse) GetSession 

func (m *CloseSessionResponse) GetSession() *IndexationSession

func (*CloseSessionResponse) ProtoMessage 

func (*CloseSessionResponse) ProtoMessage()

func (*CloseSessionResponse) Reset 

func (m *CloseSessionResponse) Reset()

func (*CloseSessionResponse) String 

func (m *CloseSessionResponse) String() string

func (*CloseSessionResponse) Validate 

func (this *CloseSessionResponse) Validate() error

type CreateNodeRequest 

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

Request / Responses Messages

func (*CreateNodeRequest) Descriptor 

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

func (*CreateNodeRequest) GetIndexationSession 

func (m *CreateNodeRequest) GetIndexationSession() string

func (*CreateNodeRequest) GetNode 

func (m *CreateNodeRequest) GetNode() *Node

func (*CreateNodeRequest) GetSilent added in v1.2.0 

func (m *CreateNodeRequest) GetSilent() bool

func (*CreateNodeRequest) GetUpdateIfExists 

func (m *CreateNodeRequest) GetUpdateIfExists() bool

func (*CreateNodeRequest) ProtoMessage 

func (*CreateNodeRequest) ProtoMessage()

func (*CreateNodeRequest) Reset 

func (m *CreateNodeRequest) Reset()

func (*CreateNodeRequest) String 

func (m *CreateNodeRequest) String() string

func (*CreateNodeRequest) Validate 

func (this *CreateNodeRequest) Validate() error

type CreateNodeResponse 

type CreateNodeResponse struct {
	Success bool  `protobuf:"varint,1,opt,name=Success" json:"Success,omitempty"`
	Node    *Node `protobuf:"bytes,2,opt,name=Node" json:"Node,omitempty"`
}

func (*CreateNodeResponse) Descriptor 

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

func (*CreateNodeResponse) GetNode 

func (m *CreateNodeResponse) GetNode() *Node

func (*CreateNodeResponse) GetSuccess 

func (m *CreateNodeResponse) GetSuccess() bool

func (*CreateNodeResponse) ProtoMessage 

func (*CreateNodeResponse) ProtoMessage()

func (*CreateNodeResponse) Reset 

func (m *CreateNodeResponse) Reset()

func (*CreateNodeResponse) String 

func (m *CreateNodeResponse) String() string

func (*CreateNodeResponse) Validate 

func (this *CreateNodeResponse) Validate() error

type CreateVersionRequest 

type CreateVersionRequest struct {
	Node         *Node            `protobuf:"bytes,1,opt,name=Node" json:"Node,omitempty"`
	TriggerEvent *NodeChangeEvent `protobuf:"bytes,2,opt,name=TriggerEvent" json:"TriggerEvent,omitempty"`
}

func (*CreateVersionRequest) Descriptor 

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

func (*CreateVersionRequest) GetNode 

func (m *CreateVersionRequest) GetNode() *Node

func (*CreateVersionRequest) GetTriggerEvent 

func (m *CreateVersionRequest) GetTriggerEvent() *NodeChangeEvent

func (*CreateVersionRequest) ProtoMessage 

func (*CreateVersionRequest) ProtoMessage()

func (*CreateVersionRequest) Reset 

func (m *CreateVersionRequest) Reset()

func (*CreateVersionRequest) String 

func (m *CreateVersionRequest) String() string

func (*CreateVersionRequest) Validate 

func (this *CreateVersionRequest) Validate() error

type CreateVersionResponse 

type CreateVersionResponse struct {
	Version *ChangeLog `protobuf:"bytes,1,opt,name=Version" json:"Version,omitempty"`
}

func (*CreateVersionResponse) Descriptor 

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

func (*CreateVersionResponse) GetVersion 

func (m *CreateVersionResponse) GetVersion() *ChangeLog

func (*CreateVersionResponse) ProtoMessage 

func (*CreateVersionResponse) ProtoMessage()

func (*CreateVersionResponse) Reset 

func (m *CreateVersionResponse) Reset()

func (*CreateVersionResponse) String 

func (m *CreateVersionResponse) String() string

func (*CreateVersionResponse) Validate 

func (this *CreateVersionResponse) Validate() error

type DeleteNodeRequest 

type DeleteNodeRequest struct {
	Node              *Node  `protobuf:"bytes,1,opt,name=Node" json:"Node,omitempty"`
	IndexationSession string `protobuf:"bytes,2,opt,name=IndexationSession" json:"IndexationSession,omitempty"`
	Silent            bool   `protobuf:"varint,3,opt,name=Silent" json:"Silent,omitempty"`
}

func (*DeleteNodeRequest) Descriptor 

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

func (*DeleteNodeRequest) GetIndexationSession 

func (m *DeleteNodeRequest) GetIndexationSession() string

func (*DeleteNodeRequest) GetNode 

func (m *DeleteNodeRequest) GetNode() *Node

func (*DeleteNodeRequest) GetSilent added in v1.2.0 

func (m *DeleteNodeRequest) GetSilent() bool

func (*DeleteNodeRequest) ProtoMessage 

func (*DeleteNodeRequest) ProtoMessage()

func (*DeleteNodeRequest) Reset 

func (m *DeleteNodeRequest) Reset()

func (*DeleteNodeRequest) String 

func (m *DeleteNodeRequest) String() string

func (*DeleteNodeRequest) Validate 

func (this *DeleteNodeRequest) Validate() error

type DeleteNodeResponse 

type DeleteNodeResponse struct {
	Success bool `protobuf:"varint,1,opt,name=Success" json:"Success,omitempty"`
}

func (*DeleteNodeResponse) Descriptor 

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

func (*DeleteNodeResponse) GetSuccess 

func (m *DeleteNodeResponse) GetSuccess() bool

func (*DeleteNodeResponse) ProtoMessage 

func (*DeleteNodeResponse) ProtoMessage()

func (*DeleteNodeResponse) Reset 

func (m *DeleteNodeResponse) Reset()

func (*DeleteNodeResponse) String 

func (m *DeleteNodeResponse) String() string

func (*DeleteNodeResponse) Validate 

func (this *DeleteNodeResponse) Validate() error

type ErrorThrower 

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

type FileKeyManager 

type FileKeyManager struct {
	FileKeyManagerHandler
}

func (*FileKeyManager) GetEncryptionKey 

func (h *FileKeyManager) GetEncryptionKey(ctx context.Context, in *GetEncryptionKeyRequest, out *GetEncryptionKeyResponse) error

type FileKeyManagerClient 

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

func NewFileKeyManagerClient 

func NewFileKeyManagerClient(serviceName string, c client.Client) FileKeyManagerClient

type FileKeyManagerHandler 

type FileKeyManagerHandler interface {
	GetEncryptionKey(context.Context, *GetEncryptionKeyRequest, *GetEncryptionKeyResponse) error
}

type FlushSessionRequest added in v1.0.0 

type FlushSessionRequest struct {
	Session *IndexationSession `protobuf:"bytes,1,opt,name=Session" json:"Session,omitempty"`
}

func (*FlushSessionRequest) Descriptor added in v1.0.0 

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

func (*FlushSessionRequest) GetSession added in v1.0.0 

func (m *FlushSessionRequest) GetSession() *IndexationSession

func (*FlushSessionRequest) ProtoMessage added in v1.0.0 

func (*FlushSessionRequest) ProtoMessage()

func (*FlushSessionRequest) Reset added in v1.0.0 

func (m *FlushSessionRequest) Reset()

func (*FlushSessionRequest) String added in v1.0.0 

func (m *FlushSessionRequest) String() string

func (*FlushSessionRequest) Validate 

func (this *FlushSessionRequest) Validate() error

type FlushSessionResponse added in v1.0.0 

type FlushSessionResponse struct {
	Session *IndexationSession `protobuf:"bytes,1,opt,name=Session" json:"Session,omitempty"`
}

func (*FlushSessionResponse) Descriptor added in v1.0.0 

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

func (*FlushSessionResponse) GetSession added in v1.0.0 

func (m *FlushSessionResponse) GetSession() *IndexationSession

func (*FlushSessionResponse) ProtoMessage added in v1.0.0 

func (*FlushSessionResponse) ProtoMessage()

func (*FlushSessionResponse) Reset added in v1.0.0 

func (m *FlushSessionResponse) Reset()

func (*FlushSessionResponse) String added in v1.0.0 

func (m *FlushSessionResponse) String() string

func (*FlushSessionResponse) Validate 

func (this *FlushSessionResponse) Validate() error

type GeoPoint 

type GeoPoint struct {
	Lat float64 `protobuf:"fixed64,1,opt,name=Lat" json:"Lat,omitempty"`
	Lon float64 `protobuf:"fixed64,2,opt,name=Lon" json:"Lon,omitempty"`
}

func (*GeoPoint) Descriptor 

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

func (*GeoPoint) GetLat 

func (m *GeoPoint) GetLat() float64

func (*GeoPoint) GetLon 

func (m *GeoPoint) GetLon() float64

func (*GeoPoint) ProtoMessage 

func (*GeoPoint) ProtoMessage()

func (*GeoPoint) Reset 

func (m *GeoPoint) Reset()

func (*GeoPoint) String 

func (m *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" json:"Center,omitempty"`
	// Example formats supported:
	// "5in" "5inch" "7yd" "7yards" "9ft" "9feet" "11km" "11kilometers"
	// "3nm" "3nauticalmiles" "13mm" "13millimeters" "15cm" "15centimeters"
	// "17mi" "17miles" "19m" "19meters"
	// If the unit cannot be determined, the entire string is parsed and the
	// unit of meters is assumed.
	Distance string `protobuf:"bytes,2,opt,name=Distance" json:"Distance,omitempty"`
	// Or use a bounding box with TopLeft and BottomRight points
	TopLeft     *GeoPoint `protobuf:"bytes,3,opt,name=TopLeft" json:"TopLeft,omitempty"`
	BottomRight *GeoPoint `protobuf:"bytes,4,opt,name=BottomRight" json:"BottomRight,omitempty"`
}

func (*GeoQuery) Descriptor 

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

func (*GeoQuery) GetBottomRight 

func (m *GeoQuery) GetBottomRight() *GeoPoint

func (*GeoQuery) GetCenter 

func (m *GeoQuery) GetCenter() *GeoPoint

func (*GeoQuery) GetDistance 

func (m *GeoQuery) GetDistance() string

func (*GeoQuery) GetTopLeft 

func (m *GeoQuery) GetTopLeft() *GeoPoint

func (*GeoQuery) ProtoMessage 

func (*GeoQuery) ProtoMessage()

func (*GeoQuery) Reset 

func (m *GeoQuery) Reset()

func (*GeoQuery) String 

func (m *GeoQuery) String() string

func (*GeoQuery) Validate 

func (this *GeoQuery) Validate() error

type GetEncryptionKeyRequest 

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

func (*GetEncryptionKeyRequest) Descriptor 

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

func (*GetEncryptionKeyRequest) GetCreate 

func (m *GetEncryptionKeyRequest) GetCreate() bool

func (*GetEncryptionKeyRequest) GetNode 

func (m *GetEncryptionKeyRequest) GetNode() *Node

func (*GetEncryptionKeyRequest) GetPassword 

func (m *GetEncryptionKeyRequest) GetPassword() string

func (*GetEncryptionKeyRequest) GetUser 

func (m *GetEncryptionKeyRequest) GetUser() string

func (*GetEncryptionKeyRequest) ProtoMessage 

func (*GetEncryptionKeyRequest) ProtoMessage()

func (*GetEncryptionKeyRequest) Reset 

func (m *GetEncryptionKeyRequest) Reset()

func (*GetEncryptionKeyRequest) String 

func (m *GetEncryptionKeyRequest) String() string

func (*GetEncryptionKeyRequest) Validate 

func (this *GetEncryptionKeyRequest) Validate() error

type GetEncryptionKeyResponse 

type GetEncryptionKeyResponse struct {
	Key []byte `protobuf:"bytes,1,opt,name=Key,proto3" json:"Key,omitempty"`
}

func (*GetEncryptionKeyResponse) Descriptor 

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

func (*GetEncryptionKeyResponse) GetKey 

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

func (*GetEncryptionKeyResponse) ProtoMessage 

func (*GetEncryptionKeyResponse) ProtoMessage()

func (*GetEncryptionKeyResponse) Reset 

func (m *GetEncryptionKeyResponse) Reset()

func (*GetEncryptionKeyResponse) String 

func (m *GetEncryptionKeyResponse) String() string

func (*GetEncryptionKeyResponse) Validate 

func (this *GetEncryptionKeyResponse) Validate() error

type HeadVersionRequest 

type HeadVersionRequest struct {
	Node      *Node  `protobuf:"bytes,1,opt,name=Node" json:"Node,omitempty"`
	VersionId string `protobuf:"bytes,2,opt,name=VersionId" json:"VersionId,omitempty"`
}

func (*HeadVersionRequest) Descriptor 

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

func (*HeadVersionRequest) GetNode 

func (m *HeadVersionRequest) GetNode() *Node

func (*HeadVersionRequest) GetVersionId 

func (m *HeadVersionRequest) GetVersionId() string

func (*HeadVersionRequest) ProtoMessage 

func (*HeadVersionRequest) ProtoMessage()

func (*HeadVersionRequest) Reset 

func (m *HeadVersionRequest) Reset()

func (*HeadVersionRequest) String 

func (m *HeadVersionRequest) String() string

func (*HeadVersionRequest) Validate 

func (this *HeadVersionRequest) Validate() error

type HeadVersionResponse 

type HeadVersionResponse struct {
	Version *ChangeLog `protobuf:"bytes,1,opt,name=Version" json:"Version,omitempty"`
}

func (*HeadVersionResponse) Descriptor 

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

func (*HeadVersionResponse) GetVersion 

func (m *HeadVersionResponse) GetVersion() *ChangeLog

func (*HeadVersionResponse) ProtoMessage 

func (*HeadVersionResponse) ProtoMessage()

func (*HeadVersionResponse) Reset 

func (m *HeadVersionResponse) Reset()

func (*HeadVersionResponse) String 

func (m *HeadVersionResponse) String() string

func (*HeadVersionResponse) Validate 

func (this *HeadVersionResponse) Validate() error

type IndexEvent added in v1.5.0 

type IndexEvent struct {
	ErrorDetected     bool   `protobuf:"varint,1,opt,name=ErrorDetected" json:"ErrorDetected,omitempty"`
	DataSourceName    string `protobuf:"bytes,2,opt,name=DataSourceName" json:"DataSourceName,omitempty"`
	ErrorPath         string `protobuf:"bytes,3,opt,name=ErrorPath" json:"ErrorPath,omitempty"`
	SessionForceClose string `protobuf:"bytes,4,opt,name=SessionForceClose" json:"SessionForceClose,omitempty"`
}

func (*IndexEvent) Descriptor added in v1.5.0 

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

func (*IndexEvent) GetDataSourceName added in v1.5.0 

func (m *IndexEvent) GetDataSourceName() string

func (*IndexEvent) GetErrorDetected added in v1.5.0 

func (m *IndexEvent) GetErrorDetected() bool

func (*IndexEvent) GetErrorPath added in v1.5.0 

func (m *IndexEvent) GetErrorPath() string

func (*IndexEvent) GetSessionForceClose added in v1.5.0 

func (m *IndexEvent) GetSessionForceClose() string

func (*IndexEvent) ProtoMessage added in v1.5.0 

func (*IndexEvent) ProtoMessage()

func (*IndexEvent) Reset added in v1.5.0 

func (m *IndexEvent) Reset()

func (*IndexEvent) String added in v1.5.0 

func (m *IndexEvent) String() string

func (*IndexEvent) Validate 

func (this *IndexEvent) Validate() error

type IndexationOperation 

type IndexationOperation struct {
	SessionUuid string `protobuf:"bytes,1,opt,name=SessionUuid" json:"SessionUuid,omitempty"`
	Description string `protobuf:"bytes,2,opt,name=Description" json:"Description,omitempty"`
	Cursor      int64  `protobuf:"varint,3,opt,name=Cursor" json:"Cursor,omitempty"`
}

func (*IndexationOperation) Descriptor 

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

func (*IndexationOperation) GetCursor 

func (m *IndexationOperation) GetCursor() int64

func (*IndexationOperation) GetDescription 

func (m *IndexationOperation) GetDescription() string

func (*IndexationOperation) GetSessionUuid 

func (m *IndexationOperation) GetSessionUuid() string

func (*IndexationOperation) ProtoMessage 

func (*IndexationOperation) ProtoMessage()

func (*IndexationOperation) Reset 

func (m *IndexationOperation) Reset()

func (*IndexationOperation) String 

func (m *IndexationOperation) String() string

func (*IndexationOperation) Validate 

func (this *IndexationOperation) Validate() error

type IndexationSession 

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

func (*IndexationSession) Descriptor 

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

func (*IndexationSession) GetCurrentOperationCount 

func (m *IndexationSession) GetCurrentOperationCount() int64

func (*IndexationSession) GetDescription 

func (m *IndexationSession) GetDescription() string

func (*IndexationSession) GetExpectedOperationsCount 

func (m *IndexationSession) GetExpectedOperationsCount() int64

func (*IndexationSession) GetRootNode 

func (m *IndexationSession) GetRootNode() *Node

func (*IndexationSession) GetSilent 

func (m *IndexationSession) GetSilent() bool

func (*IndexationSession) GetUuid 

func (m *IndexationSession) GetUuid() string

func (*IndexationSession) ProtoMessage 

func (*IndexationSession) ProtoMessage()

func (*IndexationSession) Reset 

func (m *IndexationSession) Reset()

func (*IndexationSession) String 

func (m *IndexationSession) String() string

func (*IndexationSession) Validate 

func (this *IndexationSession) Validate() error

type ListNodesRequest 

type ListNodesRequest struct {
	// Main node used as a parent
	Node *Node `protobuf:"bytes,1,opt,name=Node" json:"Node,omitempty"`
	// Send back all children of the node
	Recursive bool `protobuf:"varint,2,opt,name=Recursive" json:"Recursive,omitempty"`
	// Send back a list of parent nodes, until the root, including the original node
	Ancestors bool `protobuf:"varint,3,opt,name=Ancestors" json:"Ancestors,omitempty"`
	// Sends the list of versions for a given node
	WithVersions bool `protobuf:"varint,7,opt,name=WithVersions" json:"WithVersions,omitempty"`
	// Sends the list of commits for a given node (not used)
	WithCommits bool `protobuf:"varint,8,opt,name=WithCommits" json:"WithCommits,omitempty"`
	// Limit the number of results
	Limit int64 `protobuf:"varint,4,opt,name=Limit" json:"Limit,omitempty"`
	// Start listing at a given position
	Offset int64 `protobuf:"varint,5,opt,name=Offset" json:"Offset,omitempty"`
	// Filter by node type (LEAF / COLLECTION)
	FilterType NodeType `protobuf:"varint,6,opt,name=FilterType,enum=tree.NodeType" json:"FilterType,omitempty"`
}

func (*ListNodesRequest) Descriptor 

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

func (*ListNodesRequest) GetAncestors 

func (m *ListNodesRequest) GetAncestors() bool

func (*ListNodesRequest) GetFilterType 

func (m *ListNodesRequest) GetFilterType() NodeType

func (*ListNodesRequest) GetLimit 

func (m *ListNodesRequest) GetLimit() int64

func (*ListNodesRequest) GetNode 

func (m *ListNodesRequest) GetNode() *Node

func (*ListNodesRequest) GetOffset 

func (m *ListNodesRequest) GetOffset() int64

func (*ListNodesRequest) GetRecursive 

func (m *ListNodesRequest) GetRecursive() bool

func (*ListNodesRequest) GetWithCommits 

func (m *ListNodesRequest) GetWithCommits() bool

func (*ListNodesRequest) GetWithVersions 

func (m *ListNodesRequest) GetWithVersions() bool

func (*ListNodesRequest) ProtoMessage 

func (*ListNodesRequest) ProtoMessage()

func (*ListNodesRequest) Reset 

func (m *ListNodesRequest) Reset()

func (*ListNodesRequest) String 

func (m *ListNodesRequest) String() string

func (*ListNodesRequest) Validate 

func (this *ListNodesRequest) Validate() error

type ListNodesResponse 

type ListNodesResponse struct {
	Node *Node `protobuf:"bytes,1,opt,name=Node" json:"Node,omitempty"`
}

func (*ListNodesResponse) Descriptor 

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

func (*ListNodesResponse) GetNode 

func (m *ListNodesResponse) GetNode() *Node

func (*ListNodesResponse) ProtoMessage 

func (*ListNodesResponse) ProtoMessage()

func (*ListNodesResponse) Reset 

func (m *ListNodesResponse) Reset()

func (*ListNodesResponse) String 

func (m *ListNodesResponse) String() string

func (*ListNodesResponse) Validate 

func (this *ListNodesResponse) Validate() error

type ListVersionsRequest 

type ListVersionsRequest struct {
	Node *Node `protobuf:"bytes,1,opt,name=Node" json:"Node,omitempty"`
}

func (*ListVersionsRequest) Descriptor 

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

func (*ListVersionsRequest) GetNode 

func (m *ListVersionsRequest) GetNode() *Node

func (*ListVersionsRequest) ProtoMessage 

func (*ListVersionsRequest) ProtoMessage()

func (*ListVersionsRequest) Reset 

func (m *ListVersionsRequest) Reset()

func (*ListVersionsRequest) String 

func (m *ListVersionsRequest) String() string

func (*ListVersionsRequest) Validate 

func (this *ListVersionsRequest) Validate() error

type ListVersionsResponse 

type ListVersionsResponse struct {
	Version *ChangeLog `protobuf:"bytes,1,opt,name=Version" json:"Version,omitempty"`
}

func (*ListVersionsResponse) Descriptor 

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

func (*ListVersionsResponse) GetVersion 

func (m *ListVersionsResponse) GetVersion() *ChangeLog

func (*ListVersionsResponse) ProtoMessage 

func (*ListVersionsResponse) ProtoMessage()

func (*ListVersionsResponse) Reset 

func (m *ListVersionsResponse) Reset()

func (*ListVersionsResponse) String 

func (m *ListVersionsResponse) String() string

func (*ListVersionsResponse) Validate 

func (this *ListVersionsResponse) Validate() error

type Node 

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

func BuildAncestorsList added in v1.4.1 

func BuildAncestorsList(ctx context.Context, treeClient NodeProviderClient, node *Node) (parentUuids []*Node, err error)

BuildAncestorsList uses ListNodes with Ancestors flag set to build the list of parent nodes.

func BuildAncestorsListOrParent added in v1.4.1 

func BuildAncestorsListOrParent(ctx context.Context, treeClient NodeProviderClient, node *Node) (parentUuids []*Node, err error)

Recursive listing to build ancestors list when the node does not exists yet : try to find all existing parents

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 added in v1.0.0 

func (node *Node) Clone() *Node

Clone node to avoid modifying it directly

func (*Node) Descriptor 

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

func (*Node) GetAppearsIn 

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

func (*Node) GetCommits 

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

func (*Node) GetEtag 

func (m *Node) GetEtag() string

func (*Node) GetMTime 

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

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

func (*Node) GetModTime 

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

GetModTime returns the last modification timestamp

func (*Node) GetMode 

func (m *Node) GetMode() int32

func (*Node) GetPath 

func (m *Node) GetPath() string

func (*Node) GetSize 

func (m *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 (m *Node) GetType() NodeType

func (*Node) GetUuid 

func (m *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 added in v1.5.0 

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

MarshalLogObject implements custom marshalling for logs

func (*Node) ProtoMessage 

func (*Node) ProtoMessage()

func (*Node) Reset 

func (m *Node) Reset()

func (*Node) SetMeta 

func (node *Node) SetMeta(namespace string, jsonMeta interface{}) (err error)

SetMeta sets a metadata by marshalling to JSON

func (*Node) String 

func (m *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 added in v1.5.0 

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

type NodeChangeEvent 

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

func (*NodeChangeEvent) Descriptor 

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

func (*NodeChangeEvent) GetMetadata 

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

func (*NodeChangeEvent) GetOptimistic added in v1.5.0 

func (m *NodeChangeEvent) GetOptimistic() bool

func (*NodeChangeEvent) GetSilent added in v1.5.0 

func (m *NodeChangeEvent) GetSilent() bool

func (*NodeChangeEvent) GetSource 

func (m *NodeChangeEvent) GetSource() *Node

func (*NodeChangeEvent) GetTarget 

func (m *NodeChangeEvent) GetTarget() *Node

func (*NodeChangeEvent) GetType 

func (m *NodeChangeEvent) GetType() NodeChangeEvent_EventType

func (*NodeChangeEvent) ProtoMessage 

func (*NodeChangeEvent) ProtoMessage()

func (*NodeChangeEvent) Reset 

func (m *NodeChangeEvent) Reset()

func (*NodeChangeEvent) String 

func (m *NodeChangeEvent) String() string

func (*NodeChangeEvent) Validate 

func (this *NodeChangeEvent) Validate() error

func (*NodeChangeEvent) Zap 

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

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

type NodeChangeEvent_EventType 

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

func (NodeChangeEvent_EventType) EnumDescriptor 

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

func (NodeChangeEvent_EventType) String 

func (x NodeChangeEvent_EventType) String() string

type NodeChangesStreamer 

type NodeChangesStreamer struct {
	NodeChangesStreamerHandler
}

func (*NodeChangesStreamer) StreamChanges 

func (h *NodeChangesStreamer) StreamChanges(ctx context.Context, stream server.Streamer) error

type NodeChangesStreamerClient 

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

func NewNodeChangesStreamerClient 

func NewNodeChangesStreamerClient(serviceName string, c client.Client) NodeChangesStreamerClient

type NodeChangesStreamerHandler 

type NodeChangesStreamerHandler interface {
	StreamChanges(context.Context, *StreamChangesRequest, NodeChangesStreamer_StreamChangesStream) error
}

type NodeChangesStreamer_StreamChangesClient 

type NodeChangesStreamer_StreamChangesClient interface {
	SendMsg(interface{}) error
	RecvMsg(interface{}) error
	Close() error
	Recv() (*NodeChangeEvent, error)
}

type NodeChangesStreamer_StreamChangesStream 

type NodeChangesStreamer_StreamChangesStream interface {
	SendMsg(interface{}) error
	RecvMsg(interface{}) error
	Close() error
	Send(*NodeChangeEvent) error
}

type NodeContentReader 

type NodeContentReader struct {
	NodeContentReaderHandler
}

type NodeContentReaderClient 

type NodeContentReaderClient interface {
}

func NewNodeContentReaderClient 

func NewNodeContentReaderClient(serviceName string, c client.Client) NodeContentReaderClient

type NodeContentReaderHandler 

type NodeContentReaderHandler interface {
}

type NodeContentWriter 

type NodeContentWriter struct {
	NodeContentWriterHandler
}

type NodeContentWriterClient 

type NodeContentWriterClient interface {
}

func NewNodeContentWriterClient 

func NewNodeContentWriterClient(serviceName string, c client.Client) NodeContentWriterClient

type NodeContentWriterHandler 

type NodeContentWriterHandler interface {
}

type NodeEventsProvider 

type NodeEventsProvider struct {
	NodeEventsProviderHandler
}

func (*NodeEventsProvider) WatchNode 

func (h *NodeEventsProvider) WatchNode(ctx context.Context, stream server.Streamer) error

type NodeEventsProviderClient 

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

func NewNodeEventsProviderClient 

func NewNodeEventsProviderClient(serviceName string, c client.Client) NodeEventsProviderClient

type NodeEventsProviderHandler 

type NodeEventsProviderHandler interface {
	WatchNode(context.Context, *WatchNodeRequest, NodeEventsProvider_WatchNodeStream) error
}

type NodeEventsProvider_WatchNodeClient 

type NodeEventsProvider_WatchNodeClient interface {
	SendMsg(interface{}) error
	RecvMsg(interface{}) error
	Close() error
	Recv() (*WatchNodeResponse, error)
}

type NodeEventsProvider_WatchNodeStream 

type NodeEventsProvider_WatchNodeStream interface {
	SendMsg(interface{}) error
	RecvMsg(interface{}) error
	Close() error
	Send(*WatchNodeResponse) error
}

type NodeProvider 

type NodeProvider struct {
	NodeProviderHandler
}

func (*NodeProvider) ListNodes 

func (h *NodeProvider) ListNodes(ctx context.Context, stream server.Streamer) error

func (*NodeProvider) ReadNode 

func (h *NodeProvider) ReadNode(ctx context.Context, in *ReadNodeRequest, out *ReadNodeResponse) error

type NodeProviderClient 

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

func NewNodeProviderClient 

func NewNodeProviderClient(serviceName string, c client.Client) NodeProviderClient

type NodeProviderHandler 

type NodeProviderHandler interface {
	ReadNode(context.Context, *ReadNodeRequest, *ReadNodeResponse) error
	ListNodes(context.Context, *ListNodesRequest, NodeProvider_ListNodesStream) error
}

type NodeProviderMock 

type NodeProviderMock struct {
	Nodes map[string]Node
}

func NewNodeProviderMock 

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

func (*NodeProviderMock) ListNodes 

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

func (*NodeProviderMock) ReadNode 

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

type NodeProviderStreamer 

type NodeProviderStreamer struct {
	NodeProviderStreamerHandler
}

func (*NodeProviderStreamer) ReadNodeStream 

func (h *NodeProviderStreamer) ReadNodeStream(ctx context.Context, stream server.Streamer) error

type NodeProviderStreamerClient 

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

func NewNodeProviderStreamerClient 

func NewNodeProviderStreamerClient(serviceName string, c client.Client) NodeProviderStreamerClient

type NodeProviderStreamerHandler 

type NodeProviderStreamerHandler interface {
	ReadNodeStream(context.Context, NodeProviderStreamer_ReadNodeStreamStream) error
}

type NodeProviderStreamer_ReadNodeStreamClient 

type NodeProviderStreamer_ReadNodeStreamClient interface {
	SendMsg(interface{}) error
	RecvMsg(interface{}) error
	Close() error
	Send(*ReadNodeRequest) error
	Recv() (*ReadNodeResponse, error)
}

type NodeProviderStreamer_ReadNodeStreamStream 

type NodeProviderStreamer_ReadNodeStreamStream interface {
	SendMsg(interface{}) error
	RecvMsg(interface{}) error
	Close() error
	Send(*ReadNodeResponse) error
	Recv() (*ReadNodeRequest, error)
}

type NodeProvider_ListNodesClient 

type NodeProvider_ListNodesClient interface {
	SendMsg(interface{}) error
	RecvMsg(interface{}) error
	Close() error
	Recv() (*ListNodesResponse, error)
}

type NodeProvider_ListNodesStream 

type NodeProvider_ListNodesStream interface {
	SendMsg(interface{}) error
	RecvMsg(interface{}) error
	Close() error
	Send(*ListNodesResponse) error
}

type NodeReceiver 

type NodeReceiver struct {
	NodeReceiverHandler
}

func (*NodeReceiver) CreateNode 

func (h *NodeReceiver) CreateNode(ctx context.Context, in *CreateNodeRequest, out *CreateNodeResponse) error

func (*NodeReceiver) DeleteNode 

func (h *NodeReceiver) DeleteNode(ctx context.Context, in *DeleteNodeRequest, out *DeleteNodeResponse) error

func (*NodeReceiver) UpdateNode 

func (h *NodeReceiver) UpdateNode(ctx context.Context, in *UpdateNodeRequest, out *UpdateNodeResponse) error

type NodeReceiverClient 

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

func NewNodeReceiverClient 

func NewNodeReceiverClient(serviceName string, c client.Client) NodeReceiverClient

type NodeReceiverHandler 

type NodeReceiverHandler interface {
	CreateNode(context.Context, *CreateNodeRequest, *CreateNodeResponse) error
	UpdateNode(context.Context, *UpdateNodeRequest, *UpdateNodeResponse) error
	DeleteNode(context.Context, *DeleteNodeRequest, *DeleteNodeResponse) error
}

type NodeReceiverMock 

type NodeReceiverMock struct {
	Nodes map[string]Node
}

func (*NodeReceiverMock) CreateNode 

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

func (*NodeReceiverMock) DeleteNode 

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

func (*NodeReceiverMock) UpdateNode 

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

type NodeReceiverStream 

type NodeReceiverStream struct {
	NodeReceiverStreamHandler
}

func (*NodeReceiverStream) CreateNodeStream 

func (h *NodeReceiverStream) CreateNodeStream(ctx context.Context, stream server.Streamer) error

func (*NodeReceiverStream) DeleteNodeStream 

func (h *NodeReceiverStream) DeleteNodeStream(ctx context.Context, stream server.Streamer) error

func (*NodeReceiverStream) UpdateNodeStream 

func (h *NodeReceiverStream) UpdateNodeStream(ctx context.Context, stream server.Streamer) error

type NodeReceiverStreamClient 

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

func NewNodeReceiverStreamClient 

func NewNodeReceiverStreamClient(serviceName string, c client.Client) NodeReceiverStreamClient

type NodeReceiverStreamHandler 

type NodeReceiverStreamHandler interface {
	CreateNodeStream(context.Context, NodeReceiverStream_CreateNodeStreamStream) error
	UpdateNodeStream(context.Context, NodeReceiverStream_UpdateNodeStreamStream) error
	DeleteNodeStream(context.Context, NodeReceiverStream_DeleteNodeStreamStream) error
}

type NodeReceiverStream_CreateNodeStreamClient 

type NodeReceiverStream_CreateNodeStreamClient interface {
	SendMsg(interface{}) error
	RecvMsg(interface{}) error
	Close() error
	Send(*CreateNodeRequest) error
	Recv() (*CreateNodeResponse, error)
}

type NodeReceiverStream_CreateNodeStreamStream 

type NodeReceiverStream_CreateNodeStreamStream interface {
	SendMsg(interface{}) error
	RecvMsg(interface{}) error
	Close() error
	Send(*CreateNodeResponse) error
	Recv() (*CreateNodeRequest, error)
}

type NodeReceiverStream_DeleteNodeStreamClient 

type NodeReceiverStream_DeleteNodeStreamClient interface {
	SendMsg(interface{}) error
	RecvMsg(interface{}) error
	Close() error
	Send(*DeleteNodeRequest) error
	Recv() (*DeleteNodeResponse, error)
}

type NodeReceiverStream_DeleteNodeStreamStream 

type NodeReceiverStream_DeleteNodeStreamStream interface {
	SendMsg(interface{}) error
	RecvMsg(interface{}) error
	Close() error
	Send(*DeleteNodeResponse) error
	Recv() (*DeleteNodeRequest, error)
}

type NodeReceiverStream_UpdateNodeStreamClient 

type NodeReceiverStream_UpdateNodeStreamClient interface {
	SendMsg(interface{}) error
	RecvMsg(interface{}) error
	Close() error
	Send(*UpdateNodeRequest) error
	Recv() (*UpdateNodeResponse, error)
}

type NodeReceiverStream_UpdateNodeStreamStream 

type NodeReceiverStream_UpdateNodeStreamStream interface {
	SendMsg(interface{}) error
	RecvMsg(interface{}) error
	Close() error
	Send(*UpdateNodeResponse) error
	Recv() (*UpdateNodeRequest, error)
}

type NodeType 

type NodeType int32

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

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

func (NodeType) EnumDescriptor 

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

func (NodeType) String 

func (x NodeType) String() string

type NodeVersioner 

type NodeVersioner struct {
	NodeVersionerHandler
}

func (*NodeVersioner) CreateVersion 

func (h *NodeVersioner) CreateVersion(ctx context.Context, in *CreateVersionRequest, out *CreateVersionResponse) error

func (*NodeVersioner) HeadVersion 

func (h *NodeVersioner) HeadVersion(ctx context.Context, in *HeadVersionRequest, out *HeadVersionResponse) error

func (*NodeVersioner) ListVersions 

func (h *NodeVersioner) ListVersions(ctx context.Context, stream server.Streamer) error

func (*NodeVersioner) PruneVersions 

func (h *NodeVersioner) PruneVersions(ctx context.Context, in *PruneVersionsRequest, out *PruneVersionsResponse) error

func (*NodeVersioner) StoreVersion 

func (h *NodeVersioner) StoreVersion(ctx context.Context, in *StoreVersionRequest, out *StoreVersionResponse) error

type NodeVersionerClient 

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

func NewNodeVersionerClient 

func NewNodeVersionerClient(serviceName string, c client.Client) NodeVersionerClient

type NodeVersionerHandler 

type NodeVersionerHandler interface {
	CreateVersion(context.Context, *CreateVersionRequest, *CreateVersionResponse) error
	StoreVersion(context.Context, *StoreVersionRequest, *StoreVersionResponse) error
	ListVersions(context.Context, *ListVersionsRequest, NodeVersioner_ListVersionsStream) error
	HeadVersion(context.Context, *HeadVersionRequest, *HeadVersionResponse) error
	PruneVersions(context.Context, *PruneVersionsRequest, *PruneVersionsResponse) error
}

type NodeVersioner_ListVersionsClient 

type NodeVersioner_ListVersionsClient interface {
	SendMsg(interface{}) error
	RecvMsg(interface{}) error
	Close() error
	Recv() (*ListVersionsResponse, error)
}

type NodeVersioner_ListVersionsStream 

type NodeVersioner_ListVersionsStream interface {
	SendMsg(interface{}) error
	RecvMsg(interface{}) error
	Close() error
	Send(*ListVersionsResponse) error
}

type OpenSessionRequest 

type OpenSessionRequest struct {
	Session *IndexationSession `protobuf:"bytes,1,opt,name=Session" json:"Session,omitempty"`
}

func (*OpenSessionRequest) Descriptor 

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

func (*OpenSessionRequest) GetSession 

func (m *OpenSessionRequest) GetSession() *IndexationSession

func (*OpenSessionRequest) ProtoMessage 

func (*OpenSessionRequest) ProtoMessage()

func (*OpenSessionRequest) Reset 

func (m *OpenSessionRequest) Reset()

func (*OpenSessionRequest) String 

func (m *OpenSessionRequest) String() string

func (*OpenSessionRequest) Validate 

func (this *OpenSessionRequest) Validate() error

type OpenSessionResponse 

type OpenSessionResponse struct {
	Session *IndexationSession `protobuf:"bytes,1,opt,name=Session" json:"Session,omitempty"`
}

func (*OpenSessionResponse) Descriptor 

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

func (*OpenSessionResponse) GetSession 

func (m *OpenSessionResponse) GetSession() *IndexationSession

func (*OpenSessionResponse) ProtoMessage 

func (*OpenSessionResponse) ProtoMessage()

func (*OpenSessionResponse) Reset 

func (m *OpenSessionResponse) Reset()

func (*OpenSessionResponse) String 

func (m *OpenSessionResponse) String() string

func (*OpenSessionResponse) Validate 

func (this *OpenSessionResponse) Validate() error

type PruneVersionsRequest 

type PruneVersionsRequest struct {
	UniqueNode      *Node `protobuf:"bytes,1,opt,name=UniqueNode" json:"UniqueNode,omitempty"`
	AllDeletedNodes bool  `protobuf:"varint,2,opt,name=AllDeletedNodes" json:"AllDeletedNodes,omitempty"`
}

func (*PruneVersionsRequest) Descriptor 

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

func (*PruneVersionsRequest) GetAllDeletedNodes 

func (m *PruneVersionsRequest) GetAllDeletedNodes() bool

func (*PruneVersionsRequest) GetUniqueNode 

func (m *PruneVersionsRequest) GetUniqueNode() *Node

func (*PruneVersionsRequest) ProtoMessage 

func (*PruneVersionsRequest) ProtoMessage()

func (*PruneVersionsRequest) Reset 

func (m *PruneVersionsRequest) Reset()

func (*PruneVersionsRequest) String 

func (m *PruneVersionsRequest) String() string

func (*PruneVersionsRequest) Validate 

func (this *PruneVersionsRequest) Validate() error

type PruneVersionsResponse 

type PruneVersionsResponse struct {
	DeletedVersions []string `protobuf:"bytes,1,rep,name=DeletedVersions" json:"DeletedVersions,omitempty"`
}

func (*PruneVersionsResponse) Descriptor 

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

func (*PruneVersionsResponse) GetDeletedVersions 

func (m *PruneVersionsResponse) GetDeletedVersions() []string

func (*PruneVersionsResponse) ProtoMessage 

func (*PruneVersionsResponse) ProtoMessage()

func (*PruneVersionsResponse) Reset 

func (m *PruneVersionsResponse) Reset()

func (*PruneVersionsResponse) String 

func (m *PruneVersionsResponse) String() string

func (*PruneVersionsResponse) Validate 

func (this *PruneVersionsResponse) Validate() error

type PutSyncChangeResponse 

type PutSyncChangeResponse struct {
	Success bool   `protobuf:"varint,1,opt,name=success" json:"success,omitempty"`
	Msg     string `protobuf:"bytes,2,opt,name=msg" json:"msg,omitempty"`
}

func (*PutSyncChangeResponse) Descriptor 

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

func (*PutSyncChangeResponse) GetMsg 

func (m *PutSyncChangeResponse) GetMsg() string

func (*PutSyncChangeResponse) GetSuccess 

func (m *PutSyncChangeResponse) GetSuccess() bool

func (*PutSyncChangeResponse) ProtoMessage 

func (*PutSyncChangeResponse) ProtoMessage()

func (*PutSyncChangeResponse) Reset 

func (m *PutSyncChangeResponse) Reset()

func (*PutSyncChangeResponse) String 

func (m *PutSyncChangeResponse) String() string

func (*PutSyncChangeResponse) Validate 

func (this *PutSyncChangeResponse) Validate() error

type Query 

type Query struct {
	// Limit to a given subtree
	PathPrefix []string `protobuf:"bytes,1,rep,name=PathPrefix" json:"PathPrefix,omitempty"`
	// Range for size
	MinSize int64 `protobuf:"varint,2,opt,name=MinSize" json:"MinSize,omitempty"`
	MaxSize int64 `protobuf:"varint,3,opt,name=MaxSize" json:"MaxSize,omitempty"`
	// Range for date
	MinDate int64 `protobuf:"varint,4,opt,name=MinDate" json:"MinDate,omitempty"`
	MaxDate int64 `protobuf:"varint,5,opt,name=MaxDate" json:"MaxDate,omitempty"`
	// Limit to a given node type
	Type NodeType `protobuf:"varint,6,opt,name=Type,enum=tree.NodeType" json:"Type,omitempty"`
	// Search in filename
	FileName string `protobuf:"bytes,7,opt,name=FileName" json:"FileName,omitempty"`
	// Search in content
	Content string `protobuf:"bytes,8,opt,name=Content" json:"Content,omitempty"`
	// Free Query String (for metadata)
	FreeString string `protobuf:"bytes,9,opt,name=FreeString" json:"FreeString,omitempty"`
	// Search files by extension
	Extension string `protobuf:"bytes,10,opt,name=Extension" json:"Extension,omitempty"`
	// Search geographically
	GeoQuery *GeoQuery `protobuf:"bytes,11,opt,name=GeoQuery" json:"GeoQuery,omitempty"`
}

Search Queries

func (*Query) Descriptor 

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

func (*Query) GetContent 

func (m *Query) GetContent() string

func (*Query) GetExtension 

func (m *Query) GetExtension() string

func (*Query) GetFileName 

func (m *Query) GetFileName() string

func (*Query) GetFreeString 

func (m *Query) GetFreeString() string

func (*Query) GetGeoQuery 

func (m *Query) GetGeoQuery() *GeoQuery

func (*Query) GetMaxDate 

func (m *Query) GetMaxDate() int64

func (*Query) GetMaxSize 

func (m *Query) GetMaxSize() int64

func (*Query) GetMinDate 

func (m *Query) GetMinDate() int64

func (*Query) GetMinSize 

func (m *Query) GetMinSize() int64

func (*Query) GetPathPrefix 

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

func (*Query) GetType 

func (m *Query) GetType() NodeType

func (*Query) ProtoMessage 

func (*Query) ProtoMessage()

func (*Query) Reset 

func (m *Query) Reset()

func (*Query) String 

func (m *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" json:"Node,omitempty"`
	// Gather commit information
	WithCommits bool `protobuf:"varint,2,opt,name=WithCommits" json:"WithCommits,omitempty"`
	// Get extended stats - For folders, computes ChildrenCount
	WithExtendedStats bool `protobuf:"varint,3,opt,name=WithExtendedStats" json:"WithExtendedStats,omitempty"`
	// Used internally for the router ReadNode request, stat the datasource instead of index
	ObjectStats bool `protobuf:"varint,4,opt,name=ObjectStats" json:"ObjectStats,omitempty"`
}

Request / Responses Messages

func (*ReadNodeRequest) Descriptor 

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

func (*ReadNodeRequest) GetNode 

func (m *ReadNodeRequest) GetNode() *Node

func (*ReadNodeRequest) GetObjectStats added in v1.5.0 

func (m *ReadNodeRequest) GetObjectStats() bool

func (*ReadNodeRequest) GetWithCommits 

func (m *ReadNodeRequest) GetWithCommits() bool

func (*ReadNodeRequest) GetWithExtendedStats added in v1.2.0 

func (m *ReadNodeRequest) GetWithExtendedStats() bool

func (*ReadNodeRequest) ProtoMessage 

func (*ReadNodeRequest) ProtoMessage()

func (*ReadNodeRequest) Reset 

func (m *ReadNodeRequest) Reset()

func (*ReadNodeRequest) String 

func (m *ReadNodeRequest) String() string

func (*ReadNodeRequest) Validate 

func (this *ReadNodeRequest) Validate() error

type ReadNodeResponse 

type ReadNodeResponse struct {
	Success bool  `protobuf:"varint,1,opt,name=Success" json:"Success,omitempty"`
	Node    *Node `protobuf:"bytes,2,opt,name=Node" json:"Node,omitempty"`
}

func (*ReadNodeResponse) Descriptor 

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

func (*ReadNodeResponse) GetNode 

func (m *ReadNodeResponse) GetNode() *Node

func (*ReadNodeResponse) GetSuccess 

func (m *ReadNodeResponse) GetSuccess() bool

func (*ReadNodeResponse) ProtoMessage 

func (*ReadNodeResponse) ProtoMessage()

func (*ReadNodeResponse) Reset 

func (m *ReadNodeResponse) Reset()

func (*ReadNodeResponse) String 

func (m *ReadNodeResponse) String() string

func (*ReadNodeResponse) Validate 

func (this *ReadNodeResponse) Validate() error

type SearchRequest 

type SearchRequest struct {
	// The query object
	Query *Query `protobuf:"bytes,1,opt,name=Query" json:"Query,omitempty"`
	// Limit the number of results
	Size int32 `protobuf:"varint,2,opt,name=Size" json:"Size,omitempty"`
	// Start at given position
	From int32 `protobuf:"varint,3,opt,name=From" json:"From,omitempty"`
	// Load node details
	Details bool `protobuf:"varint,4,opt,name=Details" json:"Details,omitempty"`
	// Facet search
	Facet string `protobuf:"bytes,5,opt,name=Facet" json:"Facet,omitempty"`
}

func (*SearchRequest) Descriptor 

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

func (*SearchRequest) GetDetails 

func (m *SearchRequest) GetDetails() bool

func (*SearchRequest) GetFacet 

func (m *SearchRequest) GetFacet() string

func (*SearchRequest) GetFrom 

func (m *SearchRequest) GetFrom() int32

func (*SearchRequest) GetQuery 

func (m *SearchRequest) GetQuery() *Query

func (*SearchRequest) GetSize 

func (m *SearchRequest) GetSize() int32

func (*SearchRequest) ProtoMessage 

func (*SearchRequest) ProtoMessage()

func (*SearchRequest) Reset 

func (m *SearchRequest) Reset()

func (*SearchRequest) String 

func (m *SearchRequest) String() string

func (*SearchRequest) Validate 

func (this *SearchRequest) Validate() error

type SearchResponse 

type SearchResponse struct {
	Node *Node `protobuf:"bytes,1,opt,name=Node" json:"Node,omitempty"`
}

func (*SearchResponse) Descriptor 

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

func (*SearchResponse) GetNode 

func (m *SearchResponse) GetNode() *Node

func (*SearchResponse) ProtoMessage 

func (*SearchResponse) ProtoMessage()

func (*SearchResponse) Reset 

func (m *SearchResponse) Reset()

func (*SearchResponse) String 

func (m *SearchResponse) String() string

func (*SearchResponse) Validate 

func (this *SearchResponse) Validate() error

type SearchSyncChangeRequest 

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

func (*SearchSyncChangeRequest) Descriptor 

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

func (*SearchSyncChangeRequest) GetFlatten 

func (m *SearchSyncChangeRequest) GetFlatten() bool

func (*SearchSyncChangeRequest) GetLastSeqOnly 

func (m *SearchSyncChangeRequest) GetLastSeqOnly() bool

func (*SearchSyncChangeRequest) GetPrefix 

func (m *SearchSyncChangeRequest) GetPrefix() string

func (*SearchSyncChangeRequest) GetSeq 

func (m *SearchSyncChangeRequest) GetSeq() uint64

func (*SearchSyncChangeRequest) ProtoMessage 

func (*SearchSyncChangeRequest) ProtoMessage()

func (*SearchSyncChangeRequest) Reset 

func (m *SearchSyncChangeRequest) Reset()

func (*SearchSyncChangeRequest) String 

func (m *SearchSyncChangeRequest) String() string

func (*SearchSyncChangeRequest) Validate 

func (this *SearchSyncChangeRequest) Validate() error

type Searcher 

type Searcher struct {
	SearcherHandler
}

func (*Searcher) Search 

func (h *Searcher) Search(ctx context.Context, stream server.Streamer) error

type SearcherClient 

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

func NewSearcherClient 

func NewSearcherClient(serviceName string, c client.Client) SearcherClient

type SearcherHandler 

type SearcherHandler interface {
	Search(context.Context, *SearchRequest, Searcher_SearchStream) error
}

type Searcher_SearchClient 

type Searcher_SearchClient interface {
	SendMsg(interface{}) error
	RecvMsg(interface{}) error
	Close() error
	Recv() (*SearchResponse, error)
}

type Searcher_SearchStream 

type Searcher_SearchStream interface {
	SendMsg(interface{}) error
	RecvMsg(interface{}) error
	Close() error
	Send(*SearchResponse) error
}

type SessionIndexer 

type SessionIndexer struct {
	SessionIndexerHandler
}

func (*SessionIndexer) CloseSession 

func (h *SessionIndexer) CloseSession(ctx context.Context, in *CloseSessionRequest, out *CloseSessionResponse) error

func (*SessionIndexer) FlushSession added in v1.0.0 

func (h *SessionIndexer) FlushSession(ctx context.Context, in *FlushSessionRequest, out *FlushSessionResponse) error

func (*SessionIndexer) OpenSession 

func (h *SessionIndexer) OpenSession(ctx context.Context, in *OpenSessionRequest, out *OpenSessionResponse) error

type SessionIndexerClient 

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

func NewSessionIndexerClient 

func NewSessionIndexerClient(serviceName string, c client.Client) SessionIndexerClient

type SessionIndexerHandler 

type SessionIndexerHandler interface {
	OpenSession(context.Context, *OpenSessionRequest, *OpenSessionResponse) error
	FlushSession(context.Context, *FlushSessionRequest, *FlushSessionResponse) error
	CloseSession(context.Context, *CloseSessionRequest, *CloseSessionResponse) error
}

type SessionIndexerMock 

type SessionIndexerMock struct {
}

func (*SessionIndexerMock) CloseSession 

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

func (*SessionIndexerMock) FlushSession 

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

func (*SessionIndexerMock) OpenSession 

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

type StoreVersionRequest 

type StoreVersionRequest struct {
	Node    *Node      `protobuf:"bytes,1,opt,name=Node" json:"Node,omitempty"`
	Version *ChangeLog `protobuf:"bytes,2,opt,name=Version" json:"Version,omitempty"`
}

func (*StoreVersionRequest) Descriptor 

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

func (*StoreVersionRequest) GetNode 

func (m *StoreVersionRequest) GetNode() *Node

func (*StoreVersionRequest) GetVersion 

func (m *StoreVersionRequest) GetVersion() *ChangeLog

func (*StoreVersionRequest) ProtoMessage 

func (*StoreVersionRequest) ProtoMessage()

func (*StoreVersionRequest) Reset 

func (m *StoreVersionRequest) Reset()

func (*StoreVersionRequest) String 

func (m *StoreVersionRequest) String() string

func (*StoreVersionRequest) Validate 

func (this *StoreVersionRequest) Validate() error

type StoreVersionResponse 

type StoreVersionResponse struct {
	Success       bool         `protobuf:"varint,1,opt,name=Success" json:"Success,omitempty"`
	PruneVersions []*ChangeLog `protobuf:"bytes,2,rep,name=PruneVersions" json:"PruneVersions,omitempty"`
}

func (*StoreVersionResponse) Descriptor 

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

func (*StoreVersionResponse) GetPruneVersions 

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

func (*StoreVersionResponse) GetSuccess 

func (m *StoreVersionResponse) GetSuccess() bool

func (*StoreVersionResponse) ProtoMessage 

func (*StoreVersionResponse) ProtoMessage()

func (*StoreVersionResponse) Reset 

func (m *StoreVersionResponse) Reset()

func (*StoreVersionResponse) String 

func (m *StoreVersionResponse) String() string

func (*StoreVersionResponse) Validate 

func (this *StoreVersionResponse) Validate() error

type StreamChangesRequest 

type StreamChangesRequest struct {
	RootPath string `protobuf:"bytes,1,opt,name=RootPath" json:"RootPath,omitempty"`
}

func (*StreamChangesRequest) Descriptor 

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

func (*StreamChangesRequest) GetRootPath 

func (m *StreamChangesRequest) GetRootPath() string

func (*StreamChangesRequest) ProtoMessage 

func (*StreamChangesRequest) ProtoMessage()

func (*StreamChangesRequest) Reset 

func (m *StreamChangesRequest) Reset()

func (*StreamChangesRequest) String 

func (m *StreamChangesRequest) String() string

func (*StreamChangesRequest) Validate 

func (this *StreamChangesRequest) Validate() error

type StreamerMock 

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

func NewStreamerMock 

func NewStreamerMock(nodes map[string]Node) *StreamerMock

func (*StreamerMock) Close 

func (m *StreamerMock) Close() error

func (*StreamerMock) Context 

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

func (*StreamerMock) Error 

func (m *StreamerMock) Error() error

func (*StreamerMock) Recv 

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

func (*StreamerMock) Request 

func (m *StreamerMock) Request() client.Request

func (*StreamerMock) Send 

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

type SyncChange 

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

func (*SyncChange) Descriptor 

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

func (*SyncChange) GetNode 

func (m *SyncChange) GetNode() *SyncChangeNode

func (*SyncChange) GetNodeId 

func (m *SyncChange) GetNodeId() string

func (*SyncChange) GetSeq 

func (m *SyncChange) GetSeq() uint64

func (*SyncChange) GetSource 

func (m *SyncChange) GetSource() string

func (*SyncChange) GetTarget 

func (m *SyncChange) GetTarget() string

func (*SyncChange) GetType 

func (m *SyncChange) GetType() SyncChange_Type

func (*SyncChange) ProtoMessage 

func (*SyncChange) ProtoMessage()

func (*SyncChange) Reset 

func (m *SyncChange) Reset()

func (*SyncChange) String 

func (m *SyncChange) String() string

func (*SyncChange) Validate 

func (this *SyncChange) Validate() error

type SyncChangeNode 

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

func (*SyncChangeNode) Descriptor 

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

func (*SyncChangeNode) GetBytesize 

func (m *SyncChangeNode) GetBytesize() int64

func (*SyncChangeNode) GetMd5 

func (m *SyncChangeNode) GetMd5() string

func (*SyncChangeNode) GetMtime 

func (m *SyncChangeNode) GetMtime() int64

func (*SyncChangeNode) GetNodePath 

func (m *SyncChangeNode) GetNodePath() string

func (*SyncChangeNode) GetRepositoryIdentifier 

func (m *SyncChangeNode) GetRepositoryIdentifier() string

func (*SyncChangeNode) ProtoMessage 

func (*SyncChangeNode) ProtoMessage()

func (*SyncChangeNode) Reset 

func (m *SyncChangeNode) Reset()

func (*SyncChangeNode) String 

func (m *SyncChangeNode) String() string

func (*SyncChangeNode) Validate 

func (this *SyncChangeNode) Validate() error

type SyncChange_Type 

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

func (SyncChange_Type) EnumDescriptor 

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

func (SyncChange_Type) String 

func (x SyncChange_Type) String() string

type SyncChanges 

type SyncChanges struct {
	SyncChangesHandler
}

func (*SyncChanges) Put 

func (h *SyncChanges) Put(ctx context.Context, stream server.Streamer) error

func (*SyncChanges) Search 

func (h *SyncChanges) Search(ctx context.Context, stream server.Streamer) error

type SyncChangesClient 

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

func NewSyncChangesClient 

func NewSyncChangesClient(serviceName string, c client.Client) SyncChangesClient

type SyncChangesHandler 

type SyncChangesHandler interface {
	Put(context.Context, SyncChanges_PutStream) error
	Search(context.Context, *SearchSyncChangeRequest, SyncChanges_SearchStream) error
}

type SyncChanges_PutClient 

type SyncChanges_PutClient interface {
	SendMsg(interface{}) error
	RecvMsg(interface{}) error
	Close() error
	Send(*SyncChange) error
}

type SyncChanges_PutStream 

type SyncChanges_PutStream interface {
	SendMsg(interface{}) error
	RecvMsg(interface{}) error
	Close() error
	Recv() (*SyncChange, error)
}

type SyncChanges_SearchClient 

type SyncChanges_SearchClient interface {
	SendMsg(interface{}) error
	RecvMsg(interface{}) error
	Close() error
	Recv() (*SyncChange, error)
}

type SyncChanges_SearchStream 

type SyncChanges_SearchStream interface {
	SendMsg(interface{}) error
	RecvMsg(interface{}) error
	Close() error
	Send(*SyncChange) error
}

type UpdateNodeRequest 

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

func (*UpdateNodeRequest) Descriptor 

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

func (*UpdateNodeRequest) GetFrom 

func (m *UpdateNodeRequest) GetFrom() *Node

func (*UpdateNodeRequest) GetIndexationSession 

func (m *UpdateNodeRequest) GetIndexationSession() string

func (*UpdateNodeRequest) GetSilent added in v1.2.0 

func (m *UpdateNodeRequest) GetSilent() bool

func (*UpdateNodeRequest) GetTo 

func (m *UpdateNodeRequest) GetTo() *Node

func (*UpdateNodeRequest) ProtoMessage 

func (*UpdateNodeRequest) ProtoMessage()

func (*UpdateNodeRequest) Reset 

func (m *UpdateNodeRequest) Reset()

func (*UpdateNodeRequest) String 

func (m *UpdateNodeRequest) String() string

func (*UpdateNodeRequest) Validate 

func (this *UpdateNodeRequest) Validate() error

type UpdateNodeResponse 

type UpdateNodeResponse struct {
	Success bool  `protobuf:"varint,1,opt,name=Success" json:"Success,omitempty"`
	Node    *Node `protobuf:"bytes,2,opt,name=Node" json:"Node,omitempty"`
}

func (*UpdateNodeResponse) Descriptor 

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

func (*UpdateNodeResponse) GetNode 

func (m *UpdateNodeResponse) GetNode() *Node

func (*UpdateNodeResponse) GetSuccess 

func (m *UpdateNodeResponse) GetSuccess() bool

func (*UpdateNodeResponse) ProtoMessage 

func (*UpdateNodeResponse) ProtoMessage()

func (*UpdateNodeResponse) Reset 

func (m *UpdateNodeResponse) Reset()

func (*UpdateNodeResponse) String 

func (m *UpdateNodeResponse) String() string

func (*UpdateNodeResponse) Validate 

func (this *UpdateNodeResponse) Validate() error

type VersioningKeepPeriod 

type VersioningKeepPeriod struct {
	IntervalStart string `protobuf:"bytes,1,opt,name=IntervalStart" json:"IntervalStart,omitempty"`
	MaxNumber     int32  `protobuf:"varint,3,opt,name=MaxNumber" json:"MaxNumber,omitempty"`
}

func (*VersioningKeepPeriod) Descriptor 

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

func (*VersioningKeepPeriod) GetIntervalStart 

func (m *VersioningKeepPeriod) GetIntervalStart() string

func (*VersioningKeepPeriod) GetMaxNumber 

func (m *VersioningKeepPeriod) GetMaxNumber() int32

func (*VersioningKeepPeriod) ProtoMessage 

func (*VersioningKeepPeriod) ProtoMessage()

func (*VersioningKeepPeriod) Reset 

func (m *VersioningKeepPeriod) Reset()

func (*VersioningKeepPeriod) String 

func (m *VersioningKeepPeriod) String() string

func (*VersioningKeepPeriod) Validate 

func (this *VersioningKeepPeriod) Validate() error

type VersioningPolicy 

type VersioningPolicy struct {
	Uuid                     string                  `protobuf:"bytes,1,opt,name=Uuid" json:"Uuid,omitempty"`
	Name                     string                  `protobuf:"bytes,2,opt,name=Name" json:"Name,omitempty"`
	Description              string                  `protobuf:"bytes,3,opt,name=Description" json:"Description,omitempty"`
	VersionsDataSourceName   string                  `protobuf:"bytes,4,opt,name=VersionsDataSourceName" json:"VersionsDataSourceName,omitempty"`
	VersionsDataSourceBucket string                  `protobuf:"bytes,5,opt,name=VersionsDataSourceBucket" json:"VersionsDataSourceBucket,omitempty"`
	MaxTotalSize             int64                   `protobuf:"varint,6,opt,name=MaxTotalSize" json:"MaxTotalSize,omitempty"`
	MaxSizePerFile           int64                   `protobuf:"varint,7,opt,name=MaxSizePerFile" json:"MaxSizePerFile,omitempty"`
	IgnoreFilesGreaterThan   int64                   `protobuf:"varint,8,opt,name=IgnoreFilesGreaterThan" json:"IgnoreFilesGreaterThan,omitempty"`
	KeepPeriods              []*VersioningKeepPeriod `protobuf:"bytes,9,rep,name=KeepPeriods" json:"KeepPeriods,omitempty"`
}

func (*VersioningPolicy) Descriptor 

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

func (*VersioningPolicy) GetDescription 

func (m *VersioningPolicy) GetDescription() string

func (*VersioningPolicy) GetIgnoreFilesGreaterThan 

func (m *VersioningPolicy) GetIgnoreFilesGreaterThan() int64

func (*VersioningPolicy) GetKeepPeriods 

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

func (*VersioningPolicy) GetMaxSizePerFile 

func (m *VersioningPolicy) GetMaxSizePerFile() int64

func (*VersioningPolicy) GetMaxTotalSize 

func (m *VersioningPolicy) GetMaxTotalSize() int64

func (*VersioningPolicy) GetName 

func (m *VersioningPolicy) GetName() string

func (*VersioningPolicy) GetUuid 

func (m *VersioningPolicy) GetUuid() string

func (*VersioningPolicy) GetVersionsDataSourceBucket 

func (m *VersioningPolicy) GetVersionsDataSourceBucket() string

func (*VersioningPolicy) GetVersionsDataSourceName 

func (m *VersioningPolicy) GetVersionsDataSourceName() string

func (*VersioningPolicy) MarshalLogObject added in v1.5.0 

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

MarshalLogObject implements custom marshalling for logs

func (*VersioningPolicy) ProtoMessage 

func (*VersioningPolicy) ProtoMessage()

func (*VersioningPolicy) Reset 

func (m *VersioningPolicy) Reset()

func (*VersioningPolicy) String 

func (m *VersioningPolicy) String() string

func (*VersioningPolicy) Validate 

func (this *VersioningPolicy) Validate() error

func (*VersioningPolicy) Zap 

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

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

type WatchNodeRequest 

type WatchNodeRequest struct {
	Node *Node `protobuf:"bytes,1,opt,name=Node" json:"Node,omitempty"`
}

Request / Responses Messages

func (*WatchNodeRequest) Descriptor 

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

func (*WatchNodeRequest) GetNode 

func (m *WatchNodeRequest) GetNode() *Node

func (*WatchNodeRequest) ProtoMessage 

func (*WatchNodeRequest) ProtoMessage()

func (*WatchNodeRequest) Reset 

func (m *WatchNodeRequest) Reset()

func (*WatchNodeRequest) String 

func (m *WatchNodeRequest) String() string

func (*WatchNodeRequest) Validate 

func (this *WatchNodeRequest) Validate() error

type WatchNodeResponse 

type WatchNodeResponse struct {
	Node *Node `protobuf:"bytes,1,opt,name=Node" json:"Node,omitempty"`
}

func (*WatchNodeResponse) Descriptor 

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

func (*WatchNodeResponse) GetNode 

func (m *WatchNodeResponse) GetNode() *Node

func (*WatchNodeResponse) ProtoMessage 

func (*WatchNodeResponse) ProtoMessage()

func (*WatchNodeResponse) Reset 

func (m *WatchNodeResponse) Reset()

func (*WatchNodeResponse) String 

func (m *WatchNodeResponse) String() string

func (*WatchNodeResponse) Validate 

func (this *WatchNodeResponse) Validate() error

type WorkspaceRelativePath 

type WorkspaceRelativePath struct {
	// Workspace Id
	WsUuid string `protobuf:"bytes,1,opt,name=WsUuid" json:"WsUuid,omitempty"`
	// Workspace Label
	WsLabel string `protobuf:"bytes,2,opt,name=WsLabel" json:"WsLabel,omitempty"`
	// Relative Path inside workspace
	Path string `protobuf:"bytes,3,opt,name=Path" json:"Path,omitempty"`
	// Workspace slug
	WsSlug string `protobuf:"bytes,4,opt,name=WsSlug" json:"WsSlug,omitempty"`
}

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

func (*WorkspaceRelativePath) Descriptor 

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

func (*WorkspaceRelativePath) GetPath 

func (m *WorkspaceRelativePath) GetPath() string

func (*WorkspaceRelativePath) GetWsLabel 

func (m *WorkspaceRelativePath) GetWsLabel() string

func (*WorkspaceRelativePath) GetWsSlug 

func (m *WorkspaceRelativePath) GetWsSlug() string

func (*WorkspaceRelativePath) GetWsUuid 

func (m *WorkspaceRelativePath) GetWsUuid() string

func (*WorkspaceRelativePath) ProtoMessage 

func (*WorkspaceRelativePath) ProtoMessage()

func (*WorkspaceRelativePath) Reset 

func (m *WorkspaceRelativePath) Reset()

func (*WorkspaceRelativePath) String 

func (m *WorkspaceRelativePath) String() string

func (*WorkspaceRelativePath) Validate 

func (this *WorkspaceRelativePath) Validate() error

type WrappingStreamerResponse 

type WrappingStreamerResponse struct {
	// Types that are valid to be assigned to Data:
	//	*WrappingStreamerResponse_ListNodesResponse
	//	*WrappingStreamerResponse_NodeChangeEvent
	Data  isWrappingStreamerResponse_Data `protobuf_oneof:"Data"`
	Error string                          `protobuf:"bytes,3,opt,name=Error" json:"Error,omitempty"`
}

func (*WrappingStreamerResponse) Descriptor 

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

func (*WrappingStreamerResponse) GetData 

func (m *WrappingStreamerResponse) GetData() isWrappingStreamerResponse_Data

func (*WrappingStreamerResponse) GetError 

func (m *WrappingStreamerResponse) GetError() string

func (*WrappingStreamerResponse) GetListNodesResponse 

func (m *WrappingStreamerResponse) GetListNodesResponse() *ListNodesResponse

func (*WrappingStreamerResponse) GetNodeChangeEvent 

func (m *WrappingStreamerResponse) GetNodeChangeEvent() *NodeChangeEvent

func (*WrappingStreamerResponse) ProtoMessage 

func (*WrappingStreamerResponse) ProtoMessage()

func (*WrappingStreamerResponse) Reset 

func (m *WrappingStreamerResponse) Reset()

func (*WrappingStreamerResponse) String 

func (m *WrappingStreamerResponse) String() string

func (*WrappingStreamerResponse) XXX_OneofFuncs 

func (*WrappingStreamerResponse) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

type WrappingStreamerResponse_ListNodesResponse 

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

type WrappingStreamerResponse_NodeChangeEvent 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

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