kvstore

Documentation

Index

• Constants
• type NodeStore
  • func NewNodeStore(ctx context.Context, params NodeStoreParams) (*NodeStore, error)
  • func (n *NodeStore) Add(ctx context.Context, state models.NodeState) error
  • func (n *NodeStore) Delete(ctx context.Context, nodeID string) error
  • func (n *NodeStore) FindPeer(ctx context.Context, peerID peer.ID) (peer.AddrInfo, error)
  • func (n *NodeStore) Get(ctx context.Context, nodeID string) (models.NodeState, error)
  • func (n *NodeStore) GetByPrefix(ctx context.Context, prefix string) (models.NodeState, error)
  • func (n *NodeStore) List(ctx context.Context, filters ...routing.NodeStateFilter) ([]models.NodeState, error)
• type NodeStoreParams

Constants

const (
	// BucketNameCurrent is the bucket name for bacalhau version v1.3.1 and beyond.
	BucketNameCurrent = "node_v1"
	// BucketNameV0 is the bucket name for bacalhau version v1.3.0 and below.
	BucketNameV0 = "nodes"
)

Types

type NodeStore

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

func NewNodeStore

func NewNodeStore(ctx context.Context, params NodeStoreParams) (*NodeStore, error)

func (*NodeStore) Add

func (n *NodeStore) Add(ctx context.Context, state models.NodeState) error

Add adds a node state to the repo.

func (*NodeStore) Delete

func (n *NodeStore) Delete(ctx context.Context, nodeID string) error

Delete deletes a node state from the repo.

func (*NodeStore) FindPeer

func (n *NodeStore) FindPeer(ctx context.Context, peerID peer.ID) (peer.AddrInfo, error)

func (*NodeStore) Get

func (n *NodeStore) Get(ctx context.Context, nodeID string) (models.NodeState, error)

Get returns the node state for the given node ID.

func (*NodeStore) GetByPrefix

func (n *NodeStore) GetByPrefix(ctx context.Context, prefix string) (models.NodeState, error)

GetByPrefix returns the node state for the given node ID. Supports both full and short node IDs band currently iterates through all of the keys to find matches, due to NATS KVStore not supporting prefix searches (yet).

func (*NodeStore) List

func (n *NodeStore) List(ctx context.Context, filters ...routing.NodeStateFilter) ([]models.NodeState, error)

List returns a list of nodes

type NodeStoreParams

type NodeStoreParams struct {
	BucketName string
	Client     *nats.Conn
}