tree

package
v2.1.0+incompatible Latest Latest
Warning

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

Go to latest
Published: Jul 1, 2020 License: AGPL-3.0 Imports: 21 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
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

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

View Source
const (
	MetaFilterGrep   = "grep"
	MetaFilterNoGrep = "no-grep"
	MetaFilterTime   = "time"
	MetaFilterSize   = "size"
	MetaFilterDepth  = "depth"
)

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

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 IndexableNode

type IndexableNode struct {
	Node
	ReloadCore bool
	ReloadNs   bool

	ModifTime   time.Time
	Basename    string
	NodeType    string
	Extension   string
	TextContent string
	GeoPoint    map[string]interface{}
	Meta        map[string]interface{}
}

func NewMemIndexableNode

func NewMemIndexableNode(n *Node) *IndexableNode

func (*IndexableNode) BleveType

func (i *IndexableNode) BleveType() string

func (*IndexableNode) MemLoad

func (i *IndexableNode) MemLoad()

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 MetaFilter

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

func NewMetaFilter

func NewMetaFilter(node *Node) *MetaFilter

func (*MetaFilter) LimitDepth

func (m *MetaFilter) LimitDepth() int

func (*MetaFilter) Match

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

func (*MetaFilter) Parse

func (m *MetaFilter) Parse() bool

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 (*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 NodeProviderMock

type NodeProviderMock struct {
	Nodes map[string]Node
}

func NewNodeProviderMock

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

func (*NodeProviderMock) ListNodes

func (*NodeProviderMock) ReadNode

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 NodeReceiverMock

type NodeReceiverMock struct {
	Nodes map[string]Node
}

func (*NodeReceiverMock) CreateNode

func (*NodeReceiverMock) DeleteNode

func (*NodeReceiverMock) UpdateNode

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 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 (*NodeVersioner) HeadVersion

func (*NodeVersioner) ListVersions

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

func (*NodeVersioner) PruneVersions

func (*NodeVersioner) StoreVersion

type NodeVersionerClient

func NewNodeVersionerClient

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

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 {
	// Preset list of nodes by Path
	Paths []string `protobuf:"bytes,13,rep,name=Paths" json:"Paths,omitempty"`
	// 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"`
	// Limit to a given level of the tree - can be used in filters
	PathDepth int32 `protobuf:"varint,12,opt,name=PathDepth" json:"PathDepth,omitempty"`
	// Preset list of Node by UUIDs
	UUIDs []string `protobuf:"bytes,15,rep,name=UUIDs" json:"UUIDs,omitempty"`
	// Negate this query
	Not bool `protobuf:"varint,14,opt,name=Not" json:"Not,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) GetNot

func (m *Query) GetNot() bool

func (*Query) GetPathDepth

func (m *Query) GetPathDepth() int32

func (*Query) GetPathPrefix

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

func (*Query) GetPaths

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

func (*Query) GetType

func (m *Query) GetType() NodeType

func (*Query) GetUUIDs

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

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 (*SessionIndexer) FlushSession added in v1.0.0

func (*SessionIndexer) OpenSession

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 SessionIndexerMock

type SessionIndexerMock struct {
}

func (*SessionIndexerMock) CloseSession

func (*SessionIndexerMock) FlushSession

func (*SessionIndexerMock) OpenSession

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

func (this *WrappingStreamerResponse) Validate() error

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

Jump to

Keyboard shortcuts

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