glue

package

v0.0.3 Latest Latest Go to latest Published: Mar 4, 2024 License: MIT Imports: 14 Imported by: 1

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/ln80/event-store

Links

Open Source Insights

Documentation ¶

Index ¶

type Adapter
- func NewAdapter(registryName string, client ClientAPI) *Adapter
type ClientAPI
- func NewClient(cfg aws.Config) ClientAPI
type MockClientAPI
type WireFormatter
- func NewWireFormatter() *WireFormatter
- func (*WireFormatter) AppendSchemaID(data []byte, id string) ([]byte, error)
- func (*WireFormatter) ExtractSchemaID(data []byte) (string, []byte, error)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Adapter ¶ added in v0.0.3

type Adapter struct {
	// contains filtered or unexported fields
}

func NewAdapter ¶ added in v0.0.3

func NewAdapter(registryName string, client ClientAPI) *Adapter

func (*Adapter) Get ¶ added in v0.0.3

func (f *Adapter) Get(ctx context.Context, id string) (string, error)

Get implements registry.Fetcher.

func (*Adapter) GetByDefinition ¶ added in v0.0.3

func (f *Adapter) GetByDefinition(ctx context.Context, schema avro.Schema) (string, error)

GetByDefinition implements registry.Fetcher.

func (*Adapter) List ¶ added in v0.0.3

func (r *Adapter) List(ctx context.Context, namespaces []string) ([]string, error)

func (*Adapter) Persist ¶ added in v0.0.3

func (p *Adapter) Persist(ctx context.Context, schema *avro.RecordSchema, opts ...func(*registry.PersistConfig)) (string, error)

Persist implements registry.Persister.

func (*Adapter) Walk ¶ added in v0.0.3

func (r *Adapter) Walk(ctx context.Context, fn func(id string, number int64, latest bool, schema *avro.RecordSchema) error, opts ...func(*registry.WalkConfig)) (int, error)

Walk implements registry.Walker.

type ClientAPI ¶ added in v0.0.2

type ClientAPI interface {
	CreateSchema(ctx context.Context, params *glue.CreateSchemaInput, optFns ...func(*glue.Options)) (*glue.CreateSchemaOutput, error)
	RegisterSchemaVersion(ctx context.Context, params *glue.RegisterSchemaVersionInput, optFns ...func(*glue.Options)) (*glue.RegisterSchemaVersionOutput, error)
	GetSchemaVersion(ctx context.Context, params *glue.GetSchemaVersionInput, optFns ...func(*glue.Options)) (*glue.GetSchemaVersionOutput, error)
	GetSchemaByDefinition(ctx context.Context, params *glue.GetSchemaByDefinitionInput, optFns ...func(*glue.Options)) (*glue.GetSchemaByDefinitionOutput, error)
	ListSchemas(ctx context.Context, params *glue.ListSchemasInput, optFns ...func(*glue.Options)) (*glue.ListSchemasOutput, error)
	ListSchemaVersions(ctx context.Context, params *glue.ListSchemaVersionsInput, optFns ...func(*glue.Options)) (*glue.ListSchemaVersionsOutput, error)
}

func NewClient ¶ added in v0.0.3

func NewClient(cfg aws.Config) ClientAPI

type MockClientAPI ¶ added in v0.0.2

type MockClientAPI struct {
	CreateSchemaFunc          func(ctx context.Context, params *glue.CreateSchemaInput, optFns ...func(*glue.Options)) (*glue.CreateSchemaOutput, error)
	RegisterSchemaVersionFunc func(ctx context.Context, params *glue.RegisterSchemaVersionInput, optFns ...func(*glue.Options)) (*glue.RegisterSchemaVersionOutput, error)
	GetSchemaVersionFunc      func(ctx context.Context, params *glue.GetSchemaVersionInput, optFns ...func(*glue.Options)) (*glue.GetSchemaVersionOutput, error)
	GetSchemaByDefinitionFunc func(ctx context.Context, params *glue.GetSchemaByDefinitionInput, optFns ...func(*glue.Options)) (*glue.GetSchemaByDefinitionOutput, error)
	ListSchemasFunc           func(ctx context.Context, params *glue.ListSchemasInput, optFns ...func(*glue.Options)) (*glue.ListSchemasOutput, error)
	ListSchemaVersionsFunc    func(ctx context.Context, params *glue.ListSchemaVersionsInput, optFns ...func(*glue.Options)) (*glue.ListSchemaVersionsOutput, error)
}

func (*MockClientAPI) CreateSchema ¶ added in v0.0.2

func (m *MockClientAPI) CreateSchema(ctx context.Context, params *glue.CreateSchemaInput, optFns ...func(*glue.Options)) (*glue.CreateSchemaOutput, error)

func (*MockClientAPI) GetSchemaByDefinition ¶ added in v0.0.2

func (m *MockClientAPI) GetSchemaByDefinition(ctx context.Context, params *glue.GetSchemaByDefinitionInput, optFns ...func(*glue.Options)) (*glue.GetSchemaByDefinitionOutput, error)

func (*MockClientAPI) GetSchemaVersion ¶ added in v0.0.2

func (m *MockClientAPI) GetSchemaVersion(ctx context.Context, params *glue.GetSchemaVersionInput, optFns ...func(*glue.Options)) (*glue.GetSchemaVersionOutput, error)

func (*MockClientAPI) ListSchemaVersions ¶ added in v0.0.3

func (m *MockClientAPI) ListSchemaVersions(ctx context.Context, params *glue.ListSchemaVersionsInput, optFns ...func(*glue.Options)) (*glue.ListSchemaVersionsOutput, error)

func (*MockClientAPI) ListSchemas ¶ added in v0.0.3

func (m *MockClientAPI) ListSchemas(ctx context.Context, params *glue.ListSchemasInput, optFns ...func(*glue.Options)) (*glue.ListSchemasOutput, error)

func (*MockClientAPI) RegisterSchemaVersion ¶ added in v0.0.2

func (m *MockClientAPI) RegisterSchemaVersion(ctx context.Context, params *glue.RegisterSchemaVersionInput, optFns ...func(*glue.Options)) (*glue.RegisterSchemaVersionOutput, error)

type WireFormatter ¶ added in v0.0.3

type WireFormatter struct{}

func NewWireFormatter ¶ added in v0.0.3

func NewWireFormatter() *WireFormatter

func (*WireFormatter) AppendSchemaID ¶ added in v0.0.3

func (*WireFormatter) AppendSchemaID(data []byte, id string) ([]byte, error)

AppendSchemaID implements registry.WireFormatter.

func (*WireFormatter) ExtractSchemaID ¶ added in v0.0.3

func (*WireFormatter) ExtractSchemaID(data []byte) (string, []byte, error)

ExtractSchemaID implements registry.WireFormatter.

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL