chybrid

package
v0.0.0-...-060dca9 Latest Latest
Warning

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

Go to latest
Published: Nov 27, 2018 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Initialize

func Initialize(session *gocql.Session)

Types

type BucketSched

type BucketSched interface {
	NextBucket() ([]byte, bool)
}

type FastLookup

type FastLookup interface {
	FastLookup(bucket []byte) (srv netmodel.Server, rok bool)
}

type StoreReader

type StoreReader struct {
	Bucket  bucketstore.BucketR
	Session *gocql.Session
}

func (*StoreReader) StoreReadMessage

func (s *StoreReader) StoreReadMessage(id []byte, over, head, body bool) (result bufferex.Binary, err error)

type StoreWriter

type StoreWriter struct {
	Sched       BucketSched
	Flook       FastLookup
	Session     *gocql.Session
	UseFastOver bool
}

func (*StoreWriter) StoreWriteMessage

func (s *StoreWriter) StoreWriteMessage(id, msg []byte, expire uint64) (err error)

Jump to

Keyboard shortcuts

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