event

Documentation

Index

• func Marshal[T any](event Event[T], dataUnbinder node.Unbinder[T]) ([]byte, error)
• func MarshalBlock[T any](e Event[T], dataUnbinder node.Unbinder[T]) (block.BlockView[Event[T]], error)
• type BlockView
• type Event
  • func NewEvent[T any](data T, parents []ipld.Link) Event[T]
  • func Unmarshal[T any](b []byte, dataBinder node.Binder[T]) (Event[T], error)
• type Fetcher
  • func NewFetcher[T any](blocks block.Fetcher, dataBinder node.Binder[T]) *Fetcher[T]
  • func (f *Fetcher[T]) Get(ctx context.Context, link ipld.Link) (BlockView[T], error)

Functions

func Marshal

func Marshal[T any](event Event[T], dataUnbinder node.Unbinder[T]) ([]byte, error)

Marshal serializes an Event to CBOR encoded bytes.

func MarshalBlock

func MarshalBlock[T any](e Event[T], dataUnbinder node.Unbinder[T]) (block.BlockView[Event[T]], error)

MarshalBlock serializes the Event to CBOR encoded bytes, takes the sha2-256 hash of the data, constructs a CID and returns a block.Block.

Types

type BlockView

type BlockView[T any] interface {
	block.BlockView[Event[T]]
}

type Event

type Event[T any] interface {
	Parents() []ipld.Link
	Data() T
}

func NewEvent

func NewEvent[T any](data T, parents []ipld.Link) Event[T]

func Unmarshal

func Unmarshal[T any](b []byte, dataBinder node.Binder[T]) (Event[T], error)

Unmarshal deserializes CBOR encoded bytes to an Event.

type Fetcher

type Fetcher[T any] struct {
	// contains filtered or unexported fields
}

func NewFetcher

func NewFetcher[T any](blocks block.Fetcher, dataBinder node.Binder[T]) *Fetcher[T]

func (*Fetcher[T]) Get

func (f *Fetcher[T]) Get(ctx context.Context, link ipld.Link) (BlockView[T], error)