Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Initialize ¶
Types ¶
type BucketSched ¶
type FastLookup ¶
type StoreReader ¶
type StoreReader struct { Bucket bucketstore.BucketR Session *gocql.Session }
func (*StoreReader) StoreReadMessage ¶
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)
Click to show internal directories.
Click to hide internal directories.