atur

type Int32 struct{ V int32 }

type Int64 struct{ V int64 }

type KvOption func(*KvStoreConfig)

type KvStore interface {

	// Set kv pair to KVstore
	// input:
	// ctx : context
	// key : []byte
	// value : a Serializable Object, must be a point
	//
	// return :
	// error
	SetCtx(ctx context.Context, key []byte, value Serializable) (err error)

	// Delete the key from KVstore
	// input:
	// ctx : context
	// key : []byte
	//
	// return:
	// error
	DelCtx(ctx context.Context, key []byte) (err error)

	// Get kv pair from KVstore
	// input:
	// ctx : context
	// key : []byte
	// value : a Serializable Object, must be an initialized point,
	// 				 a null point is not availiable.
	//
	// return:
	// error
	GetCtx(ctx context.Context, key []byte, value Serializable) (err error)

	// Set a TTL kv pair to KVstore
	// input:
	// ctx : context
	// key : []byte
	// value : a Serializable Object, must be a TTLSerializable point
	//
	// return:
	// error
	SetTTLCtx(ctx context.Context, key []byte, value TTLSerializable) (err error)

	// Get TTL kv pair from KVstore
	// input:
	// ctx : context
	// key : []byte
	// value : a TTLSerializable Object, must be an initialized point,
	// 				 a null point is not availiable.
	//
	// return:
	// error
	GetTTLCtx(ctx context.Context, key []byte, value TTLSerializable) (err error)

	// Check if the key exist or not
	// input:
	// ctx : context
	// key : []byte
	//
	// return:
	// exist bool
	Exist(ctx context.Context, key []byte) (exist bool)

	// maybe only used by leveldbKvStore
	GetFull() map[string]string
	Close() (err error)
}

type KvStoreConfig struct {
	Dir            string
	Shards         int
	LeveldbOptions *leveldbOpt.Options
}

type Object interface {
	GetId() []byte
	Serializable
}

type Serializable interface {
	// This function support to serialize the object to []byte
	// in order to write down to the disk
	// this fuction **MUST** be no error, this rule must be
	// obeyed by the implementor.
	Serialize() []byte

	// Unserialize the []byte to Object.
	Unserialize(s []byte) (err error)
}

type SpinLock struct {
	// contains filtered or unexported fields
}

type TTLSerializable interface {
	TtlObject
	Serializable
}

type TtlObject interface {
	// return the last time (unix ms) this Object can keep.
	GetTTLTime() int64
}

type Uint32 struct{ V uint32 }

type Uint64 struct{ V uint64 }