dynamodb

Documentation

Index

• type Config
• type DeleteDynamodb
  • func NewDeleteDynamodb(adapter *DynamoAdapter) *DeleteDynamodb
  • func (d *DeleteDynamodb) Condition(name string, value any) adapters.Delete
  • func (d *DeleteDynamodb) Exec(ctx context.Context) error
  • func (d *DeleteDynamodb) Model(model any) adapters.Delete
• type DynamoAdapter
  • func NewDynamoAdapter(config *Config) (*DynamoAdapter, error)
  • func (d *DynamoAdapter) GetInstance() any
  • func (d *DynamoAdapter) NewDelete() adapters.Delete
  • func (d *DynamoAdapter) NewFind() adapters.Find
  • func (d *DynamoAdapter) NewInsert() adapters.Insert
  • func (d *DynamoAdapter) NewSelect() adapters.Select
  • func (d *DynamoAdapter) NewUpdate() adapters.Update
  • func (d *DynamoAdapter) TableName(model any) string
• type FindDynamodb
  • func NewFindDynamodb(adapter *DynamoAdapter) *FindDynamodb
  • func (f *FindDynamodb) Condition(name string, value any) adapters.Find
  • func (f *FindDynamodb) Exec(ctx context.Context) error
  • func (f *FindDynamodb) Model(model any) adapters.Find
• type Insert
  • func NewInsert(adapter *DynamoAdapter) *Insert
  • func (i *Insert) Exec(ctx context.Context) (*adapters.InsertResult, error)
  • func (i *Insert) Model(model any) adapters.Insert
• type Select
  • func NewSelect(adapter *DynamoAdapter) *Select
  • func (s *Select) Condition(name string, value any) adapters.Select
  • func (s *Select) Count(ctx context.Context) (int64, error)
  • func (s *Select) Exec(ctx context.Context) error
  • func (s *Select) GreaterThan(name string, value any) adapters.Select
  • func (s *Select) GreaterThanEqual(name string, value any) adapters.Select
  • func (s *Select) In(name string, value any) adapters.Select
  • func (s *Select) LessThan(name string, value any) adapters.Select
  • func (s *Select) LessThanEqual(name string, value any) adapters.Select
  • func (s *Select) Model(model any) adapters.Select
  • func (s *Select) NotEqual(name string, value any) adapters.Select
  • func (s *Select) OrderBy(name string, order string) adapters.Select
• type UpdateDynamodb
  • func NewUpdateDynamodb(adapter *DynamoAdapter) *UpdateDynamodb
  • func (u *UpdateDynamodb) Condition(name string, value any) adapters.Update
  • func (u *UpdateDynamodb) Exec(ctx context.Context) error
  • func (u *UpdateDynamodb) Model(model any) adapters.Update
  • func (u *UpdateDynamodb) Set(name string, value any) adapters.Update

Types

type Config

type Config struct {
	AwsRegion   string `json:"awsRegion"`
	TablePrefix string `json:"tablePrefix"`
}

type DeleteDynamodb

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

func NewDeleteDynamodb

func NewDeleteDynamodb(adapter *DynamoAdapter) *DeleteDynamodb

func (*DeleteDynamodb) Condition

func (d *DeleteDynamodb) Condition(name string, value any) adapters.Delete

func (*DeleteDynamodb) Exec

func (d *DeleteDynamodb) Exec(ctx context.Context) error

func (*DeleteDynamodb) Model

func (d *DeleteDynamodb) Model(model any) adapters.Delete

type DynamoAdapter

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

func NewDynamoAdapter

func NewDynamoAdapter(config *Config) (*DynamoAdapter, error)

func (*DynamoAdapter) GetInstance

func (d *DynamoAdapter) GetInstance() any

func (*DynamoAdapter) NewDelete

func (d *DynamoAdapter) NewDelete() adapters.Delete

func (*DynamoAdapter) NewFind

func (d *DynamoAdapter) NewFind() adapters.Find

func (*DynamoAdapter) NewInsert

func (d *DynamoAdapter) NewInsert() adapters.Insert

func (*DynamoAdapter) NewSelect

func (d *DynamoAdapter) NewSelect() adapters.Select

func (*DynamoAdapter) NewUpdate

func (d *DynamoAdapter) NewUpdate() adapters.Update

func (*DynamoAdapter) TableName

func (d *DynamoAdapter) TableName(model any) string

type FindDynamodb

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

func NewFindDynamodb

func NewFindDynamodb(adapter *DynamoAdapter) *FindDynamodb

func (*FindDynamodb) Condition

func (f *FindDynamodb) Condition(name string, value any) adapters.Find

func (*FindDynamodb) Exec

func (f *FindDynamodb) Exec(ctx context.Context) error

func (*FindDynamodb) Model

func (f *FindDynamodb) Model(model any) adapters.Find

type Insert

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

func NewInsert

func NewInsert(adapter *DynamoAdapter) *Insert

func (*Insert) Exec

func (i *Insert) Exec(ctx context.Context) (*adapters.InsertResult, error)

func (*Insert) Model

func (i *Insert) Model(model any) adapters.Insert

type Select

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

func NewSelect

func NewSelect(adapter *DynamoAdapter) *Select

func (*Select) Condition

func (s *Select) Condition(name string, value any) adapters.Select

func (*Select) Count

func (s *Select) Count(ctx context.Context) (int64, error)

func (*Select) Exec

func (s *Select) Exec(ctx context.Context) error

func (*Select) GreaterThan

func (s *Select) GreaterThan(name string, value any) adapters.Select

func (*Select) GreaterThanEqual

func (s *Select) GreaterThanEqual(name string, value any) adapters.Select

func (*Select) In

func (s *Select) In(name string, value any) adapters.Select

func (*Select) LessThan

func (s *Select) LessThan(name string, value any) adapters.Select

func (*Select) LessThanEqual

func (s *Select) LessThanEqual(name string, value any) adapters.Select

func (*Select) Model

func (s *Select) Model(model any) adapters.Select

func (*Select) NotEqual

func (s *Select) NotEqual(name string, value any) adapters.Select

func (*Select) OrderBy

func (s *Select) OrderBy(name string, order string) adapters.Select

type UpdateDynamodb

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

func NewUpdateDynamodb

func NewUpdateDynamodb(adapter *DynamoAdapter) *UpdateDynamodb

func (*UpdateDynamodb) Condition

func (u *UpdateDynamodb) Condition(name string, value any) adapters.Update

func (*UpdateDynamodb) Exec

func (u *UpdateDynamodb) Exec(ctx context.Context) error

func (*UpdateDynamodb) Model

func (u *UpdateDynamodb) Model(model any) adapters.Update

func (*UpdateDynamodb) Set

func (u *UpdateDynamodb) Set(name string, value any) adapters.Update