memproxy

type CallbackFunc struct {
	Object unsafe.Pointer
	Func   func(obj unsafe.Pointer)
}

type DeleteOptions struct {
}

type DeleteResponse struct {
}

type LeaseGetErrorResult struct {
	Error error
}

type LeaseGetOptions struct {
}

type LeaseGetResponse struct {
	Status LeaseGetStatus
	CAS    uint64
	Data   []byte
}

type LeaseGetResult interface {
	Result() (LeaseGetResponse, error)
}

type LeaseGetResultFunc func() (LeaseGetResponse, error)

type LeaseGetStatus uint32

type LeaseSetOptions struct {
	TTL uint32
}

type LeaseSetResponse struct {
	Status LeaseSetStatus
}

type LeaseSetStatus uint32

type Memcache interface {
	// Pipeline creates a Pipeline, a NON thread safe object
	Pipeline(ctx context.Context, options ...PipelineOption) Pipeline

	// Close shutdowns memcache client
	Close() error
}

type Pipeline interface {
	// LeaseGet should not be used directly, use the item or mmap package instead
	LeaseGet(key string, options LeaseGetOptions) LeaseGetResult

	LeaseSet(key string, data []byte, cas uint64, options LeaseSetOptions) func() (LeaseSetResponse, error)
	Delete(key string, options DeleteOptions) func() (DeleteResponse, error)

	// Execute flush commands to the network
	Execute()

	// Finish must be called after create a Pipeline, often by defer
	Finish()

	// LowerSession returns a lower priority session
	LowerSession() Session
}

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

type PipelineOption func(conf *PipelineConfig)

type PlainMemcacheOption func(opts *plainMemcacheConfig)

type Session interface {
	AddNextCall(fn CallbackFunc)
	AddDelayedCall(d time.Duration, fn CallbackFunc)
	Execute()

	GetLower() Session
}

type SessionProvider interface {
	New() Session
}

type SessionProviderOption func(conf *sessionProviderConf)