creek

package

v0.2.0 Latest Latest Go to latest Published: Jun 6, 2022 License: MIT Imports: 5 Imported by: 0

Details

This section is empty.

This section is empty.

func Must[T stream.Thing](kv stream.Stream[T], err error) stream.Stream[T]

Must is a helper function to ensure KeyVal interface is valid and there was no error when calling a New function.

This helper is intended to be used in variable initialization to load the interface and configuration at startup. Such as:

var io = dynamo.Must(dynamo.New())

func New[T stream.Thing](
	uri string,
	defSession ...*session.Session,
) (stream.Stream[T], error)

New creates a stream client to access Things at AWS storage service. The connection URI controls the access parameters.

Supported scheme:

s3:///my-bucket

This section is empty.