event

Documentation

Index

• Constants
• type DataSource
• type Event
• type Repo
  • func NewRepo(db DataSource) *Repo
  • func (s *Repo) Save(ctx context.Context, event Event) error
• type Type

Constants

const (
	Deleted = Type("subscriber-deleted")
	Added   = Type("subscriber-added")
)

Types

type DataSource

type DataSource interface {
	ExecContext(ctx context.Context, query string, args ...any) (sql.Result, error)
}

type Event

type Event struct {
	ID        int       `db:"id"`
	Type      Type      `db:"type"`
	CreatedAt time.Time `db:"created_at"`
	Payload   []byte    `db:"payload"`
}

type Repo

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

func NewRepo

func NewRepo(db DataSource) *Repo

func (*Repo) Save

func (s *Repo) Save(ctx context.Context, event Event) error

type Type

type Type string