inmemory

Documentation

Index

• type NodeStore
  • func NewNodeStore(params NodeStoreParams) *NodeStore
  • func (r *NodeStore) Delete(ctx context.Context, nodeID string) error
  • func (r *NodeStore) Get(ctx context.Context, nodeID string) (models.NodeState, error)
  • func (r *NodeStore) GetByPrefix(ctx context.Context, prefix string) (models.NodeState, error)
  • func (r *NodeStore) List(ctx context.Context, filters ...nodes.NodeStateFilter) ([]models.NodeState, error)
  • func (r *NodeStore) Put(ctx context.Context, state models.NodeState) error
• type NodeStoreParams

Types

type NodeStore

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

func NewNodeStore

func NewNodeStore(params NodeStoreParams) *NodeStore

func (*NodeStore) Delete

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

func (*NodeStore) Get

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

func (*NodeStore) GetByPrefix

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

func (*NodeStore) List

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

func (*NodeStore) Put

func (r *NodeStore) Put(ctx context.Context, state models.NodeState) error

type NodeStoreParams

type NodeStoreParams struct {
	TTL time.Duration
}