adapters

Documentation

Index

• func NewFirebaseMessagingConnection(ctx context.Context) (*messaging.Client, error)
• func NewSQLiteConnection(path string) (*sqlx.DB, error)
• type Messaging
  • func (m *Messaging) SendNotification(ctx context.Context, token []string, title string, message string) error
• type SQLiteTokenRepository
  • func NewSQLiteTokenRepository(db *sqlx.DB) *SQLiteTokenRepository
  • func (s SQLiteTokenRepository) DeleteToken(token string) error
  • func (s SQLiteTokenRepository) GetAllToken() (subscriber []string, err error)
  • func (s SQLiteTokenRepository) GetStatisticToken() (*notification.Stats, error)
  • func (s SQLiteTokenRepository) GetToken(value string) (*notification.Token, bool, error)
  • func (s SQLiteTokenRepository) InsertedToken(tokenID string, updatedAt int64) (*notification.Token, error)
  • func (s SQLiteTokenRepository) UpdatedToken(tokenID string, updatedAt int64) (*notification.Token, error)

Functions

func NewFirebaseMessagingConnection

func NewFirebaseMessagingConnection(ctx context.Context) (*messaging.Client, error)

func NewSQLiteConnection

func NewSQLiteConnection(path string) (*sqlx.DB, error)

Types

type Messaging

type Messaging struct {
	MessagingClient *messaging.Client
}

func (*Messaging) SendNotification

func (m *Messaging) SendNotification(ctx context.Context, token []string, title string, message string) error

type SQLiteTokenRepository

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

func NewSQLiteTokenRepository

func NewSQLiteTokenRepository(db *sqlx.DB) *SQLiteTokenRepository

func (SQLiteTokenRepository) DeleteToken

func (s SQLiteTokenRepository) DeleteToken(token string) error

func (SQLiteTokenRepository) GetAllToken

func (s SQLiteTokenRepository) GetAllToken() (subscriber []string, err error)

func (SQLiteTokenRepository) GetStatisticToken

func (s SQLiteTokenRepository) GetStatisticToken() (*notification.Stats, error)

func (SQLiteTokenRepository) GetToken

func (s SQLiteTokenRepository) GetToken(value string) (*notification.Token, bool, error)

func (SQLiteTokenRepository) InsertedToken

func (s SQLiteTokenRepository) InsertedToken(tokenID string, updatedAt int64) (*notification.Token, error)

func (SQLiteTokenRepository) UpdatedToken

func (s SQLiteTokenRepository) UpdatedToken(tokenID string, updatedAt int64) (*notification.Token, error)