calvin

package module
v0.0.0-...-735feb9 Latest Latest
Warning

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

Go to latest
Published: Oct 17, 2019 License: Apache-2.0 Imports: 21 Imported by: 0

README

Calvin

This is a prototypical (read: experimental) implementation of Daniel Abadi's Calvin paper.

Future Work

  • richer data model
  • build partitions and make partitions mobile
  • cluster rebalancing
  • move stored to procedures to JS as that comes with a protobuf library :)

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewTransaction

func NewTransaction() *pb.Transaction

Types

type Calvin

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

func NewCalvin

func NewCalvin(opts Options) *Calvin

func (*Calvin) ChannelsToASCII

func (c *Calvin) ChannelsToASCII(out io.Writer)

func (*Calvin) LockChainToASCII

func (c *Calvin) LockChainToASCII(out io.Writer)

func (*Calvin) LogToJSON

func (c *Calvin) LogToJSON(out io.Writer) error

func (*Calvin) LowIsolationRead

func (c *Calvin) LowIsolationRead(key []byte) ([]byte, error)

func (*Calvin) Stop

func (c *Calvin) Stop()

func (*Calvin) SubmitTransaction

func (c *Calvin) SubmitTransaction(txn *pb.Transaction)

type Options

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

func DefaultOptions

func DefaultOptions(partitionedDataStore util.PartitionedDataStore, clusterInfoProvider util.ClusterInfoProvider) Options

func (Options) WithDataStore

func (o Options) WithDataStore(dataStore util.PartitionedDataStore) Options

func (Options) WithNumWorkers

func (o Options) WithNumWorkers(numWorkers int) Options

func (Options) WithPeers

func (o Options) WithPeers(peers []uint64) Options

func (Options) WithPort

func (o Options) WithPort(port int) Options

func (Options) WithRaftID

func (o Options) WithRaftID(raftID uint64) Options

func (Options) WithSnapshotHandler

func (o Options) WithSnapshotHandler(snapshotHandler sequencer.SnapshotHandler) Options

func (Options) WithStorePath

func (o Options) WithStorePath(storePath string) Options

Directories

Path Synopsis
pb

Jump to

Keyboard shortcuts

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