netkinetic

Documentation

Index

• Constants
• func Generate(co kinetic.ClientOptions) []byte
• type Bucket
  • func (b *Bucket) BucketDelete(bucket, key []byte) error
  • func (b *Bucket) BucketGet(bucket, key []byte) (buf bufferex.Binary, err error)
  • func (b *Bucket) BucketPut(bucket, key, value []byte) error
  • func (b *Bucket) Close() error
• type ReportingBucket
  • func (b *ReportingBucket) CheckLoop()
  • func (b *ReportingBucket) Close() error

Constants

const PROVIDER = "kinetic"

Functions

func Generate

func Generate(co kinetic.ClientOptions) []byte

Types

type Bucket

type Bucket struct {
	Cli *kinetic.BlockConnection
}

func (*Bucket) BucketDelete

func (b *Bucket) BucketDelete(bucket, key []byte) error

func (*Bucket) BucketGet

func (b *Bucket) BucketGet(bucket, key []byte) (buf bufferex.Binary, err error)

func (*Bucket) BucketPut

func (b *Bucket) BucketPut(bucket, key, value []byte) error

func (*Bucket) Close

func (b *Bucket) Close() error

type ReportingBucket

type ReportingBucket struct {
	Bucket
	Name []byte
	// contains filtered or unexported fields
}

func (*ReportingBucket) CheckLoop

func (b *ReportingBucket) CheckLoop()

func (*ReportingBucket) Close

func (b *ReportingBucket) Close() error