ubolt

package
v0.0.0-...-70e0a4a Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 17, 2022 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var BucketName = []byte("v1_ukvs")

BucketName _

View Source
var ErrTimeoutReached = errors.New("timeout reached")

ErrTimeoutReached _

Functions

This section is empty.

Types

type Client

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

Client _

func NewClient

func NewClient(ctx context.Context, storagePath string) (*Client, error)

NewClient _

func (*Client) Closed

func (c *Client) Closed() <-chan struct{}

Closed _

func (*Client) Destroy

func (c *Client) Destroy(key string) error

Destroy _

func (*Client) ExpireAt

func (c *Client) ExpireAt(key string, t time.Time) error

ExpireAt _

func (*Client) FindAll

func (c *Client) FindAll(fctx context.Context, pattern string) (chan []byte, chan error)

FindAll _

func (*Client) Get

func (c *Client) Get(key string) ([]byte, error)

Get _

func (*Client) GetAll

func (c *Client) GetAll(fctx context.Context) (chan []byte, chan error)

GetAll _

func (*Client) Persist

func (c *Client) Persist() error

Persist _

func (*Client) Set

func (c *Client) Set(key string, val []byte) error

Set _

type Container

type Container struct {
	Val       []byte     `json:"val"`
	ExpiresAt *time.Time `json:"expires_at"`
}

Container _

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL