db

Documentation

Index

• Variables
• type HealthChecksDynamoDB
  • func NewHealthChecksDynamoDB(table string, cfg aws.Config) *HealthChecksDynamoDB
  • func (db *HealthChecksDynamoDB) AddHealthCheck(ctx context.Context, hc *common.HealthCheck) error
  • func (db *HealthChecksDynamoDB) GetHealthCheck(ctx context.Context, id string) (*common.HealthCheck, error)
  • func (db *HealthChecksDynamoDB) GetHealthChecks(ctx context.Context) (healthChecks []*common.HealthCheck, err error)
  • func (db *HealthChecksDynamoDB) UpdateHealthCheckStatus(ctx context.Context, id string, status, oldStatus string) error
• type HealthChecksMapDB
  • func NewCloudUploadWorkersMapDB() *HealthChecksMapDB
  • func (db *HealthChecksMapDB) AddHealthCheck(ctx context.Context, hc *common.HealthCheck) error
  • func (db *HealthChecksMapDB) Count() int
  • func (db *HealthChecksMapDB) GetHealthCheck(ctx context.Context, id string) (*common.HealthCheck, error)
  • func (db *HealthChecksMapDB) GetHealthChecks(ctx context.Context) ([]*common.HealthCheck, error)
  • func (db *HealthChecksMapDB) UpdateHealthCheckStatus(ctx context.Context, id string, status, oldStatus string) error

Variables

var (
	ErrItemNotFound = errors.New("item not found")
)

Types

type HealthChecksDynamoDB

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

func NewHealthChecksDynamoDB

func NewHealthChecksDynamoDB(table string, cfg aws.Config) *HealthChecksDynamoDB

func (*HealthChecksDynamoDB) AddHealthCheck

func (db *HealthChecksDynamoDB) AddHealthCheck(ctx context.Context, hc *common.HealthCheck) error

func (*HealthChecksDynamoDB) GetHealthCheck

func (db *HealthChecksDynamoDB) GetHealthCheck(ctx context.Context, id string) (*common.HealthCheck, error)

func (*HealthChecksDynamoDB) GetHealthChecks

func (db *HealthChecksDynamoDB) GetHealthChecks(ctx context.Context) (healthChecks []*common.HealthCheck, err error)

func (*HealthChecksDynamoDB) UpdateHealthCheckStatus

func (db *HealthChecksDynamoDB) UpdateHealthCheckStatus(ctx context.Context, id string, status, oldStatus string) error

type HealthChecksMapDB

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

func NewCloudUploadWorkersMapDB

func NewCloudUploadWorkersMapDB() *HealthChecksMapDB

func (*HealthChecksMapDB) AddHealthCheck

func (db *HealthChecksMapDB) AddHealthCheck(ctx context.Context, hc *common.HealthCheck) error

func (*HealthChecksMapDB) Count

func (db *HealthChecksMapDB) Count() int

func (*HealthChecksMapDB) GetHealthCheck

func (db *HealthChecksMapDB) GetHealthCheck(ctx context.Context, id string) (*common.HealthCheck, error)

func (*HealthChecksMapDB) GetHealthChecks

func (db *HealthChecksMapDB) GetHealthChecks(ctx context.Context) ([]*common.HealthCheck, error)

func (*HealthChecksMapDB) UpdateHealthCheckStatus

func (db *HealthChecksMapDB) UpdateHealthCheckStatus(ctx context.Context, id string, status, oldStatus string) error