dynamodb

Documentation

Index

• type AnswerStore
  • func NewAnswerStore(dynamoDBClient *dynamodb.DynamoDB, tableName string) *AnswerStore
  • func (r *AnswerStore) Create(ctx context.Context, answer domain.Answer) domain.Error
  • func (r *AnswerStore) CreateTable(ctx context.Context) domain.Error
  • func (r *AnswerStore) Delete(ctx context.Context, answer domain.Answer) domain.Error
  • func (r *AnswerStore) FetchAll(ctx context.Context) ([]domain.Answer, domain.Error)
  • func (r *AnswerStore) FindByID(ctx context.Context, id domain.AnswerID) (answer domain.Answer, version int, derr domain.Error)
  • func (r *AnswerStore) Update(ctx context.Context, answer domain.Answer, version int) domain.Error
• type AnswererStore
  • func NewAnswererStore(dynamoDBClient *dynamodb.DynamoDB, tableName string) *AnswererStore
  • func (r *AnswererStore) Create(ctx context.Context, answerer domain.Answerer) domain.Error
  • func (r *AnswererStore) CreateTable(ctx context.Context) domain.Error
  • func (r *AnswererStore) Delete(ctx context.Context, answerer domain.Answerer) domain.Error
  • func (r *AnswererStore) FetchAll(ctx context.Context) ([]domain.Answerer, domain.Error)
  • func (r *AnswererStore) FindByID(ctx context.Context, id domain.AnswererID) (answerer domain.Answerer, version int, derr domain.Error)
  • func (r *AnswererStore) Update(ctx context.Context, answerer domain.Answerer, version int) domain.Error
• type NotificationTargetStore
  • func NewNotificationTargetStore(dynamoDBClient *dynamodb.DynamoDB, tableName string) *NotificationTargetStore
  • func (r *NotificationTargetStore) Create(ctx context.Context, notificationTarget domain.NotificationTarget) domain.Error
  • func (r *NotificationTargetStore) CreateTable(ctx context.Context) domain.Error
  • func (r *NotificationTargetStore) Delete(ctx context.Context, notificationTarget domain.NotificationTarget) domain.Error
  • func (r *NotificationTargetStore) FindByID(ctx context.Context, id domain.NotificationTargetID) (notificationTarget domain.NotificationTarget, version int, derr domain.Error)
  • func (r *NotificationTargetStore) SearchByQuestionnaireID(ctx context.Context, questionnaireID domain.QuestionnaireID) ([]domain.NotificationTarget, domain.Error)
  • func (r *NotificationTargetStore) SearchByQuestionnaireIDAndAnswererID(ctx context.Context, questionnaireID domain.QuestionnaireID, ...) ([]domain.NotificationTarget, domain.Error)
  • func (r *NotificationTargetStore) Update(ctx context.Context, notificationTarget domain.NotificationTarget, version int) domain.Error
• type ParamStore
  • func NewParamStore(dynamoDBClient *dynamodb.DynamoDB, dynamoDBTable string) ParamStore
  • func (s *ParamStore) CreateTable(ctx context.Context) domain.Error
  • func (s ParamStore) Restore(ctx context.Context, key string, valuePtr interface{}) error
  • func (s ParamStore) Store(ctx context.Context, key string, value interface{}, expiration time.Duration) error
• type QuestionnaireStore
  • func NewQuestionnaireStore(dynamoDBClient *dynamodb.DynamoDB, tableName string) *QuestionnaireStore
  • func (r *QuestionnaireStore) Create(ctx context.Context, questionnaire domain.Questionnaire) domain.Error
  • func (r *QuestionnaireStore) CreateTable(ctx context.Context) domain.Error
  • func (r *QuestionnaireStore) Delete(ctx context.Context, questionnaire domain.Questionnaire) domain.Error
  • func (r *QuestionnaireStore) FetchAll(ctx context.Context) ([]domain.Questionnaire, domain.Error)
  • func (r *QuestionnaireStore) FindByID(ctx context.Context, id domain.QuestionnaireID) (questionnaire domain.Questionnaire, version int, derr domain.Error)
  • func (r *QuestionnaireStore) SearchExecutionNeeded(ctx context.Context) ([]domain.Questionnaire, domain.Error)
  • func (r *QuestionnaireStore) Update(ctx context.Context, questionnaire domain.Questionnaire, version int) domain.Error

Types

type AnswerStore

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

func NewAnswerStore

func NewAnswerStore(dynamoDBClient *dynamodb.DynamoDB, tableName string) *AnswerStore

func (*AnswerStore) Create

func (r *AnswerStore) Create(ctx context.Context, answer domain.Answer) domain.Error

func (*AnswerStore) CreateTable

func (r *AnswerStore) CreateTable(ctx context.Context) domain.Error

func (*AnswerStore) Delete

func (r *AnswerStore) Delete(ctx context.Context, answer domain.Answer) domain.Error

func (*AnswerStore) FetchAll

func (r *AnswerStore) FetchAll(ctx context.Context) ([]domain.Answer, domain.Error)

func (*AnswerStore) FindByID

func (r *AnswerStore) FindByID(ctx context.Context, id domain.AnswerID) (answer domain.Answer, version int, derr domain.Error)

func (*AnswerStore) Update

func (r *AnswerStore) Update(ctx context.Context, answer domain.Answer, version int) domain.Error

type AnswererStore

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

func NewAnswererStore

func NewAnswererStore(dynamoDBClient *dynamodb.DynamoDB, tableName string) *AnswererStore

func (*AnswererStore) Create

func (r *AnswererStore) Create(ctx context.Context, answerer domain.Answerer) domain.Error

func (*AnswererStore) CreateTable

func (r *AnswererStore) CreateTable(ctx context.Context) domain.Error

func (*AnswererStore) Delete

func (r *AnswererStore) Delete(ctx context.Context, answerer domain.Answerer) domain.Error

func (*AnswererStore) FetchAll

func (r *AnswererStore) FetchAll(ctx context.Context) ([]domain.Answerer, domain.Error)

func (*AnswererStore) FindByID

func (r *AnswererStore) FindByID(ctx context.Context, id domain.AnswererID) (answerer domain.Answerer, version int, derr domain.Error)

func (*AnswererStore) Update

func (r *AnswererStore) Update(ctx context.Context, answerer domain.Answerer, version int) domain.Error

type NotificationTargetStore

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

func NewNotificationTargetStore

func NewNotificationTargetStore(dynamoDBClient *dynamodb.DynamoDB, tableName string) *NotificationTargetStore

func (*NotificationTargetStore) Create

func (r *NotificationTargetStore) Create(ctx context.Context, notificationTarget domain.NotificationTarget) domain.Error

func (*NotificationTargetStore) CreateTable

func (r *NotificationTargetStore) CreateTable(ctx context.Context) domain.Error

func (*NotificationTargetStore) Delete

func (r *NotificationTargetStore) Delete(ctx context.Context, notificationTarget domain.NotificationTarget) domain.Error

func (*NotificationTargetStore) FindByID

func (r *NotificationTargetStore) FindByID(ctx context.Context, id domain.NotificationTargetID) (notificationTarget domain.NotificationTarget, version int, derr domain.Error)

func (*NotificationTargetStore) SearchByQuestionnaireID

func (r *NotificationTargetStore) SearchByQuestionnaireID(ctx context.Context, questionnaireID domain.QuestionnaireID) ([]domain.NotificationTarget, domain.Error)

func (*NotificationTargetStore) SearchByQuestionnaireIDAndAnswererID

func (r *NotificationTargetStore) SearchByQuestionnaireIDAndAnswererID(ctx context.Context, questionnaireID domain.QuestionnaireID, answererID domain.AnswererID) ([]domain.NotificationTarget, domain.Error)

func (*NotificationTargetStore) Update

func (r *NotificationTargetStore) Update(ctx context.Context, notificationTarget domain.NotificationTarget, version int) domain.Error

type ParamStore

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

func NewParamStore

func NewParamStore(
	dynamoDBClient *dynamodb.DynamoDB,
	dynamoDBTable string,
) ParamStore

func (*ParamStore) CreateTable

func (s *ParamStore) CreateTable(ctx context.Context) domain.Error

func (ParamStore) Restore

func (s ParamStore) Restore(ctx context.Context, key string, valuePtr interface{}) error

func (ParamStore) Store

func (s ParamStore) Store(ctx context.Context, key string, value interface{}, expiration time.Duration) error

type QuestionnaireStore

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

func NewQuestionnaireStore

func NewQuestionnaireStore(dynamoDBClient *dynamodb.DynamoDB, tableName string) *QuestionnaireStore

func (*QuestionnaireStore) Create

func (r *QuestionnaireStore) Create(ctx context.Context, questionnaire domain.Questionnaire) domain.Error

func (*QuestionnaireStore) CreateTable

func (r *QuestionnaireStore) CreateTable(ctx context.Context) domain.Error

func (*QuestionnaireStore) Delete

func (r *QuestionnaireStore) Delete(ctx context.Context, questionnaire domain.Questionnaire) domain.Error

func (*QuestionnaireStore) FetchAll

func (r *QuestionnaireStore) FetchAll(ctx context.Context) ([]domain.Questionnaire, domain.Error)

func (*QuestionnaireStore) FindByID

func (r *QuestionnaireStore) FindByID(ctx context.Context, id domain.QuestionnaireID) (questionnaire domain.Questionnaire, version int, derr domain.Error)

func (*QuestionnaireStore) SearchExecutionNeeded

func (r *QuestionnaireStore) SearchExecutionNeeded(ctx context.Context) ([]domain.Questionnaire, domain.Error)

func (*QuestionnaireStore) Update

func (r *QuestionnaireStore) Update(ctx context.Context, questionnaire domain.Questionnaire, version int) domain.Error