store

Documentation

Index

• Constants
• type Codec
• type Store
  • func New(db *pebble.DB, codec Codec) *Store
  • func (s *Store) Keys() []string
  • func (s *Store) RemoveFunction(_ context.Context, cid string) error
  • func (s *Store) RemovePeer(_ context.Context, id peer.ID) error
  • func (s *Store) RetrieveFunction(_ context.Context, cid string) (blockless.FunctionRecord, error)
  • func (s *Store) RetrieveFunctions(_ context.Context) ([]blockless.FunctionRecord, error)
  • func (s *Store) RetrievePeer(_ context.Context, id peer.ID) (blockless.Peer, error)
  • func (s *Store) RetrievePeers(_ context.Context) ([]blockless.Peer, error)
  • func (s *Store) SaveFunction(_ context.Context, function blockless.FunctionRecord) error
  • func (s *Store) SavePeer(_ context.Context, peer blockless.Peer) error

Constants

const (
	PrefixPeer     = 1
	PrefixFunction = 2
)

const (
	Separator = ':'
)

Types

type Codec

type Codec interface {
	Marshal(any) ([]byte, error)
	Unmarshal([]byte, any) error
}

type Store

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

Store enables interaction with a database.

func New

func New(db *pebble.DB, codec Codec) *Store

New creates a new Store backed by the database at the given path.

func (*Store) Keys

func (s *Store) Keys() []string

Keys returns the list of all keys in the database.

func (*Store) RemoveFunction

func (s *Store) RemoveFunction(_ context.Context, cid string) error

func (*Store) RemovePeer

func (s *Store) RemovePeer(_ context.Context, id peer.ID) error

func (*Store) RetrieveFunction

func (s *Store) RetrieveFunction(_ context.Context, cid string) (blockless.FunctionRecord, error)

func (*Store) RetrieveFunctions

func (s *Store) RetrieveFunctions(_ context.Context) ([]blockless.FunctionRecord, error)

func (*Store) RetrievePeer

func (s *Store) RetrievePeer(_ context.Context, id peer.ID) (blockless.Peer, error)

func (*Store) RetrievePeers

func (s *Store) RetrievePeers(_ context.Context) ([]blockless.Peer, error)

func (*Store) SaveFunction

func (s *Store) SaveFunction(_ context.Context, function blockless.FunctionRecord) error

func (*Store) SavePeer

func (s *Store) SavePeer(_ context.Context, peer blockless.Peer) error