dynamo

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

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

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

func NewDynamoDbFragmentStorer

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

func (*DynamoDbFragmentStorer) DeleteFragment

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

func (*DynamoDbFragmentStorer) DeleteFragments

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

func (*DynamoDbFragmentStorer) GetAllFragments

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

func (*DynamoDbFragmentStorer) GetAllTenantFragments

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

func (*DynamoDbFragmentStorer) GetFragment

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

func (*DynamoDbFragmentStorer) SetFragment

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

func (*DynamoDbFragmentStorer) SetFragments

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

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