db

package

v0.0.0-...-3d70050 Latest Latest Go to latest Published: Jan 3, 2026 License: MIT Imports: 18 Imported by: 0

Details

View Source

const (
	KEY_HEADER    = "Key"
	LENGTH_HEADER = "Length"
)

View Source

var ErrServerClosed = errors.New("simple-db: Server closed")

View Source

var (
	ErrTimeout = fmt.Errorf("request timed out")
)

This section is empty.

type Operation string

const (
	PUT    Operation = "PUT"
	GET    Operation = "GET"
	DELETE Operation = "DELETE"
)

func (op Operation) IsValid() bool

type Options struct {
	Logger       *slog.Logger
	LogLevel     slog.Level
	MemTableType memtable.Type
}

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

func NewSimpleDb(address string) (*SimpleDb, error)

func NewSimpleWithOptions(address string, options Options) (*SimpleDb, error)

func (sdb *SimpleDb) Delete(key string) error

func (sdb *SimpleDb) Get(key string) (string, bool)

func (sdb *SimpleDb) Put(key, value string) error

func (sdb *SimpleDb) Shutdown(ctx context.Context) error

func (sdb *SimpleDb) Start() error

func (sdb *SimpleDb) Stop() error

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

func NewSimpleDbClient(address string) (*SimpleDbClient, error)

func (client *SimpleDbClient) Close() error

func (client *SimpleDbClient) Delete(ctx context.Context, key string) (string, error)

func (client *SimpleDbClient) Get(ctx context.Context, key string) (string, error)

func (client *SimpleDbClient) Put(ctx context.Context, key, value string) (string, error)

func (client *SimpleDbClient) Reconnect() error