dynamo

package

v1.1.2 Latest Latest Go to latest Published: Sep 5, 2023 License: Apache-2.0 Imports: 14 Imported by: 0

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/xmidt-org/ears

Links

Open Source Insights

Documentation ¶

Index ¶

type DynamoDbDeleteItemError
- func (e *DynamoDbDeleteItemError) Error() string
- func (e *DynamoDbDeleteItemError) Unwrap() error
type DynamoDbFragmentStorer
- func NewDynamoDbFragmentStorer(config config.Config) (*DynamoDbFragmentStorer, error)
- func (d *DynamoDbFragmentStorer) DeleteFragment(ctx context.Context, tid tenant.Id, id string) error
- func (d *DynamoDbFragmentStorer) DeleteFragments(ctx context.Context, tid tenant.Id, ids []string) error
- func (d *DynamoDbFragmentStorer) GetAllFragments(ctx context.Context) ([]route.PluginConfig, error)
- func (d *DynamoDbFragmentStorer) GetAllTenantFragments(ctx context.Context, tid tenant.Id) ([]route.PluginConfig, error)
- func (d *DynamoDbFragmentStorer) GetFragment(ctx context.Context, tid tenant.Id, id string) (route.PluginConfig, error)
- func (d *DynamoDbFragmentStorer) SetFragment(ctx context.Context, tid tenant.Id, f route.PluginConfig) error
- func (d *DynamoDbFragmentStorer) SetFragments(ctx context.Context, tid tenant.Id, fragments []route.PluginConfig) error
type DynamoDbGetItemError
- func (e *DynamoDbGetItemError) Error() string
- func (e *DynamoDbGetItemError) Unwrap() error
type DynamoDbMarshalError
- func (e *DynamoDbMarshalError) Error() string
- func (e *DynamoDbMarshalError) Unwrap() error
type DynamoDbNewSessionError
- func (e *DynamoDbNewSessionError) Error() string
- func (e *DynamoDbNewSessionError) Unwrap() error
type DynamoDbPutItemError
- func (e *DynamoDbPutItemError) Error() string
- func (e *DynamoDbPutItemError) Unwrap() error
type DynamoDbStorer
- func NewDynamoDbStorer(config config.Config) (*DynamoDbStorer, error)
- func (d *DynamoDbStorer) DeleteRoute(ctx context.Context, tid tenant.Id, id string) error
- func (d *DynamoDbStorer) DeleteRoutes(ctx context.Context, tid tenant.Id, ids []string) error
- func (d *DynamoDbStorer) GetAllRoutes(ctx context.Context) ([]route.Config, error)
- func (d *DynamoDbStorer) GetAllTenantRoutes(ctx context.Context, tid tenant.Id) ([]route.Config, error)
- func (d *DynamoDbStorer) GetRoute(ctx context.Context, tid tenant.Id, id string) (route.Config, error)
- func (d *DynamoDbStorer) SetRoute(ctx context.Context, r route.Config) error
- func (d *DynamoDbStorer) SetRoutes(ctx context.Context, routes []route.Config) error
type MissingConfigError
- func (e *MissingConfigError) Error() string
type TenantStorer
- func NewTenantStorer(config config.Config) (*TenantStorer, error)
- func (s *TenantStorer) DeleteConfig(ctx context.Context, id tenant.Id) error
- func (s *TenantStorer) GetAllConfigs(ctx context.Context) ([]tenant.Config, error)
- func (s *TenantStorer) GetConfig(ctx context.Context, id tenant.Id) (*tenant.Config, error)
- func (s *TenantStorer) SetConfig(ctx context.Context, config tenant.Config) error

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type DynamoDbDeleteItemError ¶

type DynamoDbDeleteItemError struct {
	Source error
}

func (*DynamoDbDeleteItemError) Error ¶

func (e *DynamoDbDeleteItemError) Error() string

func (*DynamoDbDeleteItemError) Unwrap ¶

func (e *DynamoDbDeleteItemError) Unwrap() error

type DynamoDbFragmentStorer ¶ added in v0.9.0

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

func NewDynamoDbFragmentStorer ¶ added in v0.9.0

func NewDynamoDbFragmentStorer(config config.Config) (*DynamoDbFragmentStorer, error)

func (*DynamoDbFragmentStorer) DeleteFragment ¶ added in v0.9.0

func (d *DynamoDbFragmentStorer) DeleteFragment(ctx context.Context, tid tenant.Id, id string) error

func (*DynamoDbFragmentStorer) DeleteFragments ¶ added in v0.9.0

func (d *DynamoDbFragmentStorer) DeleteFragments(ctx context.Context, tid tenant.Id, ids []string) error

func (*DynamoDbFragmentStorer) GetAllFragments ¶ added in v0.9.0

func (d *DynamoDbFragmentStorer) GetAllFragments(ctx context.Context) ([]route.PluginConfig, error)

func (*DynamoDbFragmentStorer) GetAllTenantFragments ¶ added in v0.9.0

func (d *DynamoDbFragmentStorer) GetAllTenantFragments(ctx context.Context, tid tenant.Id) ([]route.PluginConfig, error)

func (*DynamoDbFragmentStorer) GetFragment ¶ added in v0.9.0

func (d *DynamoDbFragmentStorer) GetFragment(ctx context.Context, tid tenant.Id, id string) (route.PluginConfig, error)

func (*DynamoDbFragmentStorer) SetFragment ¶ added in v0.9.0

func (d *DynamoDbFragmentStorer) SetFragment(ctx context.Context, tid tenant.Id, f route.PluginConfig) error

func (*DynamoDbFragmentStorer) SetFragments ¶ added in v0.9.0

func (d *DynamoDbFragmentStorer) SetFragments(ctx context.Context, tid tenant.Id, fragments []route.PluginConfig) error

type DynamoDbGetItemError ¶

type DynamoDbGetItemError struct {
	Source error
}

func (*DynamoDbGetItemError) Error ¶

func (e *DynamoDbGetItemError) Error() string

func (*DynamoDbGetItemError) Unwrap ¶

func (e *DynamoDbGetItemError) Unwrap() error

type DynamoDbMarshalError ¶

type DynamoDbMarshalError struct {
	Source error
}

func (*DynamoDbMarshalError) Error ¶

func (e *DynamoDbMarshalError) Error() string

func (*DynamoDbMarshalError) Unwrap ¶

func (e *DynamoDbMarshalError) Unwrap() error

type DynamoDbNewSessionError ¶

type DynamoDbNewSessionError struct {
	Source error
}

func (*DynamoDbNewSessionError) Error ¶

func (e *DynamoDbNewSessionError) Error() string

func (*DynamoDbNewSessionError) Unwrap ¶

func (e *DynamoDbNewSessionError) Unwrap() error

type DynamoDbPutItemError ¶

type DynamoDbPutItemError struct {
	Source error
}

func (*DynamoDbPutItemError) Error ¶

func (e *DynamoDbPutItemError) Error() string

func (*DynamoDbPutItemError) Unwrap ¶

func (e *DynamoDbPutItemError) Unwrap() error

type DynamoDbStorer ¶

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

func NewDynamoDbStorer ¶

func NewDynamoDbStorer(config config.Config) (*DynamoDbStorer, error)

func (*DynamoDbStorer) DeleteRoute ¶

func (d *DynamoDbStorer) DeleteRoute(ctx context.Context, tid tenant.Id, id string) error

func (*DynamoDbStorer) DeleteRoutes ¶

func (d *DynamoDbStorer) DeleteRoutes(ctx context.Context, tid tenant.Id, ids []string) error

func (*DynamoDbStorer) GetAllRoutes ¶

func (d *DynamoDbStorer) GetAllRoutes(ctx context.Context) ([]route.Config, error)

func (*DynamoDbStorer) GetAllTenantRoutes ¶

func (d *DynamoDbStorer) GetAllTenantRoutes(ctx context.Context, tid tenant.Id) ([]route.Config, error)

func (*DynamoDbStorer) GetRoute ¶

func (d *DynamoDbStorer) GetRoute(ctx context.Context, tid tenant.Id, id string) (route.Config, error)

func (*DynamoDbStorer) SetRoute ¶

func (d *DynamoDbStorer) SetRoute(ctx context.Context, r route.Config) error

func (*DynamoDbStorer) SetRoutes ¶

func (d *DynamoDbStorer) SetRoutes(ctx context.Context, routes []route.Config) error

TODO: make this more efficient

type MissingConfigError ¶

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

func (*MissingConfigError) Error ¶

func (e *MissingConfigError) Error() string

type TenantStorer ¶

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

func NewTenantStorer ¶

func NewTenantStorer(config config.Config) (*TenantStorer, error)

func (*TenantStorer) DeleteConfig ¶

func (s *TenantStorer) DeleteConfig(ctx context.Context, id tenant.Id) error

func (*TenantStorer) GetAllConfigs ¶ added in v0.4.0

func (s *TenantStorer) GetAllConfigs(ctx context.Context) ([]tenant.Config, error)

func (*TenantStorer) GetConfig ¶

func (s *TenantStorer) GetConfig(ctx context.Context, id tenant.Id) (*tenant.Config, error)

func (*TenantStorer) SetConfig ¶

func (s *TenantStorer) SetConfig(ctx context.Context, config tenant.Config) error

Source Files ¶

View all Source files

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