lib/

Versions in this module

v0

v0.9.1

Feb 22, 2021

v0.9.0

Feb 19, 2018

v0.8.2

Jul 14, 2017

v0.8.1

Jul 5, 2017

v0.8.0

Jun 21, 2017

v0.7.0

Jun 9, 2017

v0.6.2

May 17, 2017

v0.6.1

May 14, 2017

v0.6.0

Apr 28, 2017

v0.5.1

Sep 19, 2016

v0.5.0

Apr 25, 2016

v0.4.1

Apr 26, 2015

v0.4.0

Apr 17, 2015

v0.3.1

Apr 16, 2015

v0.3.0

Mar 27, 2015

Changes in this version

+ func GenerateStampedUUID() string

+ func GenerateUUID() string

v0.2.1

Feb 15, 2015

v0.1.4

Feb 8, 2015

v0.1.3

Feb 1, 2015

v0.1.2

Jan 18, 2015

Changes in this version

type Curator

+ func (c *Curator) CreateDocument(token string, userID string, doc *Document) (BinderPortal, error)

+ type FileAuthenticator struct

+ func NewFileAuthenticator(config TokenAuthenticatorConfig, logger *log.Logger) *FileAuthenticator

+ func (f *FileAuthenticator) AuthoriseCreate(token, userID string) bool

+ func (f *FileAuthenticator) AuthoriseJoin(token, documentID string) bool

+ type FileAuthenticatorConfig struct

+ Path string

+ RefreshPeriod int64

+ SharePath string

+ ShowHidden bool

+ func DefaultFileAuthenticatorConfig() FileAuthenticatorConfig

type RedisAuthenticator

+ func NewRedisAuthenticator(config TokenAuthenticatorConfig, logger *log.Logger) *RedisAuthenticator

type TokenAuthenticatorConfig

+ FileConfig FileAuthenticatorConfig

v0.1.1

Nov 27, 2014

Changes in this version

type RedisAuthenticatorConfig

+ Password string

+ PoolIdleTOut int64

+ PoolMaxIdle int

v0.1.0

Nov 23, 2014

Changes in this version

type Binder

+ func NewBinder(id string, block DocumentStore, config BinderConfig, ...) (*Binder, error)

type BinderClient

+ MessageChan chan<- ClientMessage

+ TransformChan chan<- OTransform

type BinderPortal

+ ExitChan chan<- string

+ MessageRcvChan <-chan ClientMessage

+ MessageSndChan chan<- MessageSubmission

+ TransformSndChan chan<- TransformSubmission

+ func (p *BinderPortal) Exit(timeout time.Duration)

+ func (p *BinderPortal) SendMessage(message ClientMessage)

+ type ClientMessage struct

+ Active bool

+ Message string

+ Position *int64

+ Token string

type Curator

+ func NewCurator(config CuratorConfig, log *util.Logger, stats *util.Stats) (*Curator, error)

type Document

+ func NewDocument(content string) (*Document, error)

+ type MessageSubmission struct

+ Message ClientMessage

+ Token string

+ type TransformSubmission struct

+ ErrorChan chan<- error

+ Token string

+ Transform OTransform

+ VersionChan chan<- int

v0.0.6

Oct 31, 2014

v0.0.5

Sep 25, 2014

Changes in this version

+ const LeapDebug

+ const LeapError

+ const LeapInfo

+ const LeapWarn

+ func GenerateID(content string) string

+ func ParseDocumentContent(doctype string, content string) (interface{}, error)

+ func SerializeDocumentContent(doctype string, content interface{}) (string, error)

+ func ValidateDocument(doc *Document) error

+ type Anarchy struct

+ func (a *Anarchy) AuthoriseCreate(_, _ string) bool

+ func (a *Anarchy) AuthoriseJoin(_, _ string) bool

+ type Binder struct

+ ID string

+ SubscribeChan chan BinderSubscribeBundle

+ func BindExisting(id string, block DocumentStore, config BinderConfig, ...) (*Binder, error)

+ func BindNew(document *Document, block DocumentStore, config BinderConfig, ...) (*Binder, error)

+ func (b *Binder) Close()

+ func (b *Binder) Subscribe(token string) *BinderPortal

+ type BinderClient struct

+ Token string

+ TransformSndChan chan<- interface{}

+ type BinderConfig struct

+ ClientKickPeriod int64

+ CloseInactivityPeriod int64

+ FlushPeriod int64

+ ModelConfig ModelConfig

+ RetentionPeriod int64

+ func DefaultBinderConfig() BinderConfig

+ type BinderError struct

+ Err error

+ ID string

+ type BinderPortal struct

+ Document *Document

+ Error error

+ RequestSndChan chan<- BinderRequest

+ Token string

+ TransformRcvChan <-chan interface{}

+ Version int

+ func (p *BinderPortal) SendTransform(ot interface{}, timeout time.Duration) (int, error)

+ func (p *BinderPortal) SendUpdate(update interface{}, timeout time.Duration) error

+ type BinderRequest struct

+ ErrorChan chan<- error

+ Token string

+ Transform interface{}

+ VersionChan chan<- int

+ type BinderSubscribeBundle struct

+ PortalRcvChan chan<- *BinderPortal

+ Token string

+ type Curator struct

+ func CreateNewCurator(config CuratorConfig) (*Curator, error)

+ func (c *Curator) Close()

+ func (c *Curator) FindDocument(token string, id string) (*BinderPortal, error)

+ func (c *Curator) GetLogger() *LeapsLogger

+ func (c *Curator) NewDocument(token string, userID string, doc *Document) (*BinderPortal, error)

+ type CuratorConfig struct

+ AuthenticatorConfig TokenAuthenticatorConfig

+ BinderConfig BinderConfig

+ LoggerConfig LoggerConfig

+ StoreConfig DocumentStoreConfig

+ func DefaultCuratorConfig() CuratorConfig

+ type Document struct

+ Content interface{}

+ Description string

+ ID string

+ Title string

+ Type string

+ func CreateNewDocument(title, description, doctype string, content interface{}) (*Document, error)

+ type DocumentStore interface

+ Create func(string, *Document) error

+ Fetch func(string) (*Document, error)

+ Store func(string, *Document) error

+ func DocumentStoreFactory(config DocumentStoreConfig) (DocumentStore, error)

+ func GetFileStore(config DocumentStoreConfig) (DocumentStore, error)

+ func GetMemoryStore(config DocumentStoreConfig) (DocumentStore, error)

+ func GetMockStore(config DocumentStoreConfig) (DocumentStore, error)

+ func GetSQLStore(config DocumentStoreConfig) (DocumentStore, error)

+ type DocumentStoreConfig struct

+ Name string

+ SQLConfig SQLConfig

+ StoreDirectory string

+ Type string

+ func DefaultDocumentStoreConfig() DocumentStoreConfig

+ type FileStore struct

+ func (s *FileStore) Create(id string, doc *Document) error

+ func (s *FileStore) Fetch(id string) (*Document, error)

+ func (s *FileStore) Store(id string, doc *Document) error

+ type LeapsLogger struct

+ func CreateLogger(config LoggerConfig) *LeapsLogger

+ func (l *LeapsLogger) Close()

+ func (l *LeapsLogger) DecrementStat(path string)

+ func (l *LeapsLogger) GetStats(timeout time.Duration) (*string, error)

+ func (l *LeapsLogger) IncrementStat(path string)

+ func (l *LeapsLogger) Log(level int, prefix, message string)

+ func (l *LeapsLogger) SetStat(path string, value interface{})

+ type LoggerConfig struct

+ LogLevel int

+ TargetPath string

+ func DefaultLoggerConfig() LoggerConfig

+ type MemoryStore struct

+ func (s *MemoryStore) Create(id string, doc *Document) error

+ func (s *MemoryStore) Fetch(id string) (*Document, error)

+ func (s *MemoryStore) Store(id string, doc *Document) error

+ type Model interface

+ FlushTransforms func(content *interface{}, secondsRetention int64) (bool, error)

+ GetVersion func() int

+ PushTransform func(ot interface{}) (interface{}, int, error)

+ func CreateTextModel(config ModelConfig) Model

+ type ModelConfig struct

+ MaxDocumentSize uint64

+ MaxTransformLength uint64

+ func DefaultModelConfig() ModelConfig

+ type OModel struct

+ Applied []OTransform

+ Unapplied []OTransform

+ Version int

+ func (m *OModel) FlushTransforms(contentBoxed *interface{}, secondsRetention int64) (bool, error)

+ func (m *OModel) GetVersion() int

+ func (m *OModel) PushTransform(otBoxed interface{}) (interface{}, int, error)

+ type OTransform struct

+ Delete int

+ Insert string

+ Position int

+ TReceived int64

+ Version int

+ type RedisAuthenticator struct

+ func CreateRedisAuthenticator(config TokenAuthenticatorConfig, logger *LeapsLogger) *RedisAuthenticator

+ func (s *RedisAuthenticator) AuthoriseCreate(token, userID string) bool

+ func (s *RedisAuthenticator) AuthoriseJoin(token, documentID string) bool

+ func (s *RedisAuthenticator) DeleteKey(key string) error

+ func (s *RedisAuthenticator) ReadKey(key string) (string, error)

+ type RedisAuthenticatorConfig struct

+ URL string

+ func DefaultRedisAuthenticatorConfig() RedisAuthenticatorConfig

+ type SQLConfig struct

+ DSN string

+ TableConfig TableConfig

+ func DefaultSQLConfig() SQLConfig

+ type SQLStore struct

+ func (m *SQLStore) Create(id string, doc *Document) error

+ func (m *SQLStore) Fetch(id string) (*Document, error)

+ func (m *SQLStore) Store(id string, doc *Document) error

+ type TableConfig struct

+ ContentCol string

+ DescriptionCol string

+ IDCol string

+ Name string

+ TitleCol string

+ TypeCol string

+ func DefaultTableConfig() TableConfig

+ type TokenAuthenticator interface

+ AuthoriseCreate func(token, userID string) bool

+ AuthoriseJoin func(token, documentID string) bool

+ func GetAnarchy(config TokenAuthenticatorConfig) TokenAuthenticator

+ func TokenAuthenticatorFactory(config TokenAuthenticatorConfig, logger *LeapsLogger) (TokenAuthenticator, error)

+ type TokenAuthenticatorConfig struct

+ AllowCreate bool

+ RedisConfig RedisAuthenticatorConfig

+ Type string

+ func DefaultTokenAuthenticatorConfig() TokenAuthenticatorConfig

+ type UserUpdate struct

+ Active bool

+ Message string

+ Position *int64

+ Token string

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