tables

Documentation

Index

• type ConfigProvider
• type Service
  • func NewService(provider TableProvider, roProvider ConfigProvider) *Service
  • func (s *Service) Delete(ctx context.Context, tableInfo *models.TableInfo, items []models.Item) error
  • func (s *Service) Describe(ctx context.Context, table string) (*models.TableInfo, error)
  • func (s *Service) Filter(resultSet *models.ResultSet, filter string) *models.ResultSet
  • func (s *Service) ListTables(ctx context.Context) ([]string, error)
  • func (s *Service) NextPage(ctx context.Context, resultSet *models.ResultSet) (*models.ResultSet, error)
  • func (s *Service) Put(ctx context.Context, tableInfo *models.TableInfo, item models.Item) error
  • func (s *Service) PutItemAt(ctx context.Context, resultSet *models.ResultSet, index int) error
  • func (s *Service) PutSelectedItems(ctx context.Context, resultSet *models.ResultSet, ...) error
  • func (s *Service) Scan(ctx context.Context, tableInfo *models.TableInfo) (*models.ResultSet, error)
  • func (s *Service) ScanOrQuery(ctx context.Context, tableInfo *models.TableInfo, expr models.Queryable, ...) (*models.ResultSet, error)
• type TableProvider

Types

type ConfigProvider

type ConfigProvider interface {
	IsReadOnly() (bool, error)
	DefaultLimit() int
}

type Service

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

func NewService

func NewService(provider TableProvider, roProvider ConfigProvider) *Service

func (*Service) Delete

func (s *Service) Delete(ctx context.Context, tableInfo *models.TableInfo, items []models.Item) error

func (*Service) Describe

func (s *Service) Describe(ctx context.Context, table string) (*models.TableInfo, error)

func (*Service) Filter

func (s *Service) Filter(resultSet *models.ResultSet, filter string) *models.ResultSet

TODO: move into a new service

func (*Service) ListTables

func (s *Service) ListTables(ctx context.Context) ([]string, error)

func (*Service) NextPage

func (s *Service) NextPage(ctx context.Context, resultSet *models.ResultSet) (*models.ResultSet, error)

func (*Service) Put

func (s *Service) Put(ctx context.Context, tableInfo *models.TableInfo, item models.Item) error

func (*Service) PutItemAt

func (s *Service) PutItemAt(ctx context.Context, resultSet *models.ResultSet, index int) error

func (*Service) PutSelectedItems

func (s *Service) PutSelectedItems(ctx context.Context, resultSet *models.ResultSet, markedItems []models.ItemIndex) error

func (*Service) Scan

func (s *Service) Scan(ctx context.Context, tableInfo *models.TableInfo) (*models.ResultSet, error)

func (*Service) ScanOrQuery

func (s *Service) ScanOrQuery(ctx context.Context, tableInfo *models.TableInfo, expr models.Queryable, exclusiveStartKey map[string]types.AttributeValue) (*models.ResultSet, error)

type TableProvider

type TableProvider interface {
	ListTables(ctx context.Context) ([]string, error)
	DescribeTable(ctx context.Context, tableName string) (*models.TableInfo, error)
	DeleteItem(ctx context.Context, tableName string, key map[string]types.AttributeValue) error
	PutItem(ctx context.Context, name string, item models.Item) error
	PutItems(ctx context.Context, name string, items []models.Item) error

	QueryItems(
		ctx context.Context,
		tableName string,
		indexName string,
		filterExpr *expression.Expression,
		exclusiveStartKey map[string]types.AttributeValue,
		maxItems int,
	) (items []models.Item, lastEvaluatedKey map[string]types.AttributeValue, err error)
	ScanItems(
		ctx context.Context,
		tableName string,
		filterExpr *expression.Expression,
		exclusiveStartKey map[string]types.AttributeValue,
		maxItems int,
	) (item []models.Item, lastEvaluatedKey map[string]types.AttributeValue, err error)
}