replicatedstream

Documentation

Overview

Package replicatedstream implements helpers to load replicated schemas for testing.

Index

• func LoadSchemaWithStages(ctx context.Context, e schema.Registry) error
• func PreloadSchema(ctx context.Context, e schema.Registry) error

Functions

func LoadSchemaWithStages

func LoadSchemaWithStages(ctx context.Context, e schema.Registry) error

LoadSchemaWithStages loads schemas from files, including group stages.

func PreloadSchema

func PreloadSchema(ctx context.Context, e schema.Registry) error

PreloadSchema loads schemas from files in the booting process. This version loads group without stages.