postgres

package

Go to main page

Versions in this module

v1

v1.2.0

Oct 15, 2023

v1.1.8

Oct 15, 2023

v1.1.6

Oct 13, 2023

Changes in this version

+ var ErrEndpointExists = errors.New("an endpoint with that name already exists")

+ var ErrJobNotCreated = errors.New("job could not be created")

+ var ErrJobNotDeleted = errors.New("job could not be deleted")

+ var ErrJobNotFound = errors.New("job not found")

+ var ErrJobNotUpdated = errors.New("job could not be updated")

+ var ErrMetaEventNotCreated = errors.New("meta event could not be created")

+ var ErrMetaEventNotUpdated = errors.New("meta event could not be updated")

+ func NewJobRepo(db database.Database) datastore.JobRepository

+ func NewMetaEventRepo(db database.Database) datastore.MetaEventRepository

type EventDeliveryPaginated

+ IdempotencyKey string

+ URLQueryParams string

+ type JobPaginated struct

+ Count int

type Postgres

+ func (p *Postgres) GetHook() *hooks.Hook

type SourceMetadata

+ IdempotencyKeys pq.StringArray

v0

v0.10.0

Apr 23, 2025

v0.9.2

Apr 12, 2023

v0.9.1

Mar 30, 2023

v0.9.0

Mar 28, 2023

Changes in this version

+ var ErrAPIKeyNotCreated = errors.New("api key could not be created")

+ var ErrAPIKeyNotRevoked = errors.New("api key could not be revoked")

+ var ErrAPIKeyNotUpdated = errors.New("api key could not be updated")

+ var ErrDeviceNotCreated = errors.New("device could not be created")

+ var ErrDeviceNotDeleted = errors.New("device could not be deleted")

+ var ErrDeviceNotFound = errors.New("device not found")

+ var ErrDeviceNotUpdated = errors.New("device could not be updated")

+ var ErrEndpointNotCreated = errors.New("endpoint could not be created")

+ var ErrEndpointNotUpdated = errors.New("endpoint could not be updated")

+ var ErrEndpointSecretNotDeleted = errors.New("endpoint secret could not be deleted")

+ var ErrEventDeliveriesNotDeleted = errors.New("event deliveries could not be deleted")

+ var ErrEventDeliveryAttemptsNotUpdated = errors.New("event delivery attempts could not be updated")

+ var ErrEventDeliveryNotCreated = errors.New("event delivery could not be created")

+ var ErrEventDeliveryStatusNotUpdated = errors.New("event delivery status could not be updated")

+ var ErrEventNotCreated = errors.New("event could not be created")

+ var ErrOrganizationInviteNotCreated = errors.New("organization invite could not be created")

+ var ErrOrganizationInviteNotDeleted = errors.New("organization invite could not be deleted")

+ var ErrOrganizationInviteNotUpdated = errors.New("organization invite could not be updated")

+ var ErrOrganizationMemberNotCreated = errors.New("organization member could not be created")

+ var ErrOrganizationMemberNotDeleted = errors.New("organization member could not be deleted")

+ var ErrOrganizationMemberNotUpdated = errors.New("organization member could not be updated")

+ var ErrOrganizationNotCreated = errors.New("organization could not be created")

+ var ErrOrganizationNotDeleted = errors.New("organization could not be deleted")

+ var ErrOrganizationNotUpdated = errors.New("organization could not be updated")

+ var ErrPendingMigrationsFound = errors.New("migrate: Pending migrations exist, please run convoy migrate first")

+ var ErrPortalLinkNotCreated = errors.New("portal link could not be created")

+ var ErrPortalLinkNotDeleted = errors.New("portal link could not be deleted")

+ var ErrPortalLinkNotUpdated = errors.New("portal link could not be updated")

+ var ErrProjectConfigNotCreated = errors.New("project config could not be created")

+ var ErrProjectConfigNotUpdated = errors.New("project config could not be updated")

+ var ErrProjectNotCreated = errors.New("project could not be created")

+ var ErrProjectNotDeleted = errors.New("project could not be deleted")

+ var ErrProjectNotUpdated = errors.New("project could not be updated")

+ var ErrSourceNotCreated = errors.New("source could not be created")

+ var ErrSourceNotUpdated = errors.New("source could not be updated")

+ var ErrSourceVerifierNotCreated = errors.New("source verifier could not be created")

+ var ErrSourceVerifierNotUpdated = errors.New("source verifier could not be updated")

+ var ErrSubscriptionNotCreated = errors.New("subscription could not be created")

+ var ErrSubscriptionNotDeleted = errors.New("subscription could not be deleted")

+ var ErrSubscriptionNotUpdated = errors.New("subscription could not be updated")

+ var ErrUserNotCreated = errors.New("user could not be created")

+ var ErrUserNotUpdated = errors.New("user could not be updated")

+ func NewAPIKeyRepo(db database.Database) datastore.APIKeyRepository

+ func NewConfigRepo(db database.Database) datastore.ConfigurationRepository

+ func NewDeviceRepo(db database.Database) datastore.DeviceRepository

+ func NewEndpointRepo(db database.Database) datastore.EndpointRepository

+ func NewEventDeliveryRepo(db database.Database) datastore.EventDeliveryRepository

+ func NewEventRepo(db database.Database) datastore.EventRepository

+ func NewExportRepo(db database.Database) datastore.ExportRepository

+ func NewOrgInviteRepo(db database.Database) datastore.OrganisationInviteRepository

+ func NewOrgMemberRepo(db database.Database) datastore.OrganisationMemberRepository

+ func NewOrgRepo(db database.Database) datastore.OrganisationRepository

+ func NewPortalLinkRepo(db database.Database) datastore.PortalLinkRepository

+ func NewProjectRepo(db database.Database) datastore.ProjectRepository

+ func NewSourceRepo(db database.Database) datastore.SourceRepository

+ func NewSubscriptionRepo(db database.Database) datastore.SubscriptionRepository

+ func NewUserRepo(db database.Database) datastore.UserRepository

+ type ApiKeyPaginated struct

+ Count int

+ type CLIMetadata struct

+ EventType null.String

+ SourceID null.String

+ func (m *CLIMetadata) Scan(value interface{}) error

+ type DeviceMetadata struct

+ HostName null.String

+ Status null.String

+ UID null.String

+ type DevicePaginated struct

+ Count int

+ type EndpointMetadata struct

+ ProjectID null.String

+ SupportEmail null.String

+ TargetURL null.String

+ Title null.String

+ UID null.String

+ type EndpointPaginated struct

+ type EndpointSecret struct

+ Endpoint datastore.Endpoint

+ Secret datastore.Secret

+ type EventDeliveryPaginated struct

+ CLIMetadata *CLIMetadata

+ CreatedAt time.Time

+ DeletedAt null.Time

+ DeliveryAttempts datastore.DeliveryAttempts

+ Description string

+ Device *DeviceMetadata

+ DeviceID string

+ Endpoint *EndpointMetadata

+ EndpointID string

+ Event *EventMetadata

+ EventID string

+ Headers httpheader.HTTPHeader

+ Metadata *datastore.Metadata

+ ProjectID string

+ Source *SourceMetadata

+ Status datastore.EventDeliveryStatus

+ SubscriptionID string

+ UID string

+ UpdatedAt time.Time

+ type EventEndpoint struct

+ EndpointID string

+ EventID string

+ type EventMetadata struct

+ EventType null.String

+ UID null.String

+ type PortalLinkEndpoint struct

+ EndpointID string

+ PortalLinkID string

+ type PortalLinkPaginated struct

+ Count int

+ Endpoint struct{ ... }

+ type Postgres struct

+ func NewDB(cfg config.Configuration) (*Postgres, error)

+ func (p *Postgres) Close() error

+ func (p *Postgres) GetDB() *sqlx.DB

+ type SourceMetadata struct

+ Name null.String

+ UID null.String

v0.9.0-rc.3

Mar 15, 2023

v0.9.0-rc.2

Mar 14, 2023

v0.9.0-rc.1

Mar 2, 2023

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL