common

package
v2.2.0-rc0+incompatible Latest Latest
Warning

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

 Go to latest Published: Nov 10, 2020 License: AGPL-3.0 Imports: 5 Imported by: 0

Documentation

Overview

Package common provides a library of tools used by all pydio services

Index

Constants

View Source 
const (
	SERVICE_NATS = "nats"

	SERVICE_LOG         = "log"
	SERVICE_CONFIG      = "config"
	SERVICE_INSTALL     = "install"
	SERVICE_UPDATE      = "update"
	SERVICE_HEALTHCHECK = "healthcheck"

	SERVICE_TAG_IDM        = "idm"
	SERVICE_TAG_SCHEDULER  = "scheduler"
	SERVICE_TAG_DATA       = "data"
	SERVICE_TAG_DATASOURCE = "datasource"
	SERVICE_TAG_BROKER     = "broker"
	SERVICE_TAG_GATEWAY    = "gateway"
	SERVICE_TAG_DISCOVERY  = "discovery"
	SERVICE_TAG_FRONTEND   = "frontend"

	SERVICE_ACL       = "acl"
	SERVICE_SHARE     = "share"
	SERVICE_ROLE      = "role"
	SERVICE_USER      = "user"
	SERVICE_AUTH      = "auth"
	SERVICE_OAUTH     = "oauth"
	SERVICE_WORKSPACE = "workspace"
	SERVICE_POLICY    = "policy"
	SERVICE_GRAPH     = "graph"
	SERVICE_USER_META = "user-meta"

	SERVICE_USER_KEY  = "user-key"
	SERVICE_TREE      = "tree"
	SERVICE_META      = "meta"
	SERVICE_ENC_KEY   = "data-key"
	SERVICE_SEARCH    = "search"
	SERVICE_CHANGES   = "changes"
	SERVICE_SYNC      = "sync"
	SERVICE_TEMPLATES = "templates"

	SERVICE_ACTIVITY      = "activity"
	SERVICE_MAILER        = "mailer"
	SERVICE_WEBSOCKET     = "websocket"
	SERVICE_CHAT          = "chat"
	SERVICE_FRONTEND      = "frontend"
	SERVICE_FRONT_STATICS = "statics"

	SERVICE_TIMER    = "timer"
	SERVICE_JOBS     = "jobs"
	SERVICE_TASKS    = "tasks"
	SERVICE_VERSIONS = "versions"
	SERVICE_DOCSTORE = "docstore"

	SERVICE_DATA_         = "data."
	SERVICE_DATA_INDEX    = SERVICE_DATA_ + "index"
	SERVICE_DATA_OBJECTS  = SERVICE_DATA_ + "objects"
	SERVICE_DATA_SYNC     = SERVICE_DATA_ + "sync"
	SERVICE_DATA_INDEX_   = SERVICE_DATA_INDEX + "."
	SERVICE_DATA_OBJECTS_ = SERVICE_DATA_OBJECTS + "."
	SERVICE_DATA_SYNC_    = SERVICE_DATA_SYNC + "."

	SERVICE_GRPC_NAMESPACE_    = "pydio.grpc."
	SERVICE_WEB_NAMESPACE_     = "pydio.web."
	SERVICE_REST_NAMESPACE_    = "pydio.rest."
	SERVICE_GATEWAY_NAMESPACE_ = "pydio.gateway."
	SERVICE_TEST_NAMESPACE_    = "pydio.test."

	SERVICE_GATEWAY_PROXY      = SERVICE_GATEWAY_NAMESPACE_ + "proxy"
	SERVICE_GATEWAY_DATA       = SERVICE_GATEWAY_NAMESPACE_ + "data"
	SERVICE_GATEWAY_GRPC       = SERVICE_GATEWAY_NAMESPACE_ + "grpc"
	SERVICE_GATEWAY_GRPC_CLEAR = SERVICE_GATEWAY_NAMESPACE_ + "grpc.clear"
	SERVICE_GATEWAY_DAV        = SERVICE_GATEWAY_NAMESPACE_ + "dav"
	SERVICE_GATEWAY_WOPI       = SERVICE_GATEWAY_NAMESPACE_ + "wopi"
	SERVICE_MICRO_API          = SERVICE_GATEWAY_NAMESPACE_ + "rest"
)

Defines all constants for services names.

View Source 
const (
	TOPIC_PROXY_RESTART    = "topic.pydio.proxy.restart"
	TOPIC_SERVICE_START    = "topic.pydio.service.start"
	TOPIC_SERVICE_STOP     = "topic.pydio.service.stop"
	TOPIC_SERVICE_STARTED  = "topic.pydio.service.started"
	TOPIC_SERVICE_STOPPED  = "topic.pydio.service.stopped"
	TOPIC_ASSETS_RELOAD    = "topic.pydio.assets.reload"
	TOPIC_INDEX_CHANGES    = "topic.pydio.index.nodes.changes"
	TOPIC_TREE_CHANGES     = "topic.pydio.tree.nodes.changes"
	TOPIC_META_CHANGES     = "topic.pydio.meta.nodes.changes"
	TOPIC_TIMER_EVENT      = "topic.pydio.meta.timer.event"
	TOPIC_JOB_CONFIG_EVENT = "topic.pydio.jobconfig.event"
	TOPIC_JOB_TASK_EVENT   = "topic.pydio.jobconfig.event"
	TOPIC_IDM_EVENT        = "topic.pydio.idm.event"
	TOPIC_ACTIVITY_EVENT   = "topic.pydio.activity.event"
	TOPIC_CHAT_EVENT       = "topic.pydio.chat.event"
	TOPIC_DATASOURCE_EVENT = "topic.pydio.datasource.event"
	TOPIC_INDEX_EVENT      = "topic.pydio.index.event"
)

Define constants for Event Bus Topics

View Source 
const (
	META_NAMESPACE_DATASOURCE_NAME        = "pydio:meta-data-source-name"
	META_NAMESPACE_DATASOURCE_PATH        = "pydio:meta-data-source-path"
	META_NAMESPACE_NODE_TEST_LOCAL_FOLDER = "pydio:test:local-folder-storage"
	META_NAMESPACE_RECYCLE_RESTORE        = "pydio:recycle_restore"
	META_NAMESPACE_NODENAME               = "name"
	RECYCLE_BIN_NAME                      = "recycle_bin"

	PYDIO_THUMBSTORE_NAMESPACE        = "pydio-thumbstore"
	PYDIO_DOCSTORE_BINARIES_NAMESPACE = "pydio-binaries"
	PYDIO_VERSIONS_NAMESPACE          = "versions-store"
)

Define constants for metadata and fixed datasources

View Source 
const (
	PYDIO_CONTEXT_USER_KEY       = "X-Pydio-User"
	PYDIO_SYSTEM_USERNAME        = "pydio.system.user"
	PYDIO_S3ANON_USERNAME        = "pydio.anon.user"
	PYDIO_S3ANON_PROFILE         = "anon"
	PYDIO_SYNC_HIDDEN_FILE_META  = ".pydio"
	X_AMZ_META_CLEAR_SIZE        = "X-Amz-Meta-Pydio-Clear-Size"
	X_AMZ_META_CLEAR_SIZE_UNKOWN = "unknown"
	X_AMZ_META_NODE_UUID         = "X-Amz-Meta-Pydio-Node-Uuid"
	X_AMZ_META_CONTENT_MD5       = "X-Amz-Meta-Content-Md5"
	X_AMZ_META_DIRECTIVE         = "X-Amz-Metadata-Directive"
	XPydioClientUuid             = "X-Pydio-Client-Uuid"
	XPydioSessionUuid            = "X-Pydio-Session"
	XPydioIndexationSessionUuid  = "X-Pydio-Indexation-Session"
	XPydioFrontendSessionUuid    = "X-Pydio-Frontend-Session"
	XPydioMoveUuid               = "X-Pydio-Move"
	SyncSessionClose_            = "close-"
	SyncSessionPrefixCopy        = "copy-"
	SyncSessionPrefixMove        = "move-"

	PYDIO_PROFILE_ADMIN    = "admin"
	PYDIO_PROFILE_STANDARD = "standard"
	PYDIO_PROFILE_SHARED   = "shared"
	PYDIO_PROFILE_ANON     = "anon"

	KEYRING_MASTER_KEY              = "keyring.master"
	META_FLAG_READONLY              = "node_readonly"
	META_FLAG_LEVEL_READONLY        = "level_readonly"
	META_FLAG_ENCRYPTED             = "datasource_encrypted"
	META_FLAG_VERSIONING            = "datasource_versioning"
	META_FLAG_WORKSPACE_ROOT        = "ws_root"
	META_FLAG_WORKSPACE_SCOPE       = "ws_scope"
	META_FLAG_WORKSPACE_SYNCABLE    = "ws_syncable"
	META_FLAG_WORKSPACE_PERMISSIONS = "ws_permissions"
	META_FLAG_WORKSPACE_LABEL       = "ws_label"
	META_FLAG_WORKSPACE_DESCRIPTION = "ws_description"
	META_FLAG_WORKSPACE_SLUG        = "ws_slug"
	META_FLAG_WORKSPACE_UUID        = "ws_uuid"
	META_FLAG_VIRTUAL_ROOT          = "virtual_root"
	META_FLAG_BUCKET                = "ds_bucket"
	NODE_FLAG_ETAG_TEMPORARY        = "temporary"
)

Additional constants for authentication/authorization aspects

View Source 
const (
	DOCSTORE_ID_SELECTIONS          = "selections"
	DOCSTORE_ID_VIRTUALNODES        = "virtualnodes"
	DOCSTORE_ID_VERSIONING_POLICIES = "versioningPolicies"
	DOCSTORE_ID_SHARES              = "share"
	DOCSTORE_ID_RESET_PASS_KEYS     = "resetPasswordKeys"
)

DocStore constants for StoreID's

View Source 
const (
	DB_NUM_RESERVED_CONNECTIONS = 10
	DB_MAX_OPEN_CONNS           = 20
	DB_MAX_IDLE_CONNS           = 20
	DB_CONN_MAX_LIFETIME        = 24 * time.Hour
)

Defaults for DB connexions.

View Source 
const (
	KEY_MSG_ID = "MsgId"
	KEY_TS     = "Ts"
	KEY_NANO   = "Nano"
	KEY_LEVEL  = "Level"
	KEY_LOGGER = "Logger"
	KEY_MSG    = "Msg"
)

Define string used as keys.

View Source 
const (
	// Login
	AUDIT_LOGIN_SUCCEED       = "1"
	AUDIT_LOGIN_FAILED        = "2"
	AUDIT_LOGIN_POLICY_DENIAL = "3"
	AUDIT_INVALID_JWT         = "4"
	AUDIT_LOCK_USER           = "5"

	// Tree events
	AUDIT_NODE_CREATE       = "11"
	AUDIT_NODE_READ         = "12"
	AUDIT_NODE_LIST         = "13"
	AUDIT_NODE_UPDATE       = "14"
	AUDIT_NODE_DELETE       = "15"
	AUDIT_WS_CREATE         = "16"
	AUDIT_WS_UPDATE         = "17"
	AUDIT_WS_DELETE         = "18"
	AUDIT_NODE_MOVED_TO_BIN = "19"

	// S3 Objects
	AUDIT_OBJECT_GET = "21"
	AUDIT_OBJECT_PUT = "22"

	// Users, Group, Roles
	AUDIT_USER_CREATE  = "41"
	AUDIT_USER_READ    = "42"
	AUDIT_USER_UPDATE  = "43"
	AUDIT_USER_DELETE  = "44"
	AUDIT_GROUP_CREATE = "46"
	AUDIT_GROUP_READ   = "47"
	AUDIT_GROUP_UPDATE = "48"
	AUDIT_GROUP_DELETE = "49"
	AUDIT_ROLE_CREATE  = "51"
	AUDIT_ROLE_READ    = "52"
	AUDIT_ROLE_UPDATE  = "53"
	AUDIT_ROLE_DELETE  = "54"

	// Policies
	AUDIT_POLICY_GROUP_STORE  = "61"
	AUDIT_POLICY_GROUP_DELETE = "62"
	AUDIT_POLICY_STORE        = "63"
	AUDIT_POLICY_DELETE       = "64"

	// ShareLinks And Cells
	AUDIT_CELL_CREATE = "71"
	AUDIT_CELL_READ   = "72"
	AUDIT_CELL_UPDATE = "73"
	AUDIT_CELL_DELETE = "74"
	AUDIT_LINK_CREATE = "75"
	AUDIT_LINK_READ   = "76"
	AUDIT_LINK_UPDATE = "77"
	AUDIT_LINK_DELETE = "78"
)

Known audit message IDs

View Source 
const (
	KEY_CONTEXT = "Context"

	// Follow a given request between the various services
	KEY_SPAN_UUID        = "SpanUuid"
	KEY_SPAN_PARENT_UUID = "SpanParentUuid"
	KEY_SPAN_ROOT_UUID   = "SpanRootUuid"

	// Group messages for a given high level operation
	KEY_OPERATION_UUID  = "OperationUuid"
	KEY_OPERATION_LABEL = "OperationLabel"

	KEY_NODE      = "Node"
	KEY_NODE_UUID = "NodeUuid"
	KEY_NODE_PATH = "NodePath"

	KEY_WORKSPACE       = "Workspace"
	KEY_WORKSPACE_UUID  = "WorkspaceUuid"
	KEY_WORKSPACE_SCOPE = "WorkspaceScope"

	KEY_CHANGE_LOG        = "ChangeLog"
	KEY_NODE_CHANGE_EVENT = "NodeChangeEvent"
	KEY_VERSIONING_POLICY = "VersioningPolicy"

	KEY_ACTIVITY_SUBSCRIPTION   = "ActivitySubscription"
	KEY_ACTIVITY_STREAM_REQUEST = "StreamActivitiesRequest"
	KEY_ACTIVITY_POST_EVENT     = "PostActivityEvent"
	KEY_ACTIVITY_OBJECT         = "ActivityObject"

	KEY_ROLE      = "Role"
	KEY_ROLE_UUID = "RoleUuid"
	KEY_ROLES     = "Roles"
	KEY_PROFILE   = "Profile"

	KEY_USER      = "User"
	KEY_USERNAME  = "UserName"
	KEY_USER_UUID = "UserUuid"

	KEY_GROUP_PATH = "GroupPath"

	KEY_CONNECTOR = "Connector"

	// Should be ACL and ACLID if we use proto names, changed to stay homogeneous with the other fields
	KEY_ACL    = "Acl"
	KEY_ACL_ID = "AclId"

	// Pydio internal merged representation of all ACLs that a user has access to
	KEY_ACCESS_LIST = "AccessList"

	KEY_POLICY_GROUP      = "PolicyGroup"
	KEY_POLICY_GROUP_UUID = "PolicyGroupUuid"
	KEY_POLICY            = "Policy"
	KEY_POLICY_ID         = "PolicyId"
	KEY_POLICY_REQUEST    = "PolicyRequest"

	// Scheduler
	KEY_JOB       = "Job"
	KEY_JOB_ID    = "JobId"
	KEY_ACTION    = "Action"
	KEY_ACTION_ID = "ActionId"
	KEY_TASK      = "Task"
	KEY_TASK_ID   = "TaskId"
	// Running tasks in scheduler
	KEY_SCHEDULER_JOB_ID      = "SchedulerJobUuid"
	KEY_SCHEDULER_TASK_ID     = "SchedulerTaskUuid"
	KEY_SCHEDULER_ACTION_PATH = "SchedulerTaskActionPath"

	// Cells
	KEY_CELL      = "Cell"
	KEY_CELL_UUID = "CellUuid"
	KEY_LINK      = "ShareLink"
	KEY_LINK_UUID = "ShareLinkUuid"

	// Chat
	KEY_CHAT_ROOM          = "ChatRoom"
	KEY_CHAT_LIST_ROOM_REQ = "ChatListRoomRequest"
	KEY_CHAT_LIST_MSG_REQ  = "ChatListMsgRequest"
	KEY_CHAT_POST_MSG_REQ  = "ChatPostMsgRequest"
)

Known audit message IDs

View Source 
const (
	KEY_FRONT_IP      = "FrontIp"
	KEY_FRONT_USERID  = "UserId"
	KEY_FRONT_WKSID   = "WorkspaceId"
	KEY_FRONT_SOURCE  = "Source"
	KEY_FRONT_PREFIX  = "Prefix"
	KEY_FRONT_MESSAGE = "Message"
	KEY_FRONT_NODES   = "Nodes"
)

Keys for the front end

Variables

View Source 
var (
	BuildStamp    string
	BuildRevision string
)

Main code information. Set by the go linker in the resulting binary when doing 'make main'

View Source 
var (
	PackageType  string
	PackageLabel string
)

Package info. Initialised by main.

View Source 
var (
	UpdateDefaultChannel   = "stable"
	UpdateDefaultServerUrl = "https://updatecells.pydio.com/"
	UpdateDefaultPublicKey = `` /* 424-byte string literal not displayed */
)

Update Server default values.

View Source 
var (
	LogConfig        LogConfigType
	LogLevel         zapcore.Level
	LogCaptureStdOut bool
)

Logging Levels.

View Source 
var (
	LogEventLabels = map[string]string{
		AUDIT_LOGIN_SUCCEED: "Login succeed",
		AUDIT_LOGIN_FAILED:  "Login failed",
		AUDIT_NODE_CREATE:   "Create Node",
		AUDIT_NODE_READ:     "Read Node",
		AUDIT_NODE_LIST:     "List Node",
		AUDIT_NODE_UPDATE:   "Upadate Node",
		AUDIT_NODE_DELETE:   "Delete Node",
		AUDIT_OBJECT_GET:    "Get Object",
		AUDIT_OBJECT_PUT:    "Put Object",
	}
)
View Source 
var (
	// PydioUserProfiles order reflects the level of authorizations
	PydioUserProfiles = []string{
		PYDIO_PROFILE_ANON,
		PYDIO_PROFILE_SHARED,
		PYDIO_PROFILE_STANDARD,
		PYDIO_PROFILE_ADMIN,
	}
)
View Source 
var (
	XSpecialPydioHeaders = []string{
		XPydioClientUuid,
		XPydioSessionUuid,
		XPydioIndexationSessionUuid,
		XPydioFrontendSessionUuid,
		XPydioMoveUuid,
	}
)

Functions

func Version 

func Version() *hashiversion.Version

Version returns the current code version as an object.

Types

type ConfigValues added in v1.2.2 

type ConfigValues interface {
	Get(key ...string) interface{}
	Set(key string, value interface{}) error
	Del(key string) error

	Bool(key string, def ...bool) bool
	Bytes(key string, def ...[]byte) []byte
	Int(key string, def ...int) int
	Int64(key string, def ...int64) int64
	Duration(key string, def ...string) time.Duration
	String(key string, def ...string) string
	StringMap(key string) map[string]string
	StringArray(key string, def ...[]string) []string
	Map(key string) map[string]interface{}
	Array(key string) Scanner
	Values(key string) ConfigValues

	Database(k string) (string, string)

	IsEmpty() bool

	Scanner
}

type Converter 

type Converter interface {
	Convert(*any.Any) (string, bool)
}

Converter interface

type LogConfigType 

type LogConfigType string

Various custom types internally used by Pydio. 

const (
	LogConfigConsole    LogConfigType = "console"
	LogConfigProduction LogConfigType = "production"
)

Define constants for Loggging configuration

type Manager 

type Manager interface {
	Get(string) interface{}
	Set(string, interface{}) error
	Del(string) error
	Map(string) map[string]interface{}
}

Manager interface

type Scanner 

type Scanner interface {
	Scan(val interface{}) error
}

type ServiceName 

type ServiceName string

Various custom types internally used by Pydio.

type ServiceTag 

type ServiceTag string

Various custom types internally used by Pydio.

type ServiceType 

type ServiceType string

Various custom types internally used by Pydio.

type Watcher 

type Watcher interface {
	Watch() (config.Watcher, error)
}

type XMLSerializableForm added in v1.2.2 

type XMLSerializableForm interface {
	Serialize(languages ...string) interface{}
}

Source Files

View all Source files

Directories

Path Synopsis
Package auth provides tools related to authentication of pydio services
 Package auth provides tools related to authentication of pydio services
claim
Package claim wraps the JWT claims with util functions
 Package claim wraps the JWT claims with util functions
hydra
Package BoltDB provides tools for using Bolt as a standard persistence layer for services
 Package BoltDB provides tools for using Bolt as a standard persistence layer for services
maintenance
Package config provides tools for managing configurations
 Package config provides tools for managing configurations
micro
micro/envvar
Package envvar implements Pydio specific interface for dynamic configurations that are backed by OS environment variables.
 Package envvar implements Pydio specific interface for dynamic configurations that are backed by OS environment variables.
micro/file
micro/memory
micro/remote
Package source implements a configuration client backed by a config server
 Package source implements a configuration client backed by a config server
micro/vault
migrations
source
sql
Package crypto provides tools for data encryption and certificates management
 Package crypto provides tools for data encryption and certificates management
providers
Package dao provides abstraction of persistence layer used by pydio services.
 Package dao provides abstraction of persistence layer used by pydio services.
etl
actions
models
stores
stores/cells/local
stores/pydio8
Package event wraps protobuf events to add context information
 Package event wraps protobuf events to add context information
Package forms provides utility methods to generate XML that is interpreted by the Front End to build forms.
 Package forms provides utility methods to generate XML that is interpreted by the Front End to build forms.
protos
Package log define and configure the Pydio loggers based on zap.
 Package log define and configure the Pydio loggers based on zap.
Package defaults initializes the defaults GRPC clients and servers used by services
 Package defaults initializes the defaults GRPC clients and servers used by services
broker
broker/http
broker/nats
rcache
registry/nats
router
Package router provides api service routing
 Package router provides api service routing
transport/grpc
Package mocks should provide utils used by tests to mock various layers.
 Package mocks should provide utils used by tests to mock various layers.
## Protobuf Definitions
 ## Protobuf Definitions
activity
Package activity is a generated protocol buffer package.
 Package activity is a generated protocol buffer package.
auth
Package auth is a generated protocol buffer package.
 Package auth is a generated protocol buffer package.
chat
Package chat is a generated protocol buffer package.
 Package chat is a generated protocol buffer package.
ctl
Package ctl is a generated protocol buffer package.
 Package ctl is a generated protocol buffer package.
docstore
Package docstore is a generated protocol buffer package.
 Package docstore is a generated protocol buffer package.
encryption
Package encryption is a generated protocol buffer package.
 Package encryption is a generated protocol buffer package.
idm
Package idm is a generated protocol buffer package.
 Package idm is a generated protocol buffer package.
install
Package install is a generated protocol buffer package.
 Package install is a generated protocol buffer package.
jobs
Package jobs is a generated protocol buffer package.
 Package jobs is a generated protocol buffer package.
log
Package log is a generated protocol buffer package.
 Package log is a generated protocol buffer package.
mailer
Package mailer is a generated protocol buffer package.
 Package mailer is a generated protocol buffer package.
object
Package object is a generated protocol buffer package.
 Package object is a generated protocol buffer package.
rest
Package rest is a generated protocol buffer package.
 Package rest is a generated protocol buffer package.
rest/cmd
Package cmd provides a specific tool for transforming json swagger file into a go file
 Package cmd provides a specific tool for transforming json swagger file into a go file
sync
Package sync is a generated protocol buffer package.
 Package sync is a generated protocol buffer package.
test
Package test is a generated protocol buffer package.
 Package test is a generated protocol buffer package.
tree
Package tree is a generated protocol buffer package.
 Package tree is a generated protocol buffer package.
update
Package update is a generated protocol buffer package.
 Package update is a generated protocol buffer package.
Package registry provides the main glue between services
 Package registry provides the main glue between services
Package service acts as a factory for all Pydio services.
 Package service acts as a factory for all Pydio services.
context
Package servicecontext performs context values read/write, generally through server or client wrappers
 Package servicecontext performs context values read/write, generally through server or client wrappers
frontend
Package frontend provides tools to publish static data from within any micro service
 Package frontend provides tools to publish static data from within any micro service
metrics
proto
Package service is a generated protocol buffer package.
 Package service is a generated protocol buffer package.
resources
Package resources provides extendable service Handler for managing resource-policy based data.
 Package resources provides extendable service Handler for managing resource-policy based data.
sql
Package sql provides tools and DAOs for speaking SQL as well as managing tables migrations
 Package sql provides tools and DAOs for speaking SQL as well as managing tables migrations
index
Package index provides ready-to-use tables and DAOs for storing hierarchical data using the nested sets pattern
 Package index provides ready-to-use tables and DAOs for storing hierarchical data using the nested sets pattern
resources
Package resources provides ready-to-use SQL schemes and DAOs for attaching resource policies to any data
 Package resources provides ready-to-use SQL schemes and DAOs for attaching resource policies to any data
sync
endpoints/cells
Package cells provides endpoints for speaking either with a local server using a views.Router (and connecting to the local NATS registry), or a remote Cells server using a GRPC gateway client.
 Package cells provides endpoints for speaking either with a local server using a views.Router (and connecting to the local NATS registry), or a remote Cells server using a GRPC gateway client.
endpoints/filesystem
Package file system provides endpoints for reading/writing from/to a local folder
 Package file system provides endpoints for reading/writing from/to a local folder
endpoints/index
Package index provides a GRPC client for storing information into any tree.NodeProviderClient/tree.NodeReceiverClient service.
 Package index provides a GRPC client for storing information into any tree.NodeProviderClient/tree.NodeReceiverClient service.
endpoints/memory
Package memory provides an in-memory basic implementation of an Endpoint, with nodes stored in a map.
 Package memory provides an in-memory basic implementation of an Endpoint, with nodes stored in a map.
endpoints/s3
Package s3 provides an endpoint for connecting to Amazon S3 or an S3-compatible storage
 Package s3 provides an endpoint for connecting to Amazon S3 or an S3-compatible storage
endpoints/snapshot
Package snapshot provides fast in-memory or on-file implementations of endpoint for storing snapshots
 Package snapshot provides fast in-memory or on-file implementations of endpoint for storing snapshots
filters
Package filters provides batchers and filters to analyze and simplify sync events
 Package filters provides batchers and filters to analyze and simplify sync events
merger
Package merger implements all logic to compare trees and create set of operations to be applied
 Package merger implements all logic to compare trees and create set of operations to be applied
model
Package model gathers the main structs and interfaces used in sync library.
 Package model gathers the main structs and interfaces used in sync library.
proc
Package proc provides actual actions to be performed once the sync has filtered all events
 Package proc provides actual actions to be performed once the sync has filtered all events
task
Package task defines a synchronization task
 Package task defines a synchronization task
Package utils provides swiss-knife tools for all services
 Package utils provides swiss-knife tools for all services
cache
Package cache provides ready-to-use in-memory cache mechanisms
 Package cache provides ready-to-use in-memory cache mechanisms
context
Package context manipulates context metadata
 Package context manipulates context metadata
docs
error
Package error creates and parses common errors
 Package error creates and parses common errors
filesystem
i18n
Package i18n wraps go-i18n lib for manipulating bundles
 Package i18n wraps go-i18n lib for manipulating bundles
meta
Package meta provides tool for reading metadata from services declaring "MetaProvider" support
 Package meta provides tool for reading metadata from services declaring "MetaProvider" support
migrations
mtree
Package mtree provides advanced tools for encoding tree paths in a material format
 Package mtree provides advanced tools for encoding tree paths in a material format
net
Package net provides tools for reading IPs, available Ports, extending HTTP requests, etc.
 Package net provides tools for reading IPs, available Ports, extending HTTP requests, etc.
permissions
Package permissions provides high-level tools for computing permissions from ACLs
 Package permissions provides high-level tools for computing permissions from ACLs
schedule
Package schedule provides a fixed ticker based on a start time iso8601 interval periods are supported
 Package schedule provides a fixed ticker based on a start time iso8601 interval periods are supported
std
Package std provides tools for standard types (strings, int, floats, etc).
 Package std provides tools for standard types (strings, int, floats, etc).
Package views provides high-level clients for talking to the main data tree in certain context.
 Package views provides high-level clients for talking to the main data tree in certain context.

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.