examples

README

Examples

This is the examples directory. If you would like intellisense for the examples, install the dependencies like so:

cd examples
bun install

Documentation

Index

• func ExpectData[K comparable, V comparable](ctx context.Context, streamClient skip.StreamClient, uuid string, ...) error
• func StartSkipContainer(ctx context.Context, path string) (func(), error)
• func UpdateInputCollection(ctx context.Context, t *testing.T, controlClient skip.ControlClient, ...)
• func WaitForIO()
• type StreamEvent

Functions

func ExpectData

func ExpectData[K comparable, V comparable](ctx context.Context, streamClient skip.StreamClient, uuid string, expected []StreamEvent[K, V]) error

func StartSkipContainer

func StartSkipContainer(ctx context.Context, path string) (func(), error)

StartSkipContainer creates a Skip container and returns a cleanup function to terminate it. The given path is the path to the skip.ts file to be used in the container. This is not suitable for production use but is useful for testing and development.

func UpdateInputCollection

func UpdateInputCollection(ctx context.Context, t *testing.T, controlClient skip.ControlClient, collection string, update []skip.CollectionData)

func WaitForIO

func WaitForIO()

Types

type StreamEvent

type StreamEvent[K comparable, V comparable] struct {
	Type skip.StreamType
	Data []skip.CollectionValue[K, V]
}