The highest tagged major version is v4.

storage

package

v2.2.9 Latest Latest Go to latest Published: May 17, 2024 License: MIT Imports: 8 Imported by: 0

Details

Package storage contains the storage processor which allows to concurrently store the processed data in a storage system.

View Source

const Name = "storage"

Name of the processor.

This section is empty.

This section is empty.

type Storage[In any] struct {
	processor.IProcessor[In] `json:"processor" validate:"required"`
}

Storage definition.

func Must[In any](
	s storage.IStorage,
	concurrency int,
	idPrefix string,
	opts ...processor.Func[In],
) *Storage[In]

Must returns a new processor or panics if an error occurs.

func New[In any](
	s storage.IStorage,
	concurrency int,
	idPrefix string,
	opts ...processor.Func[In],
) (*Storage[In], error)

New creates a new Storage processor.

NOTE: Mininum concurrency is 1. NOTE: idPrefix example: "news-"