object

Apr 27, 2025

Changes in this version

type Client

+ func (c *Client) AnnouncePrefix(args ndn.Announcement)

+ func (c *Client) AttachCommandHandler(handlerName enc.Name, handler func(enc.Name, enc.Wire, func(enc.Wire) error)) error

+ func (c *Client) DetachCommandHandler(name enc.Name) error

+ func (c *Client) ExpressCommand(dest enc.Name, name enc.Name, cmd enc.Wire, callback func(enc.Wire, error))

+ func (c *Client) WithdrawPrefix(name enc.Name, onError func(error))

Apr 16, 2025

Changes in this version

type BoltStore — darwin/amd64, linux/amd64, windows/amd64

+ func (s *BoltStore) RemoveFlatRange(prefix enc.Name, first enc.Component, last enc.Component) error

+ func (s *BoltStore) RemovePrefix(prefix enc.Name) error

+ type JsStore struct — js/wasm

+ func NewJsStore(api js.Value) *JsStore

+ func (s *JsStore) Begin() (ndn.Store, error)

+ func (s *JsStore) Commit() error

+ func (s *JsStore) Get(name enc.Name, prefix bool) ([]byte, error)

+ func (s *JsStore) Put(name enc.Name, version uint64, wire []byte) error

+ func (s *JsStore) Remove(name enc.Name) error

+ func (s *JsStore) RemoveFlatRange(prefix enc.Name, first enc.Component, last enc.Component) error

+ func (s *JsStore) RemovePrefix(prefix enc.Name) error

+ func (s *JsStore) Rollback() error

type MemoryStore

+ func (s *MemoryStore) RemoveFlatRange(prefix enc.Name, first enc.Component, last enc.Component) error

+ func (s *MemoryStore) RemovePrefix(prefix enc.Name) error

Feb 15, 2025

Changes in this version

+ func ExpressR(engine ndn.Engine, args ndn.ExpressRArgs)

+ type CachingStore struct

+ func NewCachingStore(store ndn.Store) *CachingStore

+ func (s *CachingStore) Begin() (ndn.Store, error)

+ func (s *CachingStore) Close() error

+ func (s *CachingStore) Commit() error

+ func (s *CachingStore) Flush() error

+ func (s *CachingStore) Get(name enc.Name, prefix bool) ([]byte, error)

+ func (s *CachingStore) Put(name enc.Name, version uint64, wire []byte) error

+ func (s *CachingStore) Remove(name enc.Name, prefix bool) error

+ func (s *CachingStore) Rollback() error

+ func (s *CachingStore) String() string

type Client

+ func (c *Client) GetLocal(name enc.Name) (enc.Wire, error)

+ func (c *Client) IsCongested() bool

+ func (c *Client) LatestLocal(name enc.Name) (enc.Name, error)

type ConsumeState

+ func (a *ConsumeState) Cancel()

+ func (a *ConsumeState) Version() uint64

Jan 25, 2025

Changes in this version

+ func Produce(args ndn.ProduceArgs, store ndn.Store, signer ndn.Signer) (enc.Name, error)

type Client

+ func (c *Client) Client() ndn.Client

+ func (c *Client) ConsumeExt(args ndn.ConsumeExtArgs)

+ func (c *Client) Remove(name enc.Name) error

+ func (c *Client) Store() ndn.Store

+ func (c *Client) String() string

+ func (c *Client) SuggestSigner(name enc.Name) ndn.Signer

+ func (c *Client) Validate(data ndn.Data, sigCov enc.Wire, callback func(bool, error))

+ func (c *Client) ValidateExt(args ndn.ValidateExtArgs)

+ type MemoryFifoDir struct

+ func NewMemoryFifoDir(size int) *MemoryFifoDir

+ func (d *MemoryFifoDir) Count() int

+ func (d *MemoryFifoDir) Evict(client ndn.Client) error

+ func (d *MemoryFifoDir) Pop() enc.Name

+ func (d *MemoryFifoDir) Push(name enc.Name)

type MemoryStore

+ func (s *MemoryStore) MemSize() int

Dec 24, 2024

Changes in this version

+ var BoltBucket = []byte("data")

+ var ErrBoltNoBucket = errors.New("no bucket in bolt")

+ type BoltStore struct

+ func NewBoltStore(path string) (*BoltStore, error)

+ func (s *BoltStore) Begin() error

+ func (s *BoltStore) Close() error

+ func (s *BoltStore) Commit() error

+ func (s *BoltStore) Get(name enc.Name, prefix bool) (wire []byte, err error)

+ func (s *BoltStore) Put(name enc.Name, version uint64, wire []byte) error

+ func (s *BoltStore) Remove(name enc.Name, prefix bool) error

+ func (s *BoltStore) Rollback() error

+ type Client struct

+ func NewClient(engine ndn.Engine, store ndn.Store) *Client

+ func (c *Client) Consume(name enc.Name, callback ConsumeCallback)

+ func (c *Client) Engine() ndn.Engine

+ func (c *Client) ExpressR(args ExpressRArgs, callback ndn.ExpressCallbackFunc)

+ func (c *Client) Produce(args ProduceArgs) (enc.Name, error)

+ func (c *Client) Start() error

+ func (c *Client) Stop()

+ type ConsumeCallback func(status *ConsumeState) bool

+ type ConsumeState struct

+ func (a *ConsumeState) Content() []byte

+ func (a *ConsumeState) Error() error

+ func (a *ConsumeState) IsComplete() bool

+ func (a *ConsumeState) Name() enc.Name

+ func (a *ConsumeState) Progress() int

+ func (a *ConsumeState) ProgressMax() int

+ type ExpressRArgs struct

+ AppParam enc.Wire

+ Config *ndn.InterestConfig

+ Name enc.Name

+ Retries int

+ Signer ndn.Signer

+ type MemoryStore struct

+ func NewMemoryStore() *MemoryStore

+ func (s *MemoryStore) Begin() error

+ func (s *MemoryStore) Commit() error

+ func (s *MemoryStore) Get(name enc.Name, prefix bool) ([]byte, error)

+ func (s *MemoryStore) Put(name enc.Name, version uint64, wire []byte) error

+ func (s *MemoryStore) Remove(name enc.Name, prefix bool) error

+ func (s *MemoryStore) Rollback() error

+ type ProduceArgs struct

+ Content enc.Wire

+ Expiry time.Time

+ FreshnessPeriod time.Duration

+ Name enc.Name

+ Version *uint64