Documentation
¶
Index ¶
- type ConfigProvider
- type 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ConfigProvider ¶
type Service ¶
type Service struct {
// contains filtered or unexported fields
}
func NewService ¶
func NewService(provider TableProvider, roProvider ConfigProvider) *Service
func (*Service) PutSelectedItems ¶
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)
}
Click to show internal directories.
Click to hide internal directories.