docstore

package

v0.0.0-...-382cb39 Latest Latest Go to latest Published: Dec 1, 2017 License: Apache-2.0 Imports: 20 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/v2pro/quokka

Links

Open Source Insights

README ¶

storage of small data

Documentation ¶

Index ¶

Constants
func AddEntity(entityType string, schema *runtime.Schema) *entityTypeDef
func AddEventHandler(handler EventHandler)
func Entity(entityType string, thriftIDL string) *entityTypeDef
func StartNode(ctx context.Context, addr string)
func StopNode(ctx context.Context)
type CommandHandler
type Event
type EventHandler
type NumberedError

Constants ¶

View Source

const ErrBusinessRuleViolated = 20002 // `throw` in javascript code means business rule violation

View Source

const ErrDocumentSchemaViolated = 10004

View Source

const ErrDuplicatedEntity = LoggedErrStart // create entity with same entity id but with different command id

View Source

const ErrEntityMissing = 10006 // query can not find the entity

View Source

const ErrEventLogConflict = 10001 // the master is no longer in charge, should find out who is the master

View Source

const ErrForwardedTooManyTimes = 10002 // the master can not be found

View Source

const ErrMustCreateFirst = 20001 // entity not created yet, so can not exec other command

View Source

const ErrRequestSchemaViolated = 10003

View Source

const ErrResponseSchemaViolated = 10005

View Source

const ErrUnknown = 10000

View Source

const LoggedErrEnd = 30000

View Source

const LoggedErrStart = 20000

error number within range [LoggedErrStart, LoggedErrEnd) is committed in event_log as fact

Variables ¶

This section is empty.

Functions ¶

func AddEntity ¶

func AddEntity(entityType string, schema *runtime.Schema) *entityTypeDef

func AddEventHandler ¶

func AddEventHandler(handler EventHandler)

func Entity ¶

func Entity(entityType string, thriftIDL string) *entityTypeDef

func StartNode ¶

func StartNode(ctx context.Context, addr string)

func StopNode ¶

func StopNode(ctx context.Context)

Types ¶

type CommandHandler ¶

type CommandHandler func(doc interface{}, request interface{}) (resp interface{})

type Event ¶

type Event struct {
	PartitionId     uint64          `json:"-"`
	EntityType      string          `json:"-"`
	EventId         uint64          `json:"-"`
	EntityId        string          `json:"e"`
	BaseEventId     uint64          `json:"b"`
	Version         uint64          `json:"v"`
	CommandId       string          `json:"c"`
	CommandType     string          `json:"t"`
	CommandRequest  json.RawMessage `json:"r"`
	HandlerVersion  string          `json:"h"`
	CommandResponse json.RawMessage `json:"p"`
	State           json.RawMessage `json:"s"`
	Delta           json.RawMessage `json:"d"`
	CommittedAt     int64           `json:"a"`
}

type EventHandler ¶

type EventHandler interface {
	LoadOffset(ctx context.Context, partitionId uint64, entityType string) (uint64, error)
	CommitOffset(ctx context.Context, partitionId uint64, entityType string, offset uint64) error
	Sync(ctx context.Context, event *Event) error
}

type NumberedError ¶

type NumberedError interface {
	error
	ErrorNumber() int
}

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
compiler
runtime
thrift
transpiler

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