ncstreams

Documentation

Index

• func Open(ctx context.Context, url string, subFnk getSubscriberFnk, options ...Option) (eventstream.Sourcer, error)
• type Option
  • func WithDebug(debug bool) Option
  • func WithFormat(format string) Option
• type Options

Functions

func Open

func Open(ctx context.Context, url string, subFnk getSubscriberFnk, options ...Option) (eventstream.Sourcer, error)

Open new source by URLs

Types

type Option

type Option func(opts *Options)

Option modificator callback

func WithDebug

func WithDebug(debug bool) Option

WithDebug puts debug mode into the source

func WithFormat

func WithFormat(format string) Option

WithFormat puts format name into the source

type Options

type Options struct {
	// Debug mode of the source
	Debug bool

	// Format converter
	Format converter.Converter
}

Options contains options of the source