inventory_list_coders

package
v0.0.0-...-2e33cca Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 24, 2026 License: MIT Imports: 17 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func CollectSkuList 

func CollectSkuList(
	ctx interfaces.ActiveContext,
	listFormat sku.ListCoder,
	reader *bufio.Reader,
	list *sku.HeapTransacted,
) (err error)

TODO also return a repool func

func WriteInventoryList 

func WriteInventoryList(
	ctx interfaces.ActiveContext,
	format sku.ListCoder,
	skus interfaces.SeqError[*sku.Transacted],
	bufferedWriter *bufio.Writer,
) (n int64, err error)

Types

type Closet 

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

func MakeCloset 

func MakeCloset(
	envRepo env_repo.Env,
	box *box_format.BoxTransacted,
) Closet

func (Closet) AllDecodedObjectsFromStream 

func (closet Closet) AllDecodedObjectsFromStream(
	reader io.Reader,
	afterDecoding func(*sku.Transacted) error,
) interfaces.SeqError[*sku.Transacted]

func (Closet) GetBoxFormat 

func (closet Closet) GetBoxFormat() *box_format.BoxTransacted

func (Closet) GetCoderForType 

func (closet Closet) GetCoderForType(tipe ids.TypeStruct) sku.ListCoder

func (Closet) IterInventoryListBlobSkusFromBlobStore 

func (closet Closet) IterInventoryListBlobSkusFromBlobStore(
	tipe ids.TypeStruct,
	blobStore domain_interfaces.BlobStore,
	blobId domain_interfaces.MarklId,
) interfaces.SeqError[*sku.Transacted]

func (Closet) IterInventoryListBlobSkusFromReader 

func (closet Closet) IterInventoryListBlobSkusFromReader(
	tipe ids.TypeStruct,
	reader io.Reader,
) interfaces.SeqError[*sku.Transacted]

func (Closet) ReadInventoryListBlob 

func (closet Closet) ReadInventoryListBlob(
	ctx interfaces.ActiveContext,
	tipe ids.TypeStruct,
	reader *bufio.Reader,
) (list *sku.HeapTransacted, err error)

func (Closet) ReadInventoryListObject 

func (closet Closet) ReadInventoryListObject(
	ctx interfaces.ActiveContext,
	tipe domain_interfaces.ObjectId,
	reader *bufio.Reader,
) (out *sku.Transacted, err error)

func (Closet) StreamInventoryListBlobSkus 

func (closet Closet) StreamInventoryListBlobSkus(
	transactedGetter sku.TransactedGetter,
) interfaces.SeqError[*sku.Transacted]

func (Closet) WriteBlobToWriter 

func (closet Closet) WriteBlobToWriter(
	ctx interfaces.ActiveContext,
	tipe domain_interfaces.ObjectId,
	seq sku.Seq,
	bufferedWriter *bufio.Writer,
) (n int64, err error)

TODO consume interfaces.SeqError and expose as a coder instead

func (Closet) WriteObjectToWriter 

func (closet Closet) WriteObjectToWriter(
	tipe ids.TypeStruct,
	object *sku.Transacted,
	bufferedWriter *bufio.Writer,
) (n int64, err error)

func (Closet) WriteTypedBlobToWriter 

func (closet Closet) WriteTypedBlobToWriter(
	ctx interfaces.ActiveContext,
	tipe ids.TypeStruct,
	seq sku.Seq,
	bufferedWriter *bufio.Writer,
) (n int64, err error)

type ErrAfterDecoding 

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

func (ErrAfterDecoding) Error 

func (err ErrAfterDecoding) Error() string

func (ErrAfterDecoding) GetErrorType 

func (err ErrAfterDecoding) GetErrorType() pkgErrDisamb

func (ErrAfterDecoding) Is 

func (err ErrAfterDecoding) Is(target error) bool

func (ErrAfterDecoding) Unwrap 

func (err ErrAfterDecoding) Unwrap() error

type SeqCoder 

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

TODO swap SeqCoder to support yielding errors

func (SeqCoder) DecodeFrom 

func (coder SeqCoder) DecodeFrom(
	yield func(*sku.Transacted) bool,
	bufferedReader *bufio.Reader,
) (n int64, err error)

type SeqErrorDecoder 

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

func (SeqErrorDecoder) DecodeFrom 

func (coder SeqErrorDecoder) DecodeFrom(
	yield func(*sku.Transacted, error) bool,
	bufferedReader *bufio.Reader,
) (n int64, err error)

func (SeqErrorDecoder) EncodeTo 

func (coder SeqErrorDecoder) EncodeTo(
	seq sku.Seq,
	bufferedWriter *bufio.Writer,
) (n int64, err error)

type SeqErrorEncoder 

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

Source Files

  • closet.go
  • coder.go
  • doddish.go
  • errors.go
  • json_v0.go
  • main.go

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.