provider

Documentation

Index

• Constants
• Variables
• func OptionGet(v any, opt string) any
• func OptionSet(v any, opt string, value any) error
• func OptionType(v any, opt string) reflect.Type
• func Options(v any) []string
• func SetOptions(val any, opts map[string]string) error
• type Provider
• type SinkBuilder
• type SinkOptions
• type SourceBuilder
• type SourceOptions
• type UnsupportedSinkBuilder
  • func (b UnsupportedSinkBuilder) Build() (api.Sink, api.CloseWaitFunc, error)
  • func (b UnsupportedSinkBuilder) Set(_ string, _ any) SinkBuilder
  • func (b UnsupportedSinkBuilder) WithSinkRef(_ string) SinkBuilder
• type UnsupportedSourceBuilder
  • func (b UnsupportedSourceBuilder) Build() (api.Source, api.CloseWaitFunc, error)
  • func (b UnsupportedSourceBuilder) Set(_ string, _ any) SourceBuilder
  • func (b UnsupportedSourceBuilder) WithSourceRef(_ string) SourceBuilder

Constants

const (
	OptionCASAlgorithm = "cas-algorithm"
)

Variables

var ErrUnsupported = errors.New("unsupported")

Functions

func OptionGet

func OptionGet(v any, opt string) any

OptionGet returns the value of the option as any.

func OptionSet

func OptionSet(v any, opt string, value any) error

OptionSet sets the value of the option.

func OptionType

func OptionType(v any, opt string) reflect.Type

OptionType returns the type of the option.

func Options

func Options(v any) []string

Options uses struct field tags to determine the options of a type.

func SetOptions

func SetOptions(val any, opts map[string]string) error

Types

type Provider

type Provider interface {
	Name() string
	SourceBuilder() SourceBuilder
	SinkBuilder() SinkBuilder
	CAS() (api.CAS, api.CloseWaitFunc, error)
	CASReader() (api.CASReader, api.CloseWaitFunc, error)
	CASWriter() (api.CASWriter, api.CloseWaitFunc, error)
}

type SinkBuilder

type SinkBuilder interface {
	WithSinkRef(string) SinkBuilder
	Set(string, any) SinkBuilder
	Build() (api.Sink, api.CloseWaitFunc, error)
}

type SinkOptions

type SinkOptions interface {
	SinkRef() string
}

type SourceBuilder

type SourceBuilder interface {
	WithSourceRef(string) SourceBuilder
	Build() (api.Source, api.CloseWaitFunc, error)
}

type SourceOptions

type SourceOptions interface {
	SourceRef() string
}

type UnsupportedSinkBuilder

type UnsupportedSinkBuilder struct{}

func (UnsupportedSinkBuilder) Build

func (b UnsupportedSinkBuilder) Build() (api.Sink, api.CloseWaitFunc, error)

func (UnsupportedSinkBuilder) Set

func (b UnsupportedSinkBuilder) Set(_ string, _ any) SinkBuilder

func (UnsupportedSinkBuilder) WithSinkRef

func (b UnsupportedSinkBuilder) WithSinkRef(_ string) SinkBuilder

type UnsupportedSourceBuilder

type UnsupportedSourceBuilder struct{}

func (UnsupportedSourceBuilder) Build

func (b UnsupportedSourceBuilder) Build() (api.Source, api.CloseWaitFunc, error)

func (UnsupportedSourceBuilder) Set

func (b UnsupportedSourceBuilder) Set(_ string, _ any) SourceBuilder

func (UnsupportedSourceBuilder) WithSourceRef

func (b UnsupportedSourceBuilder) WithSourceRef(_ string) SourceBuilder