bindings

Documentation

Index

• Constants
• func Call(cli *rpc.Client, method string, args interface{}, reply interface{}) error
• func Dial(addr string, connect bool) net.Conn
• type Parameters
  • func NewParameters(masterAddr string, masterPort int, verbose bool, leaderless bool, fast bool, ...) *Parameters
  • func (b *Parameters) Connect() error
  • func (b *Parameters) Disconnect()
  • func (b *Parameters) FindClosestReplica(replyRL *masterproto.GetReplicaListReply) error
  • func (b *Parameters) MasterDial() *rpc.Client
  • func (b *Parameters) Read(key int64) []byte
  • func (b *Parameters) Scan(key int64, count int64) []byte
  • func (b *Parameters) Stats() string
  • func (b *Parameters) Write(key int64, value []byte)

Constants

const MAX_ATTEMPTS = 3

const TIMEOUT = 3 * time.Second

const TRUE = uint8(1)

Functions

func Call

func Call(cli *rpc.Client, method string, args interface{}, reply interface{}) error

func Dial

func Dial(addr string, connect bool) net.Conn

Types

type Parameters

type Parameters struct {
	Leader int
	// contains filtered or unexported fields
}

func NewParameters

func NewParameters(masterAddr string, masterPort int, verbose bool, leaderless bool, fast bool, localReads bool) *Parameters

func (*Parameters) Connect

func (b *Parameters) Connect() error

func (*Parameters) Disconnect

func (b *Parameters) Disconnect()

func (*Parameters) FindClosestReplica

func (b *Parameters) FindClosestReplica(replyRL *masterproto.GetReplicaListReply) error

func (*Parameters) MasterDial

func (b *Parameters) MasterDial() *rpc.Client

func (*Parameters) Read

func (b *Parameters) Read(key int64) []byte

func (*Parameters) Scan

func (b *Parameters) Scan(key int64, count int64) []byte

func (*Parameters) Stats

func (b *Parameters) Stats() string

func (*Parameters) Write

func (b *Parameters) Write(key int64, value []byte)

not idempotent in case of a failure