rig

Oct 25, 2018

Changes in this version

+ type DirectoryCreator interface

+ CreateDirectory func(string) error

+ type ObjectStore interface

+ DeleteObject func(name string) error

+ GetObject func(name string) (io.ReadCloser, error)

+ PutObject func(name string, data io.ReadSeeker, size int64) error

+ func NewFileObjectStore(basePath string) ObjectStore

+ func NewS3ObjectStore(s3 *s3.S3, bucket string) ObjectStore

+ type RiggedService struct

+ func NewRiggedService(service Service, objectStore ObjectStore, prefix string) (*RiggedService, error)

+ func (rs *RiggedService) Apply(op Operation, waitUntilDurable bool) error

+ func (rs *RiggedService) Flush() (int, error)

+ func (rs *RiggedService) Recover() error

+ func (rs *RiggedService) Snapshot() error

+ func (rs *RiggedService) SnapshotVersion() uint64

type Service

+ Restore func(uint64, io.Reader) error

+ Snapshot func() (io.ReadSeeker, int64, error)

+ Version func() (uint64, error)

Sep 9, 2018

Changes in this version

+ type HTTPError interface

+ StatusCode func() int

Sep 17, 2017

Changes in this version

+ type LogPayload struct

+ Op Operation

+ Version uint64

+ func NewLogPayload(version uint64, op Operation) *LogPayload

type Operation

+ func NewOperation(method string, data json.RawMessage) Operation

type Rig

+ func (r *Rig) DoHandler() http.Handler

+ func (r *Rig) LogHandler() http.Handler

Sep 17, 2017

Changes in this version

+ type Operation interface

+ Data func() []byte

+ Method func() string

+ type Rig struct

+ func New(logDir string, service Service, applyCommits bool, token, peer string) (*Rig, error)

Jul 22, 2017

Changes in this version

type Log

+ func (l *Log) Compact(recordsToKeep uint) error

Jul 22, 2017

Changes in this version

+ type Doer struct

+ func NewDoer(commitLog *Log, peer string) (*Doer, error)

+ func (d *Doer) Do(p client.LogPayload, ignoreVersion bool) error

+ func (d *Doer) Handler() func(w http.ResponseWriter, r *http.Request)

+ type Log struct

+ func NewLog(logDir string, service Service, applyCommits bool) (*Log, error)

+ func (l *Log) Commit() error

+ func (l *Log) Committed() (client.LogPayload, error)

+ func (l *Log) LockResources(o client.Operation) error

+ func (l *Log) Prepare(payload client.LogPayload) error

+ func (l *Log) Prepared() (client.LogPayload, error)

+ func (l *Log) Record(version uint64) (client.LogPayload, error)

+ func (l *Log) Rollback() error

+ func (l *Log) Service() *siesta.Service

+ func (l *Log) UnlockResources(o client.Operation)

+ type LogError struct

+ Err error

+ StatusCode int

+ Type string

+ func (err LogError) Error() string

+ type Service interface

+ Apply func(uint64, client.Operation) error

+ LockResources func(client.Operation) bool

+ UnlockResources func(client.Operation)

+ Validate func(client.Operation) error