db

package
v0.0.0-...-13d5e30 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 8, 2026 License: MIT Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AddTagToContactParams 

type AddTagToContactParams struct {
	ContactID uuid.UUID
	TagID     uuid.UUID
	UserID    uuid.UUID
}

type AddTagToThreadParams 

type AddTagToThreadParams struct {
	ThreadID uuid.UUID
	TagID    uuid.UUID
	UserID   uuid.UUID
}

type ArchiveContactParams 

type ArchiveContactParams struct {
	ID     uuid.UUID
	UserID uuid.UUID
}

type ArchiveThreadParams 

type ArchiveThreadParams struct {
	ID     uuid.UUID
	UserID uuid.UUID
}

type Campaign 

type Campaign struct {
	ID         uuid.UUID
	Name       string
	Purpose    pgtype.Text
	StartDate  pgtype.Date
	PacingRule pgtype.Text
	CreatedAt  pgtype.Timestamptz
}

type CheckIn 

type CheckIn struct {
	ID         uuid.UUID
	ThreadID   uuid.UUID
	Date       pgtype.Date
	Deadline   pgtype.Date
	Status     CheckinStatus
	ResolvedAt pgtype.Timestamptz
	CreatedAt  pgtype.Timestamptz
}

type CheckinStatus 

type CheckinStatus string
const (
	CheckinStatusPending   CheckinStatus = "pending"
	CheckinStatusCompleted CheckinStatus = "completed"
	CheckinStatusSkipped   CheckinStatus = "skipped"
	CheckinStatusMissed    CheckinStatus = "missed"
)

func (*CheckinStatus) Scan 

func (e *CheckinStatus) Scan(src interface{}) error

type Contact 

type Contact struct {
	ID        uuid.UUID
	Name      string
	Role      pgtype.Text
	Status    ContactStatus
	CreatedAt pgtype.Timestamptz
	UpdatedAt pgtype.Timestamptz
	UserID    uuid.UUID
}

type ContactMethod 

type ContactMethod struct {
	ID        uuid.UUID
	ContactID uuid.UUID
	Type      string
	Value     string
	CreatedAt pgtype.Timestamptz
}

type ContactStatus 

type ContactStatus string
const (
	ContactStatusActive   ContactStatus = "active"
	ContactStatusArchived ContactStatus = "archived"
)

func (*ContactStatus) Scan 

func (e *ContactStatus) Scan(src interface{}) error

type ContactTag 

type ContactTag struct {
	ContactID uuid.UUID
	TagID     uuid.UUID
}

type CreateCheckInParams 

type CreateCheckInParams struct {
	ThreadID uuid.UUID
	Date     pgtype.Date
	Deadline pgtype.Date
}

type CreateContactMethodParams 

type CreateContactMethodParams struct {
	ContactID uuid.UUID
	Type      string
	Value     string
}

type CreateContactParams 

type CreateContactParams struct {
	Name   string
	Role   pgtype.Text
	UserID uuid.UUID
}

type CreateTagParams 

type CreateTagParams struct {
	Name   string
	UserID uuid.UUID
}

type CreateThreadParams 

type CreateThreadParams struct {
	ContactID           uuid.UUID
	Label               string
	CadenceIntervalDays *int32
}

type DBTX 

type DBTX interface {
	Exec(context.Context, string, ...interface{}) (pgconn.CommandTag, error)
	Query(context.Context, string, ...interface{}) (pgx.Rows, error)
	QueryRow(context.Context, string, ...interface{}) pgx.Row
}

type DeleteContactMethodParams 

type DeleteContactMethodParams struct {
	ID     uuid.UUID
	UserID uuid.UUID
}

type GetContactByIDParams 

type GetContactByIDParams struct {
	ID     uuid.UUID
	UserID uuid.UUID
}

type GetCurrentPendingCheckInParams 

type GetCurrentPendingCheckInParams struct {
	ThreadID uuid.UUID
	UserID   uuid.UUID
}

type GetThreadByCheckInIDParams 

type GetThreadByCheckInIDParams struct {
	ID     uuid.UUID
	UserID uuid.UUID
}

type GetThreadByIDParams 

type GetThreadByIDParams struct {
	ID     uuid.UUID
	UserID uuid.UUID
}

type ListContactMethodsByContactParams 

type ListContactMethodsByContactParams struct {
	ContactID uuid.UUID
	UserID    uuid.UUID
}

type ListContactsByNameParams 

type ListContactsByNameParams struct {
	Name   string
	UserID uuid.UUID
}

type ListTagsForContactParams 

type ListTagsForContactParams struct {
	ContactID uuid.UUID
	UserID    uuid.UUID
}

type ListTagsForThreadParams 

type ListTagsForThreadParams struct {
	ThreadID uuid.UUID
	UserID   uuid.UUID
}

type ListThreadsByContactParams 

type ListThreadsByContactParams struct {
	ContactID uuid.UUID
	UserID    uuid.UUID
	Status    NullThreadStatus
	TagID     *uuid.UUID
}

type NullCheckinStatus 

type NullCheckinStatus struct {
	CheckinStatus CheckinStatus
	Valid         bool // Valid is true if CheckinStatus is not NULL
}

func (*NullCheckinStatus) Scan 

func (ns *NullCheckinStatus) Scan(value interface{}) error

Scan implements the Scanner interface.

func (NullCheckinStatus) Value 

func (ns NullCheckinStatus) Value() (driver.Value, error)

Value implements the driver Valuer interface.

type NullContactStatus 

type NullContactStatus struct {
	ContactStatus ContactStatus
	Valid         bool // Valid is true if ContactStatus is not NULL
}

func (*NullContactStatus) Scan 

func (ns *NullContactStatus) Scan(value interface{}) error

Scan implements the Scanner interface.

func (NullContactStatus) Value 

func (ns NullContactStatus) Value() (driver.Value, error)

Value implements the driver Valuer interface.

type NullThreadStatus 

type NullThreadStatus struct {
	ThreadStatus ThreadStatus
	Valid        bool // Valid is true if ThreadStatus is not NULL
}

func (*NullThreadStatus) Scan 

func (ns *NullThreadStatus) Scan(value interface{}) error

Scan implements the Scanner interface.

func (NullThreadStatus) Value 

func (ns NullThreadStatus) Value() (driver.Value, error)

Value implements the driver Valuer interface.

type Querier 

type Querier interface {
	AddTagToContact(ctx context.Context, arg AddTagToContactParams) error
	AddTagToThread(ctx context.Context, arg AddTagToThreadParams) error
	ArchiveContact(ctx context.Context, arg ArchiveContactParams) error
	ArchiveThread(ctx context.Context, arg ArchiveThreadParams) error
	CreateCheckIn(ctx context.Context, arg CreateCheckInParams) (CheckIn, error)
	CreateContact(ctx context.Context, arg CreateContactParams) (Contact, error)
	CreateContactMethod(ctx context.Context, arg CreateContactMethodParams) (ContactMethod, error)
	CreateTag(ctx context.Context, arg CreateTagParams) (Tag, error)
	CreateThread(ctx context.Context, arg CreateThreadParams) (Thread, error)
	DeleteContactMethod(ctx context.Context, arg DeleteContactMethodParams) error
	GetContactByID(ctx context.Context, arg GetContactByIDParams) (Contact, error)
	GetCurrentPendingCheckIn(ctx context.Context, arg GetCurrentPendingCheckInParams) (CheckIn, error)
	GetThreadByCheckInID(ctx context.Context, arg GetThreadByCheckInIDParams) (Thread, error)
	GetThreadByID(ctx context.Context, arg GetThreadByIDParams) (Thread, error)
	ListContactMethodsByContact(ctx context.Context, arg ListContactMethodsByContactParams) ([]ContactMethod, error)
	ListContacts(ctx context.Context, userID uuid.UUID) ([]Contact, error)
	ListContactsByName(ctx context.Context, arg ListContactsByNameParams) ([]Contact, error)
	ListTags(ctx context.Context, userID uuid.UUID) ([]Tag, error)
	ListTagsForContact(ctx context.Context, arg ListTagsForContactParams) ([]Tag, error)
	ListTagsForThread(ctx context.Context, arg ListTagsForThreadParams) ([]Tag, error)
	ListThreadsByContact(ctx context.Context, arg ListThreadsByContactParams) ([]Thread, error)
	RemoveTagFromContact(ctx context.Context, arg RemoveTagFromContactParams) error
	RemoveTagFromThread(ctx context.Context, arg RemoveTagFromThreadParams) error
	RescheduleCheckIn(ctx context.Context, arg RescheduleCheckInParams) (CheckIn, error)
	ResolveCheckIn(ctx context.Context, arg ResolveCheckInParams) (CheckIn, error)
	UpdateContact(ctx context.Context, arg UpdateContactParams) (Contact, error)
}

type Queries 

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

func New 

func New(db DBTX) *Queries

func (*Queries) AddTagToContact 

func (q *Queries) AddTagToContact(ctx context.Context, arg AddTagToContactParams) error

func (*Queries) AddTagToThread 

func (q *Queries) AddTagToThread(ctx context.Context, arg AddTagToThreadParams) error

func (*Queries) ArchiveContact 

func (q *Queries) ArchiveContact(ctx context.Context, arg ArchiveContactParams) error

func (*Queries) ArchiveThread 

func (q *Queries) ArchiveThread(ctx context.Context, arg ArchiveThreadParams) error

func (*Queries) CreateCheckIn 

func (q *Queries) CreateCheckIn(ctx context.Context, arg CreateCheckInParams) (CheckIn, error)

func (*Queries) CreateContact 

func (q *Queries) CreateContact(ctx context.Context, arg CreateContactParams) (Contact, error)

func (*Queries) CreateContactMethod 

func (q *Queries) CreateContactMethod(ctx context.Context, arg CreateContactMethodParams) (ContactMethod, error)

func (*Queries) CreateTag 

func (q *Queries) CreateTag(ctx context.Context, arg CreateTagParams) (Tag, error)

func (*Queries) CreateThread 

func (q *Queries) CreateThread(ctx context.Context, arg CreateThreadParams) (Thread, error)

func (*Queries) DeleteContactMethod 

func (q *Queries) DeleteContactMethod(ctx context.Context, arg DeleteContactMethodParams) error

func (*Queries) GetContactByID 

func (q *Queries) GetContactByID(ctx context.Context, arg GetContactByIDParams) (Contact, error)

func (*Queries) GetCurrentPendingCheckIn 

func (q *Queries) GetCurrentPendingCheckIn(ctx context.Context, arg GetCurrentPendingCheckInParams) (CheckIn, error)

func (*Queries) GetThreadByCheckInID 

func (q *Queries) GetThreadByCheckInID(ctx context.Context, arg GetThreadByCheckInIDParams) (Thread, error)

func (*Queries) GetThreadByID 

func (q *Queries) GetThreadByID(ctx context.Context, arg GetThreadByIDParams) (Thread, error)

func (*Queries) ListContactMethodsByContact 

func (q *Queries) ListContactMethodsByContact(ctx context.Context, arg ListContactMethodsByContactParams) ([]ContactMethod, error)

func (*Queries) ListContacts 

func (q *Queries) ListContacts(ctx context.Context, userID uuid.UUID) ([]Contact, error)

func (*Queries) ListContactsByName 

func (q *Queries) ListContactsByName(ctx context.Context, arg ListContactsByNameParams) ([]Contact, error)

func (*Queries) ListTags 

func (q *Queries) ListTags(ctx context.Context, userID uuid.UUID) ([]Tag, error)

func (*Queries) ListTagsForContact 

func (q *Queries) ListTagsForContact(ctx context.Context, arg ListTagsForContactParams) ([]Tag, error)

func (*Queries) ListTagsForThread 

func (q *Queries) ListTagsForThread(ctx context.Context, arg ListTagsForThreadParams) ([]Tag, error)

func (*Queries) ListThreadsByContact 

func (q *Queries) ListThreadsByContact(ctx context.Context, arg ListThreadsByContactParams) ([]Thread, error)

func (*Queries) RemoveTagFromContact 

func (q *Queries) RemoveTagFromContact(ctx context.Context, arg RemoveTagFromContactParams) error

func (*Queries) RemoveTagFromThread 

func (q *Queries) RemoveTagFromThread(ctx context.Context, arg RemoveTagFromThreadParams) error

func (*Queries) RescheduleCheckIn 

func (q *Queries) RescheduleCheckIn(ctx context.Context, arg RescheduleCheckInParams) (CheckIn, error)

func (*Queries) ResolveCheckIn 

func (q *Queries) ResolveCheckIn(ctx context.Context, arg ResolveCheckInParams) (CheckIn, error)

func (*Queries) UpdateContact 

func (q *Queries) UpdateContact(ctx context.Context, arg UpdateContactParams) (Contact, error)

func (*Queries) WithTx 

func (q *Queries) WithTx(tx pgx.Tx) *Queries

type RemoveTagFromContactParams 

type RemoveTagFromContactParams struct {
	ContactID uuid.UUID
	TagID     uuid.UUID
	UserID    uuid.UUID
}

type RemoveTagFromThreadParams 

type RemoveTagFromThreadParams struct {
	ThreadID uuid.UUID
	TagID    uuid.UUID
	UserID   uuid.UUID
}

type RescheduleCheckInParams 

type RescheduleCheckInParams struct {
	ID       uuid.UUID
	Date     pgtype.Date
	Deadline pgtype.Date
	UserID   uuid.UUID
}

type ResolveCheckInParams 

type ResolveCheckInParams struct {
	ID     uuid.UUID
	Status CheckinStatus
	UserID uuid.UUID
}

type Tag 

type Tag struct {
	ID     uuid.UUID
	Name   string
	UserID uuid.UUID
}

type Thread 

type Thread struct {
	ID                  uuid.UUID
	ContactID           uuid.UUID
	Label               string
	CadenceIntervalDays *int32
	Status              ThreadStatus
	CampaignID          *uuid.UUID
	EmailEnabled        pgtype.Bool
	PushEnabled         pgtype.Bool
	CreatedAt           pgtype.Timestamptz
}

type ThreadStatus 

type ThreadStatus string
const (
	ThreadStatusActive   ThreadStatus = "active"
	ThreadStatusArchived ThreadStatus = "archived"
)

func (*ThreadStatus) Scan 

func (e *ThreadStatus) Scan(src interface{}) error

type ThreadTag 

type ThreadTag struct {
	ThreadID uuid.UUID
	TagID    uuid.UUID
}

type UpdateContactParams 

type UpdateContactParams struct {
	Name   string
	Role   pgtype.Text
	ID     uuid.UUID
	UserID uuid.UUID
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.