repositories

Documentation

Index

• type DynamoDbNotificationHistoryRepository
  • func (s *DynamoDbNotificationHistoryRepository) Exists(subscriptionId string, postId string) (bool, error)
  • func (s *DynamoDbNotificationHistoryRepository) TrackNotification(subscriptionId string, postId string, notifiedAt time.Time) error
• type DynamoDbSubscriptionRepository
  • func (r *DynamoDbSubscriptionRepository) GetSubscriptions() ([]*models.Subscription, error)
• type NotificationHistoryRepository
  • func NewNotificationHistoryRepository(config *configuration.AppConfig) NotificationHistoryRepository
• type SubscriptionRepository
  • func NewSubscriptionRepository(config *configuration.AppConfig) SubscriptionRepository

Types

type DynamoDbNotificationHistoryRepository

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

func (*DynamoDbNotificationHistoryRepository) Exists

func (s *DynamoDbNotificationHistoryRepository) Exists(subscriptionId string, postId string) (bool, error)

func (*DynamoDbNotificationHistoryRepository) TrackNotification

func (s *DynamoDbNotificationHistoryRepository) TrackNotification(subscriptionId string, postId string, notifiedAt time.Time) error

type DynamoDbSubscriptionRepository

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

func (*DynamoDbSubscriptionRepository) GetSubscriptions

func (r *DynamoDbSubscriptionRepository) GetSubscriptions() ([]*models.Subscription, error)

type NotificationHistoryRepository

type NotificationHistoryRepository interface {
	Exists(subscriptionId string, postId string) (bool, error)
	TrackNotification(subscriptionId string, postId string, notifiedAt time.Time) error
}

func NewNotificationHistoryRepository

func NewNotificationHistoryRepository(config *configuration.AppConfig) NotificationHistoryRepository

type SubscriptionRepository

type SubscriptionRepository interface {
	GetSubscriptions() ([]*models.Subscription, error)
}

func NewSubscriptionRepository

func NewSubscriptionRepository(config *configuration.AppConfig) SubscriptionRepository