notificationchannel

Documentation

Index

• type Channel
• type Store
  • func NewStore(ctx context.Context, db *sql.DB, reg *nfydest.Registry) (*Store, error)
  • func (s *Store) DeleteManyTx(ctx context.Context, tx *sql.Tx, ids []string) error
  • func (s *Store) FindDestByID(ctx context.Context, tx gadb.DBTX, id uuid.UUID) (gadb.DestV1, error)
  • func (s *Store) FindMany(ctx context.Context, ids []string) ([]Channel, error)
  • func (s *Store) FindOne(ctx context.Context, id uuid.UUID) (*Channel, error)
  • func (s *Store) LookupDestID(ctx context.Context, tx *sql.Tx, d gadb.DestV1) (uuid.UUID, error)
  • func (s *Store) MapDestToID(ctx context.Context, tx gadb.DBTX, d gadb.DestV1) (uuid.UUID, error)

Types

type Channel

type Channel struct {
	ID   uuid.UUID
	Name string
	Dest gadb.DestV1
}

type Store

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

func NewStore

func NewStore(ctx context.Context, db *sql.DB, reg *nfydest.Registry) (*Store, error)

func (*Store) DeleteManyTx

func (s *Store) DeleteManyTx(ctx context.Context, tx *sql.Tx, ids []string) error

func (*Store) FindDestByID

func (s *Store) FindDestByID(ctx context.Context, tx gadb.DBTX, id uuid.UUID) (gadb.DestV1, error)

func (*Store) FindMany

func (s *Store) FindMany(ctx context.Context, ids []string) ([]Channel, error)

func (*Store) FindOne

func (s *Store) FindOne(ctx context.Context, id uuid.UUID) (*Channel, error)

func (*Store) LookupDestID

func (s *Store) LookupDestID(ctx context.Context, tx *sql.Tx, d gadb.DestV1) (uuid.UUID, error)

func (*Store) MapDestToID

func (s *Store) MapDestToID(ctx context.Context, tx gadb.DBTX, d gadb.DestV1) (uuid.UUID, error)