calvin

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

• func NewTransaction() *pb.Transaction
• type Calvin
  • func NewCalvin(opts Options) *Calvin
  • func (c *Calvin) ChannelsToASCII(out io.Writer)
  • func (c *Calvin) LockChainToASCII(out io.Writer)
  • func (c *Calvin) LogToJSON(out io.Writer) error
  • func (c *Calvin) LowIsolationRead(key []byte) ([]byte, error)
  • func (c *Calvin) Stop()
  • func (c *Calvin) SubmitTransaction(txn *pb.Transaction)
• type Options
  • func DefaultOptions(partitionedDataStore util.PartitionedDataStore, ...) Options
  • func (o Options) WithDataStore(dataStore util.PartitionedDataStore) Options
  • func (o Options) WithNumWorkers(numWorkers int) Options
  • func (o Options) WithPeers(peers []uint64) Options
  • func (o Options) WithPort(port int) Options
  • func (o Options) WithRaftID(raftID uint64) Options
  • func (o Options) WithSnapshotHandler(snapshotHandler sequencer.SnapshotHandler) Options
  • func (o Options) WithStorePath(storePath string) Options

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