datastore

Oct 13, 2023

Changes in this version

+ var ErrMetaEventNotFound = errors.New("meta event not found")

+ var ErrSignupDisabled = errors.New("user registration is disabled")

+ type CustomResponse struct

+ Body string

+ ContentType string

type EndpointRepository

+ FindEndpointByTargetURL func(ctx context.Context, projectID string, targetURL string) (*Endpoint, error)

type Event

+ IdempotencyKey string

+ IsDuplicateEvent bool

+ URLQueryParams string

type EventDelivery

+ IdempotencyKey string

+ URLQueryParams string

type EventRepository

+ CopyRows func(ctx context.Context, projectID string, interval int) error

+ DeleteProjectTokenizedEvents func(ctx context.Context, projectID string, filter *EventFilter) error

+ FindEventsByIdempotencyKey func(ctx context.Context, projectID string, idempotencyKey string) ([]Event, error)

+ FindFirstEventWithIdempotencyKey func(ctx context.Context, projectID string, idempotencyKey string) (*Event, error)

type Filter

+ IdempotencyKey string

+ SubscriptionID string

+ type HookEventType string

+ const EndpointCreated

+ const EndpointDeleted

+ const EndpointUpdated

+ const EventDeliveryFailed

+ const EventDeliverySuccess

+ const EventDeliveryUpdated

+ const ProjectUpdated

+ type Job struct

+ CompletedAt null.Time

+ CreatedAt time.Time

+ DeletedAt null.Time

+ FailedAt null.Time

+ ProjectID string

+ StartedAt null.Time

+ Status JobStatus

+ Type string

+ UID string

+ UpdatedAt time.Time

+ type JobRepository interface

+ CreateJob func(ctx context.Context, job *Job) error

+ DeleteJob func(ctx context.Context, uid string, projectID string) error

+ FetchJobById func(ctx context.Context, uid string, projectID string) (*Job, error)

+ FetchJobsByProjectId func(ctx context.Context, projectID string) ([]Job, error)

+ FetchRunningJobsByProjectId func(ctx context.Context, projectID string) ([]Job, error)

+ LoadJobsPaged func(ctx context.Context, projectID string, pageable Pageable) ([]Job, PaginationData, error)

+ MarkJobAsCompleted func(ctx context.Context, uid, projectID string) error

+ MarkJobAsFailed func(ctx context.Context, uid, projectID string) error

+ MarkJobAsStarted func(ctx context.Context, uid, projectID string) error

+ type JobStatus string

+ const JobStatusCompleted

+ const JobStatusFailed

+ const JobStatusReady

+ const JobStatusRunning

+ type KafkaAuth struct

+ Hash string

+ Password string

+ TLS bool

+ Type string

+ Username string

+ type KafkaPubSubConfig struct

+ Auth *KafkaAuth

+ Brokers []string

+ ConsumerGroupID string

+ TopicName string

+ type MetaEvent struct

+ Attempt *MetaEventAttempt

+ CreatedAt time.Time

+ DeletedAt null.Time

+ EventType string

+ Metadata *Metadata

+ ProjectID string

+ Status EventDeliveryStatus

+ UID string

+ UpdatedAt time.Time

+ type MetaEventAttempt struct

+ RequestHeader HttpHeader

+ ResponseData string

+ ResponseHeader HttpHeader

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

+ func (m *MetaEventAttempt) Value() (driver.Value, error)

+ type MetaEventConfiguration struct

+ EventType pq.StringArray

+ IsEnabled bool

+ PubSub *PubSubConfig

+ Secret string

+ Type MetaEventType

+ URL string

+ type MetaEventPayload struct

+ Data json.RawMessage

+ EventType string

+ type MetaEventRepository interface

+ CreateMetaEvent func(context.Context, *MetaEvent) error

+ FindMetaEventByID func(ctx context.Context, projectID string, id string) (*MetaEvent, error)

+ LoadMetaEventsPaged func(ctx context.Context, projectID string, f *Filter) ([]MetaEvent, PaginationData, error)

+ UpdateMetaEvent func(ctx context.Context, projectID string, metaEvent *MetaEvent) error

+ type MetaEventType string

+ const HTTPMetaEvent

+ const PubSubMetaEvent

type PortalLink

+ CanManageEndpoint bool

+ OwnerID string

type PortalLinkRepository

+ FindPortalLinkByOwnerID func(ctx context.Context, projectID string, id string) (*PortalLink, error)

type ProjectConfig

+ AddEventIDTraceHeaders bool

+ MetaEvent *MetaEventConfiguration

+ func (p *ProjectConfig) GetMetaEventConfig() MetaEventConfiguration

+ type ProjectEvents struct

+ EventsCount int

+ Id string

type ProjectRepository

+ GetProjectsWithEventsInTheInterval func(ctx context.Context, interval int) ([]ProjectEvents, error)

type PubSubConfig

+ Kafka *KafkaPubSubConfig

type PubSubType

+ const KafkaPubSub

type RetentionPolicyConfiguration

+ SearchPolicy string

+ type SearchIndexParams struct

+ Interval int

+ ProjectID string

type Source

+ CustomResponse CustomResponse

+ IdempotencyKeys pq.StringArray

type Subscription

+ Function null.String

type SubscriptionRepository

+ CountEndpointSubscriptions func(ctx context.Context, projectID, endpointID string) (int64, error)

+ TransformPayload func(ctx context.Context, function string, payload map[string]interface{}) (interface{}, []string, error)

Apr 12, 2023

Changes in this version

type EndpointStatus

+ const PausedEndpointStatus

Mar 30, 2023

Changes in this version

type Filter

+ OwnerID string

Mar 28, 2023

Changes in this version

+ var DefaultCursor = fmt.Sprintf("%d", math.MaxInt)

+ var DefaultProjectConfig = ProjectConfig

+ var ErrSecretNotFound = errors.New("secret not found")

type CLIMetadata

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

+ func (m *CLIMetadata) Value() (driver.Value, error)

+ type DeliveryAttempts []DeliveryAttempt

+ func (h *DeliveryAttempts) Scan(value interface{}) error

+ func (h DeliveryAttempts) Value() (driver.Value, error)

type Endpoint

+ func (e *Endpoint) FindSecret(secretID string) *Secret

+ func (e *Endpoint) GetAuthConfig() EndpointAuthentication

+ type EndpointConfig struct

+ AdvancedSignatures bool

+ Authentication *EndpointAuthentication

+ RateLimit *RateLimitConfiguration

+ Secrets []Secret

type EndpointMetadata

+ func (s *EndpointMetadata) Scan(v interface{}) error

type EndpointRepository

+ DeleteSecret func(ctx context.Context, endpoint *Endpoint, secretID string, projectID string) error

+ UpdateSecrets func(ctx context.Context, endpointID string, projectID string, secrets Secrets) error

type EventDelivery

+ Device *Device

+ Source *Source

type EventIntervalData

+ GroupStub string

+ type ExportRepository interface

+ ExportRecords func(ctx context.Context, tableName, projectID string, createdAt time.Time) (json.RawMessage, int64, error)

+ type GooglePubSubConfig struct

+ ProjectID string

+ ServiceAccount []byte

+ SubscriptionID string

+ type M map[string]interface

+ func (h *M) Scan(value interface{}) error

+ func (h M) Map() map[string]interface{}

+ func (h M) Value() (driver.Value, error)

type Metadata

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

+ type PageDirection string

+ const Next

+ const Prev

type Pageable

+ Direction PageDirection

+ NextCursor string

+ PrevCursor string

+ func (p Pageable) Cursor() string

+ func (p Pageable) Limit() int

type PaginationData

+ HasNextPage bool

+ HasPreviousPage bool

+ NextPageCursor string

+ PrevPageCursor string

+ PrevRowCount PrevRowCount

+ func (p *PaginationData) Build(pageable Pageable, items []string) *PaginationData

+ type PrevRowCount struct

+ Count int

type Project

+ ProjectConfigID string

+ RetainedEvents int

type ProjectConfig

+ func (p *ProjectConfig) GetRateLimitConfig() RateLimitConfiguration

+ func (p *ProjectConfig) GetRetentionPolicyConfig() RetentionPolicyConfiguration

+ func (p *ProjectConfig) GetSignatureConfig() SignatureConfiguration

+ func (p *ProjectConfig) GetStrategyConfig() StrategyConfiguration

type ProjectStatistics

+ TotalEndpoints int64

+ TotalSources int64

+ TotalSubscriptions int64

+ type PubSubConfig struct

+ Google *GooglePubSubConfig

+ Sqs *SQSPubSubConfig

+ Type PubSubType

+ Workers int

+ func (p *PubSubConfig) Scan(value interface{}) error

+ func (p PubSubConfig) Value() (driver.Value, error)

+ type PubSubHandler func(*Source, string) error

+ type PubSubType string

+ const GooglePubSub

+ const SqsPubSub

+ type SQSPubSubConfig struct

+ AccessKeyID string

+ DefaultRegion string

+ QueueName string

+ SecretKey string

+ type Secrets []Secret

+ func (s *Secrets) Scan(value interface{}) error

+ func (s Secrets) Value() (driver.Value, error)

+ type SignatureVersions []SignatureVersion

+ func (s *SignatureVersions) Scan(v interface{}) error

+ func (s SignatureVersions) Value() (driver.Value, error)

type Source

+ PubSub *PubSubConfig

+ URL string

+ VerifierID string

type Subscription

+ Device *Device

+ func (s *Subscription) GetAlertConfig() AlertConfiguration

+ func (s *Subscription) GetFilterConfig() FilterConfiguration

+ func (s *Subscription) GetRateLimitConfig() RateLimitConfiguration

+ func (s *Subscription) GetRetryConfig() RetryConfiguration

Feb 21, 2023

Changes in this version

type CLIMetadata

+ SourceID string

type OrganisationMemberRepository

+ FindUserProjects func(ctx context.Context, userID string) ([]Project, error)

type SourceRepository

+ FindSourceByName func(ctx context.Context, projectId string, name string) (*Source, error)

type SubscriptionRepository

+ FindCLISubscriptions func(ctx context.Context, projectID string) ([]Subscription, error)

+ FindSubscriptionsBySourceID func(context.Context, string, string) ([]Subscription, error)

Feb 8, 2023

Changes in this version

type APIKeyRepository

+ FindAPIKeyByProjectID func(context.Context, string) (*APIKey, error)

type EventDeliveryRepository

+ LoadEventDeliveriesIntervals func(context.Context, string, SearchParams, Period, int) ([]EventInterval, error)

type OrganisationInvite

+ OrganisationName string

Dec 23, 2022

Changes in this version

+ const DataMigrationsCollection

+ const EndpointCollection

+ const FilterCollection

+ const PortalLinkCollection

+ const ProjectsCollection

+ var ErrDuplicateEndpointName = errors.New("an endpoint with this name exists")

+ var ErrDuplicateProjectName = errors.New("a project with this name already exists")

+ var ErrPortalLinkNotFound = errors.New("portal link not found")

+ var ErrProjectNotFound = errors.New("project not found")

type ApiKeyFilter

+ EndpointID string

+ EndpointIDs []string

+ ProjectID string

type AppMetadata

+ ProjectID string

type Application

+ ProjectID string

+ type DeprecatedEndpoint struct

+ AdvancedSignatures bool

+ Authentication *EndpointAuthentication

+ CreatedAt primitive.DateTime

+ DeletedAt *primitive.DateTime

+ Description string

+ HttpTimeout string

+ RateLimit int

+ RateLimitDuration string

+ Secret string

+ Secrets []Secret

+ TargetURL string

+ UID string

+ UpdatedAt primitive.DateTime

type Device

+ EndpointID string

+ ProjectID string

type Endpoint

+ AppID string

+ ID primitive.ObjectID

+ OwnerID string

+ ProjectID string

+ SlackWebhookURL string

+ SupportEmail string

+ Title string

+ type EndpointRepository interface

+ CountProjectEndpoints func(ctx context.Context, projectID string) (int64, error)

+ CreateEndpoint func(ctx context.Context, endpoint *Endpoint, projectID string) error

+ DeleteEndpoint func(ctx context.Context, endpoint *Endpoint) error

+ DeleteProjectEndpoints func(context.Context, string) error

+ ExpireSecret func(ctx context.Context, projectID string, endpointID string, secrets []Secret) error

+ FindEndpointByID func(çtx context.Context, id string) (*Endpoint, error)

+ FindEndpointsByAppID func(ctx context.Context, appID string) ([]Endpoint, error)

+ FindEndpointsByID func(ctx context.Context, ids []string) ([]Endpoint, error)

+ FindEndpointsByOwnerID func(ctx context.Context, projectID string, ownerID string) ([]Endpoint, error)

+ LoadEndpointsPaged func(ctx context.Context, projectID string, query string, pageable Pageable) ([]Endpoint, PaginationData, error)

+ LoadEndpointsPagedByProjectId func(ctx context.Context, projectID string, pageable Pageable) ([]Endpoint, PaginationData, error)

+ SearchEndpointsByProjectId func(ctx context.Context, projectID string, params SearchParams) ([]Endpoint, error)

+ UpdateEndpoint func(ctx context.Context, endpoint *Endpoint, projectID string) error

+ UpdateEndpointStatus func(ctx context.Context, projectID, endpointID string, status EndpointStatus) error

type Event

+ EndpointMetadata []*Endpoint

+ Endpoints []string

+ ProjectID string

+ func (e *Event) GetRawHeaders() map[string]interface{}

+ func (e *Event) GetRawHeadersJSON() ([]byte, error)

type EventDelivery

+ ProjectID string

type EventDeliveryFilter

+ ProjectID string

type EventDeliveryRepository

+ DeleteProjectEventDeliveries func(ctx context.Context, filter *EventDeliveryFilter, hardDelete bool) error

type EventFilter

+ ProjectID string

type EventRepository

+ CountEvents func(ctx context.Context, f *Filter) (int64, error)

+ CountProjectMessages func(ctx context.Context, projectID string) (int64, error)

+ DeleteProjectEvents func(context.Context, *EventFilter, bool) error

type Filter

+ EndpointID string

+ EndpointIDs []string

+ Project *Project

type FilterBy

+ EndpointID string

+ EndpointIDs []string

+ ProjectID string

type FilterConfiguration

+ Filter FilterSchema

+ type FilterSchema struct

+ Body map[string]interface{}

+ Headers map[string]interface{}

type MongoStore

+ func (d *MongoStore) CountWithDeleted(ctx context.Context, filter map[string]interface{}) (int64, error)

type Organisation

+ AssignedDomain string

+ CustomDomain string

type OrganisationRepository

+ FetchOrganisationByAssignedDomain func(context.Context, string) (*Organisation, error)

+ FetchOrganisationByCustomDomain func(context.Context, string) (*Organisation, error)

+ type PortalLink struct

+ CreatedAt primitive.DateTime

+ DeletedAt *primitive.DateTime

+ Endpoints []string

+ EndpointsMetadata []Endpoint

+ ID primitive.ObjectID

+ Name string

+ ProjectID string

+ Token string

+ UID string

+ UpdatedAt primitive.DateTime

+ type PortalLinkRepository interface

+ CreatePortalLink func(context.Context, *PortalLink) error

+ FindPortalLinkByID func(ctx context.Context, projectID string, id string) (*PortalLink, error)

+ FindPortalLinkByToken func(ctx context.Context, token string) (*PortalLink, error)

+ LoadPortalLinksPaged func(ctx context.Context, projectID string, f *FilterBy, pageable Pageable) ([]PortalLink, PaginationData, error)

+ RevokePortalLink func(ctx context.Context, projectID string, id string) error

+ UpdatePortalLink func(ctx context.Context, projectID string, portal *PortalLink) error

+ type Project struct

+ Config *ProjectConfig

+ CreatedAt primitive.DateTime

+ DeletedAt *primitive.DateTime

+ ID primitive.ObjectID

+ LogoURL string

+ Metadata *ProjectMetadata

+ Name string

+ OrganisationID string

+ RateLimit int

+ RateLimitDuration string

+ Statistics *ProjectStatistics

+ Type ProjectType

+ UID string

+ UpdatedAt primitive.DateTime

+ func (o *Project) IsDeleted() bool

+ func (o *Project) IsOwner(e *Endpoint) bool

+ type ProjectConfig struct

+ DisableEndpoint bool

+ IsRetentionPolicyEnabled bool

+ MaxIngestSize uint64

+ RateLimit *RateLimitConfiguration

+ ReplayAttacks bool

+ RetentionPolicy *RetentionPolicyConfiguration

+ Signature *SignatureConfiguration

+ Strategy *StrategyConfiguration

+ type ProjectFilter struct

+ Names []string

+ OrgID string

+ func (g *ProjectFilter) ToGenericMap() map[string]interface{}

+ func (g *ProjectFilter) WithNamesTrimmed() *ProjectFilter

+ type ProjectMetadata struct

+ RetainedEvents int

+ type ProjectRepository interface

+ CreateProject func(context.Context, *Project) error

+ DeleteProject func(ctx context.Context, uid string) error

+ FetchProjectByID func(context.Context, string) (*Project, error)

+ FetchProjectsByIDs func(context.Context, []string) ([]Project, error)

+ FillProjectsStatistics func(ctx context.Context, projects []*Project) error

+ LoadProjects func(context.Context, *ProjectFilter) ([]*Project, error)

+ UpdateProject func(context.Context, *Project) error

+ type ProjectStatistics struct

+ MessagesSent int64

+ ProjectID string

+ TotalApps int64

+ type ProjectType string

+ const IncomingProject

+ const OutgoingProject

type Source

+ ProjectID string

type Store

+ CountWithDeleted func(ctx context.Context, filter map[string]interface{}) (int64, error)

type Subscription

+ ProjectID string

+ type SubscriptionFilter struct

+ DeletedAt *primitive.DateTime

+ Filter map[string]interface{}

+ ID primitive.ObjectID

+ UID string

type SubscriptionRepository

+ FindSubscriptionsByEndpointID func(ctx context.Context, projectId string, endpointID string) ([]Subscription, error)

+ TestSubscriptionFilter func(ctx context.Context, payload map[string]interface{}, ...) (bool, error)

type User

+ EmailVerificationExpiresAt primitive.DateTime

+ EmailVerificationToken string

+ EmailVerified bool

type UserRepository

+ FindUserByEmailVerificationToken func(ctx context.Context, token string) (*User, error)

Dec 13, 2022

Changes in this version

type Event

+ Raw string

type Metadata

+ Raw string

Nov 29, 2022

Changes in this version

type Filter

+ SubscriptionIDs []string

Nov 7, 2022

Changes in this version

+ var ErrNoActiveSecret = errors.New("no active secret found")

type Application

+ func (app *Application) FindEndpoint(id string) (*Endpoint, error)

type ApplicationRepository

+ ExpireSecret func(ctx context.Context, appID string, endpointID string, secrets []Secret) error

type EncodingType

+ func (e EncodingType) String() string

type Endpoint

+ AdvancedSignatures bool

+ Secrets []Secret

+ func (e *Endpoint) GetActiveSecretIndex() (int, error)

+ type Secret struct

+ CreatedAt primitive.DateTime

+ DeletedAt primitive.DateTime

+ DocumentStatus DocumentStatus

+ ExpiresAt primitive.DateTime

+ UID string

+ UpdatedAt primitive.DateTime

+ Value string

type SignatureConfiguration

+ Versions []SignatureVersion

+ func GetDefaultSignatureConfig() *SignatureConfiguration

+ type SignatureVersion struct

+ CreatedAt primitive.DateTime

+ Encoding EncodingType

+ Hash string

+ UID string

Oct 25, 2022

Changes in this version

+ const APIKeyCollection

+ const AppCollection

+ const ConfigCollection

+ const DeviceCollection

+ const OrganisationCollection

+ const OrganisationInvitesCollection

+ const OrganisationMembersCollection

+ const SourceCollection

+ const SubscriptionCollection

+ const UserCollection

+ var DefaultRetentionPolicy = RetentionPolicyConfiguration

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

+ var ErrInvalidCollection = errors.New("Invalid collection type")

type APIKey

+ UserID string

+ type ApiKeyFilter struct

+ AppID string

+ GroupID string

+ KeyType KeyType

+ UserID string

+ type CLIMetadata struct

+ EventType string

+ HostName string

+ type CollectionKey string

+ const CollectionCtx

+ type Device struct

+ AppID string

+ CreatedAt primitive.DateTime

+ DeletedAt primitive.DateTime

+ DocumentStatus DocumentStatus

+ GroupID string

+ HostName string

+ ID primitive.ObjectID

+ LastSeenAt primitive.DateTime

+ Status DeviceStatus

+ UID string

+ UpdatedAt primitive.DateTime

+ type DeviceMap map[string]*Device

+ type DeviceRepository interface

+ CreateDevice func(ctx context.Context, device *Device) error

+ DeleteDevice func(ctx context.Context, uid string, appID, groupID string) error

+ FetchDeviceByHostName func(ctx context.Context, hostName string, appID, groupID string) (*Device, error)

+ FetchDeviceByID func(ctx context.Context, uid string, appID, groupID string) (*Device, error)

+ LoadDevicesPaged func(ctx context.Context, groupID string, filter *ApiKeyFilter, pageable Pageable) ([]Device, PaginationData, error)

+ UpdateDevice func(ctx context.Context, device *Device, appID, groupID string) error

+ UpdateDeviceLastSeen func(ctx context.Context, device *Device, appID, groupID string, ...) error

+ type DeviceStatus string

+ const DeviceStatusDisabled

+ const DeviceStatusOffline

+ const DeviceStatusOnline

type Endpoint

+ Authentication *EndpointAuthentication

+ type EndpointAuthentication struct

+ ApiKey *ApiKey

+ Type EndpointAuthenticationType

+ type EndpointAuthenticationType string

+ const APIKeyAuthentication

type EventDelivery

+ CLIMetadata *CLIMetadata

+ DeviceID string

type EventDeliveryRepository

+ FindDiscardedEventDeliveries func(ctx context.Context, appId, deviceId string, searchParams SearchParams) ([]EventDelivery, error)

type Filter

+ SourceID string

type FilterBy

+ SourceID string

type KeyType

+ const PersonalKey

+ func (k KeyType) IsValid() bool

+ func (k KeyType) IsValidAppKey() bool

+ type MongoStore struct

+ Database *mongo.Database

+ IsConnected bool

+ func (d *MongoStore) Aggregate(ctx context.Context, pipeline mongo.Pipeline, output interface{}, ...) error

+ func (d *MongoStore) Count(ctx context.Context, filter map[string]interface{}) (int64, error)

+ func (d *MongoStore) DeleteByID(ctx context.Context, id string, hardDelete bool) error

+ func (d *MongoStore) DeleteMany(ctx context.Context, filter, payload bson.M, hardDelete bool) error

+ func (d *MongoStore) DeleteOne(ctx context.Context, filter bson.M, hardDelete bool) error

+ func (d *MongoStore) FindAll(ctx context.Context, filter bson.M, sort interface{}, ...) error

+ func (d *MongoStore) FindByID(ctx context.Context, id string, projection bson.M, result interface{}) error

+ func (d *MongoStore) FindMany(ctx context.Context, filter, projection bson.M, sort interface{}, ...) (PaginationData, error)

+ func (d *MongoStore) FindManyWithDeletedAt(ctx context.Context, filter, projection bson.M, sort interface{}, ...) error

+ func (d *MongoStore) FindOne(ctx context.Context, filter, projection bson.M, result interface{}) error

+ func (d *MongoStore) Inc(ctx context.Context, filter bson.M, payload interface{}) error

+ func (d *MongoStore) Save(ctx context.Context, payload interface{}, out interface{}) error

+ func (d *MongoStore) SaveMany(ctx context.Context, payload []interface{}) error

+ func (d *MongoStore) UpdateByID(ctx context.Context, id string, payload interface{}) error

+ func (d *MongoStore) UpdateMany(ctx context.Context, filter, payload bson.M, bulk bool) error

+ func (d *MongoStore) UpdateOne(ctx context.Context, filter bson.M, payload interface{}) error

+ func (d *MongoStore) WithTransaction(ctx context.Context, fn func(sessCtx mongo.SessionContext) error) error

type S3Storage

+ Endpoint string

type SourceProvider

+ func (s SourceProvider) IsValid() bool

type SourceType

+ func (s SourceType) IsValid() bool

type Store

+ WithTransaction func(ctx context.Context, fn func(sessCtx mongo.SessionContext) error) error

type Subscription

+ DeviceID string

+ DisableEndpoint *bool

+ RateLimitConfig *RateLimitConfiguration

type SubscriptionRepository

+ FindSubscriptionByDeviceID func(ctx context.Context, groupId string, deviceID string) (*Subscription, error)

+ type SubscriptionType string

+ const SubscriptionTypeAPI

+ const SubscriptionTypeCLI

Aug 25, 2022

Changes in this version

+ var ErrDuplicateEmail = errors.New("a user with this email already exists")

type Configuration

+ IsSignupEnabled bool

type Event

+ Source *Source

+ type FilterBy struct

+ AppID string

+ GroupID string

+ SearchParams SearchParams

+ func (f *FilterBy) String() *string

+ type SearchFilter struct

+ FilterBy FilterBy

+ Pageable Pageable

+ Query string

Aug 5, 2022

Changes in this version

type Event

+ Headers httpheader.HTTPHeader

type EventDelivery

+ Headers httpheader.HTTPHeader

type KeyType

+ const AppPortalKey

+ const CLIKey

+ const ProjectKey

type VerifierType

+ const NoopVerifier

Jul 25, 2022

Changes in this version

+ const DefaultStrategyProvider

+ const ExponentialStrategyProvider

+ const LinearStrategyProvider

+ var DefaultAlertConfig = AlertConfiguration

+ var DefaultRateLimitConfig = RateLimitConfiguration

+ var DefaultRetryConfig = RetryConfiguration

+ var DefaultSignatureConfig = SignatureConfiguration

+ var DefaultStoragePolicy = StoragePolicyConfiguration

+ var DefaultStrategyConfig = StrategyConfiguration

+ var ErrConfigNotFound = errors.New("config not found")

+ var ErrDuplicateAppName = errors.New("an application with this name exists")

+ var ErrDuplicateGroupName = errors.New("a group with this name already exists")

+ var ErrInvalidPtr = errors.New("out param is not a valid pointer")

+ var ErrNotAuthorisedToAccessDocument = errors.New("your credentials cannot access or modify this resource")

+ var ErrOrgInviteNotFound = errors.New("organisation invite not found")

+ var ErrOrgMemberNotFound = errors.New("organisation member not found")

+ var ErrOrgNotFound = errors.New("organisation not found")

+ var ErrSourceNotFound = errors.New("source not found")

+ var ErrSubscriptionNotFound = errors.New("subscription not found")

+ var ErrUserNotFound = errors.New("user not found")

+ func IsValidPointer(i interface{}) bool

+ type AlertConfiguration struct

+ Count int

+ Threshold string

+ type ApiKey struct

+ HeaderName string

+ HeaderValue string

+ type AppMap map[string]*Application

type ApplicationRepository

+ CreateApplicationEndpoint func(context.Context, string, string, *Endpoint) error

+ type BasicAuth struct

+ Password string

+ UserName string

+ type Configuration struct

+ CreatedAt primitive.DateTime

+ DeletedAt primitive.DateTime

+ DocumentStatus DocumentStatus

+ ID primitive.ObjectID

+ IsAnalyticsEnabled bool

+ StoragePolicy *StoragePolicyConfiguration

+ UID string

+ UpdatedAt primitive.DateTime

+ type ConfigurationRepository interface

+ CreateConfiguration func(context.Context, *Configuration) error

+ LoadConfiguration func(context.Context) (*Configuration, error)

+ UpdateConfiguration func(context.Context, *Configuration) error

type DatabaseClient

+ ConfigurationRepo func() ConfigurationRepository

+ OrganisationInviteRepo func() OrganisationInviteRepository

+ OrganisationMemberRepo func() OrganisationMemberRepository

+ OrganisationRepo func() OrganisationRepository

+ SourceRepo func() SourceRepository

+ SubRepo func() SubscriptionRepository

+ UserRepo func() UserRepository

+ type EncodingType string

+ const Base64Encoding

+ const HexEncoding

+ type EndpointMap map[string]*Endpoint

type Event

+ App *Application

+ AppID string

+ ForwardedHeaders HttpHeader

+ GroupID string

+ SourceID string

+ func (e *Event) SetForwardedHeaders(headers []string, r *http.Request)

type EventDelivery

+ App *Application

+ AppID string

+ Endpoint *Endpoint

+ EndpointID string

+ Event *Event

+ EventID string

+ ForwardedHeaders HttpHeader

+ GroupID string

+ SubscriptionID string

+ type EventDeliveryFilter struct

+ CreatedAtEnd int64

+ CreatedAtStart int64

+ GroupID string

type EventDeliveryRepository

+ DeleteGroupEventDeliveries func(ctx context.Context, filter *EventDeliveryFilter, hardDelete bool) error

+ type EventFilter struct

+ CreatedAtEnd int64

+ CreatedAtStart int64

+ DocumentStatus DocumentStatus

+ GroupID string

+ type EventMap map[string]*Event

type EventRepository

+ FindEventsByIDs func(context.Context, []string) ([]Event, error)

type Filter

+ Query string

+ type FilterConfiguration struct

+ EventTypes []string

type Group

+ Metadata *GroupMetadata

+ OrganisationID string

+ Type GroupType

type GroupConfig

+ IsRetentionPolicyEnabled bool

+ RateLimit *RateLimitConfiguration

+ RetentionPolicy *RetentionPolicyConfiguration

type GroupFilter

+ OrgID string

+ func (g *GroupFilter) ToGenericMap() map[string]interface{}

+ type GroupMetadata struct

+ RetainedEvents int

type GroupRepository

+ FillGroupsStatistics func(ctx context.Context, groups []*Group) error

type GroupStatistics

+ GroupID string

+ type GroupType string

+ const IncomingGroup

+ const OutgoingGroup

+ type HMac struct

+ Encoding EncodingType

+ Hash string

+ Header string

+ Secret string

type HttpHeader

+ func (h HttpHeader) SetHeadersInRequest(r *http.Request)

+ type InviteStatus string

+ const InviteStatusAccepted

+ const InviteStatusCancelled

+ const InviteStatusDeclined

+ const InviteStatusPending

+ func (i InviteStatus) String() string

+ type OnPremStorage struct

+ Path string

+ type Organisation struct

+ CreatedAt primitive.DateTime

+ DeletedAt primitive.DateTime

+ DocumentStatus DocumentStatus

+ ID primitive.ObjectID

+ Name string

+ OwnerID string

+ UID string

+ UpdatedAt primitive.DateTime

+ type OrganisationInvite struct

+ CreatedAt primitive.DateTime

+ DeletedAt primitive.DateTime

+ DocumentStatus DocumentStatus

+ ExpiresAt primitive.DateTime

+ ID primitive.ObjectID

+ InviteeEmail string

+ OrganisationID string

+ Role auth.Role

+ Status InviteStatus

+ Token string

+ UID string

+ UpdatedAt primitive.DateTime

+ type OrganisationInviteRepository interface

+ CreateOrganisationInvite func(ctx context.Context, iv *OrganisationInvite) error

+ DeleteOrganisationInvite func(ctx context.Context, uid string) error

+ FetchOrganisationInviteByID func(ctx context.Context, uid string) (*OrganisationInvite, error)

+ FetchOrganisationInviteByToken func(ctx context.Context, token string) (*OrganisationInvite, error)

+ LoadOrganisationsInvitesPaged func(ctx context.Context, orgID string, inviteStatus InviteStatus, ...) ([]OrganisationInvite, PaginationData, error)

+ UpdateOrganisationInvite func(ctx context.Context, iv *OrganisationInvite) error

+ type OrganisationMember struct

+ CreatedAt primitive.DateTime

+ DeletedAt primitive.DateTime

+ DocumentStatus DocumentStatus

+ ID primitive.ObjectID

+ OrganisationID string

+ Role auth.Role

+ UID string

+ UpdatedAt primitive.DateTime

+ UserID string

+ UserMetadata *UserMetadata

+ type OrganisationMemberRepository interface

+ CreateOrganisationMember func(ctx context.Context, member *OrganisationMember) error

+ DeleteOrganisationMember func(ctx context.Context, memberID string, orgID string) error

+ FetchOrganisationMemberByID func(ctx context.Context, memberID string, organisationID string) (*OrganisationMember, error)

+ FetchOrganisationMemberByUserID func(ctx context.Context, userID string, organisationID string) (*OrganisationMember, error)

+ LoadOrganisationMembersPaged func(ctx context.Context, organisationID string, pageable Pageable) ([]*OrganisationMember, PaginationData, error)

+ LoadUserOrganisationsPaged func(ctx context.Context, userID string, pageable Pageable) ([]Organisation, PaginationData, error)

+ UpdateOrganisationMember func(ctx context.Context, member *OrganisationMember) error

+ type OrganisationRepository interface

+ CreateOrganisation func(context.Context, *Organisation) error

+ DeleteOrganisation func(context.Context, string) error

+ FetchOrganisationByID func(context.Context, string) (*Organisation, error)

+ LoadOrganisationsPaged func(context.Context, Pageable) ([]Organisation, PaginationData, error)

+ UpdateOrganisation func(context.Context, *Organisation) error

+ type Password struct

+ Hash []byte

+ Plaintext string

+ func (p *Password) GenerateHash() error

+ func (p *Password) Matches() (bool, error)

+ type ProviderConfig struct

+ Twitter *TwitterProviderConfig

+ type RateLimitConfiguration struct

+ Count int

+ Duration string

+ type RetentionPolicyConfiguration struct

+ Policy string

+ type RetryConfiguration struct

+ Duration string

+ RetryCount int

+ Type config.StrategyProvider

+ type S3Storage struct

+ AccessKey string

+ Bucket string

+ Region string

+ SecretKey string

+ SessionToken string

+ type Source struct

+ CreatedAt primitive.DateTime

+ DeletedAt primitive.DateTime

+ DocumentStatus DocumentStatus

+ ForwardHeaders []string

+ GroupID string

+ ID primitive.ObjectID

+ IsDisabled bool

+ MaskID string

+ Name string

+ Provider SourceProvider

+ ProviderConfig *ProviderConfig

+ Type SourceType

+ UID string

+ UpdatedAt primitive.DateTime

+ Verifier *VerifierConfig

+ type SourceFilter struct

+ Provider string

+ Type string

+ type SourceMap map[string]*Source

+ type SourceProvider string

+ const GithubSourceProvider

+ const ShopifySourceProvider

+ const TwitterSourceProvider

+ type SourceRepository interface

+ CreateSource func(context.Context, *Source) error

+ DeleteSourceByID func(ctx context.Context, groupID string, id string) error

+ FindSourceByID func(ctx context.Context, groupID string, id string) (*Source, error)

+ FindSourceByMaskID func(ctx context.Context, maskID string) (*Source, error)

+ LoadSourcesPaged func(ctx context.Context, groupID string, filter *SourceFilter, pageable Pageable) ([]Source, PaginationData, error)

+ UpdateSource func(ctx context.Context, groupID string, source *Source) error

+ type SourceType string

+ const DBChangeStream

+ const HTTPSource

+ const PubSubSource

+ const RestApiSource

+ type StoragePolicyConfiguration struct

+ OnPrem *OnPremStorage

+ S3 *S3Storage

+ Type StorageType

+ type StorageType string

+ const OnPrem

+ const S3

+ type Store interface

+ Aggregate func(ctx context.Context, pipeline mongo.Pipeline, result interface{}, ...) error

+ Count func(ctx context.Context, filter map[string]interface{}) (int64, error)

+ DeleteByID func(ctx context.Context, id string, hardDelete bool) error

+ DeleteMany func(ctx context.Context, filter, payload bson.M, hardDelete bool) error

+ DeleteOne func(ctx context.Context, filter bson.M, hardDelete bool) error

+ FindAll func(ctx context.Context, filter bson.M, sort interface{}, ...) error

+ FindByID func(ctx context.Context, id string, projection bson.M, result interface{}) error

+ FindMany func(ctx context.Context, filter, projection bson.M, sort interface{}, ...) error

+ FindManyWithDeletedAt func(ctx context.Context, filter, projection bson.M, sort interface{}, ...) error

+ FindOne func(ctx context.Context, filter, projection bson.M, result interface{}) error

+ Inc func(ctx context.Context, filter bson.M, payload interface{}) error

+ Save func(ctx context.Context, payload interface{}, result interface{}) error

+ SaveMany func(ctx context.Context, payload []interface{}) error

+ UpdateByID func(ctx context.Context, id string, payload interface{}) error

+ UpdateMany func(ctx context.Context, filter, payload bson.M) error

+ UpdateOne func(ctx context.Context, filter bson.M, payload interface{}) error

type StrategyConfiguration

+ Duration uint64

+ RetryCount uint64

+ type StrategyProvider string

+ type Subscription struct

+ AlertConfig *AlertConfiguration

+ App *Application

+ AppID string

+ CreatedAt primitive.DateTime

+ DeletedAt primitive.DateTime

+ DocumentStatus DocumentStatus

+ Endpoint *Endpoint

+ EndpointID string

+ FilterConfig *FilterConfiguration

+ GroupID string

+ ID primitive.ObjectID

+ Name string

+ RetryConfig *RetryConfiguration

+ Source *Source

+ SourceID string

+ Status SubscriptionStatus

+ Type string

+ UID string

+ UpdatedAt primitive.DateTime

+ type SubscriptionRepository interface

+ CreateSubscription func(context.Context, string, *Subscription) error

+ DeleteSubscription func(context.Context, string, *Subscription) error

+ FindSubscriptionByID func(context.Context, string, string) (*Subscription, error)

+ FindSubscriptionsByAppID func(ctx context.Context, groupId string, appID string) ([]Subscription, error)

+ FindSubscriptionsByEventType func(context.Context, string, string, EventType) ([]Subscription, error)

+ FindSubscriptionsBySourceIDs func(context.Context, string, string) ([]Subscription, error)

+ LoadSubscriptionsPaged func(context.Context, string, Pageable) ([]Subscription, PaginationData, error)

+ UpdateSubscription func(context.Context, string, *Subscription) error

+ UpdateSubscriptionStatus func(context.Context, string, string, SubscriptionStatus) error

+ type SubscriptionStatus string

+ const ActiveSubscriptionStatus

+ const InactiveSubscriptionStatus

+ const PendingSubscriptionStatus

+ type TwitterProviderConfig struct

+ CrcVerifiedAt primitive.DateTime

+ type User struct

+ CreatedAt primitive.DateTime

+ DeletedAt primitive.DateTime

+ DocumentStatus DocumentStatus

+ Email string

+ FirstName string

+ ID primitive.ObjectID

+ LastName string

+ Password string

+ ResetPasswordExpiresAt primitive.DateTime

+ ResetPasswordToken string

+ Role auth.Role

+ UID string

+ UpdatedAt primitive.DateTime

+ type UserMetadata struct

+ Email string

+ FirstName string

+ LastName string

+ UserID string

+ type UserRepository interface

+ CreateUser func(context.Context, *User) error

+ FindUserByEmail func(context.Context, string) (*User, error)

+ FindUserByID func(context.Context, string) (*User, error)

+ FindUserByToken func(context.Context, string) (*User, error)

+ LoadUsersPaged func(context.Context, Pageable) ([]User, PaginationData, error)

+ UpdateUser func(ctx context.Context, user *User) error

+ type VerifierConfig struct

+ ApiKey *ApiKey

+ BasicAuth *BasicAuth

+ HMac *HMac

+ Type VerifierType

+ type VerifierType string

+ const APIKeyVerifier

+ const BasicAuthVerifier

+ const HMacVerifier

Apr 25, 2022

Changes in this version

type Application

+ SlackWebhookURL string

type GroupConfig

+ ReplayAttacks bool

type GroupFilter

+ func (g *GroupFilter) WithNamesTrimmed() *GroupFilter

+ type SignatureValues struct

+ Hash string

+ Header config.SignatureHeaderProvider

Mar 25, 2022

Changes in this version

type Application

+ IsDisabled bool

type Endpoint

+ HttpTimeout string

+ RateLimit int

+ RateLimitDuration string

type EndpointMetadata

+ HttpTimeout string

+ RateLimit int

+ RateLimitDuration string

type EventDeliveryRepository

+ CountEventDeliveries func(context.Context, string, string, string, []EventDeliveryStatus, SearchParams) (int64, error)

+ type Filter struct

+ AppID string

+ EventID string

+ Group *Group

+ Pageable Pageable

+ SearchParams SearchParams

+ Status []EventDeliveryStatus

type Group

+ RateLimit int

+ RateLimitDuration string

Mar 9, 2022

Changes in this version

type EventDeliveryRepository

+ UpdateStatusOfEventDeliveries func(context.Context, []string, EventDeliveryStatus) error

Mar 7, 2022

Changes in this version

type EventDeliveryRepository

+ CountDeliveriesByStatus func(context.Context, EventDeliveryStatus) (int64, error)

Feb 25, 2022

Changes in this version

type EventDeliveryStatus

+ func (e EventDeliveryStatus) IsValid() bool

+ type ExponentialBackoffStrategyConfiguration struct

+ RetryLimit uint64

type StrategyConfiguration

+ ExponentialBackoff ExponentialBackoffStrategyConfiguration

Dec 25, 2021

Changes in this version

+ const EventCollection

+ const EventDeliveryCollection

+ func NewEventDeliveryRepository(db *mongo.Database) convoy.EventDeliveryRepository

+ func NewEventRepository(db *mongo.Database) convoy.EventRepository

Oct 15, 2021

Changes in this version

+ const GroupCollection

+ func NewGroupRepo(client *mongo.Database) convoy.GroupRepository

Sep 7, 2021

Changes in this version

+ const AppCollections

+ const MsgCollection

+ const OrgCollection

+ func EnsureIndex(db *mongo.Database, collectionName string, field string, unique bool) bool

+ func New(cfg config.Configuration) (*mongo.Client, error)

+ func NewApplicationRepo(client *mongo.Database) convoy.ApplicationRepository

+ func NewMessageRepository(db *mongo.Database) convoy.MessageRepository

+ func NewOrganisationRepo(client *mongo.Database) convoy.OrganisationRepository

Feb 16, 2022

Changes in this version

+ var ErrAPIKeyNotFound = errors.New("api key not found")

+ var ErrApplicationNotFound = errors.New("application not found")

+ var ErrEndpointNotFound = errors.New("endpoint not found")

+ var ErrEventDeliveryAttemptNotFound = errors.New("delivery attempt not found")

+ var ErrEventDeliveryNotFound = errors.New("event not found")

+ var ErrEventNotFound = errors.New("event not found")

+ var ErrGroupNotFound = errors.New("group not found")

+ var PeriodValues = map[string]Period

+ func IsValidPeriod(period string) bool

+ type APIKey struct

+ CreatedAt primitive.DateTime

+ DeletedAt primitive.DateTime

+ DocumentStatus DocumentStatus

+ ExpiresAt primitive.DateTime

+ Hash string

+ ID primitive.ObjectID

+ MaskID string

+ Name string

+ Role auth.Role

+ Salt string

+ Type KeyType

+ UID string

+ UpdatedAt primitive.DateTime

+ type APIKeyRepository interface

+ CreateAPIKey func(context.Context, *APIKey) error

+ FindAPIKeyByHash func(context.Context, string) (*APIKey, error)

+ FindAPIKeyByID func(context.Context, string) (*APIKey, error)

+ FindAPIKeyByMaskID func(context.Context, string) (*APIKey, error)

+ LoadAPIKeysPaged func(context.Context, *Pageable) ([]APIKey, PaginationData, error)

+ RevokeAPIKeys func(context.Context, []string) error

+ UpdateAPIKey func(context.Context, *APIKey) error

+ type AppMetadata struct

+ GroupID string

+ SupportEmail string

+ Title string

+ UID string

+ type Application struct

+ CreatedAt primitive.DateTime

+ DeletedAt primitive.DateTime

+ DocumentStatus DocumentStatus

+ Endpoints []Endpoint

+ Events int64

+ GroupID string

+ ID primitive.ObjectID

+ SupportEmail string

+ Title string

+ UID string

+ UpdatedAt primitive.DateTime

+ type ApplicationRepository interface

+ CountGroupApplications func(ctx context.Context, groupID string) (int64, error)

+ CreateApplication func(context.Context, *Application) error

+ DeleteApplication func(context.Context, *Application) error

+ DeleteGroupApps func(context.Context, string) error

+ FindApplicationByID func(context.Context, string) (*Application, error)

+ FindApplicationEndpointByID func(context.Context, string, string) (*Endpoint, error)

+ LoadApplicationsPaged func(context.Context, string, string, Pageable) ([]Application, PaginationData, error)

+ LoadApplicationsPagedByGroupId func(context.Context, string, Pageable) ([]Application, PaginationData, error)

+ SearchApplicationsByGroupId func(context.Context, string, SearchParams) ([]Application, error)

+ UpdateApplication func(context.Context, *Application) error

+ UpdateApplicationEndpointsStatus func(context.Context, string, []string, EndpointStatus) error

+ type DatabaseClient interface

+ APIRepo func() APIKeyRepository

+ AppRepo func() ApplicationRepository

+ Client func() interface{}

+ Disconnect func(context.Context) error

+ EventDeliveryRepo func() EventDeliveryRepository

+ EventRepo func() EventRepository

+ GetName func() string

+ GroupRepo func() GroupRepository

+ type DefaultStrategyConfiguration struct

+ IntervalSeconds uint64

+ RetryLimit uint64

+ type DeliveryAttempt struct

+ APIVersion string

+ CreatedAt primitive.DateTime

+ DeletedAt primitive.DateTime

+ EndpointID string

+ Error string

+ HttpResponseCode string

+ ID primitive.ObjectID

+ IPAddress string

+ Method string

+ MsgID string

+ RequestHeader HttpHeader

+ ResponseData string

+ ResponseHeader HttpHeader

+ Status bool

+ UID string

+ URL string

+ UpdatedAt primitive.DateTime

+ type DocumentStatus string

+ const ActiveDocumentStatus

+ const DeletedDocumentStatus

+ const InactiveDocumentStatus

+ type Endpoint struct

+ CreatedAt primitive.DateTime

+ DeletedAt primitive.DateTime

+ Description string

+ DocumentStatus DocumentStatus

+ Events []string

+ Secret string

+ Status EndpointStatus

+ TargetURL string

+ UID string

+ UpdatedAt primitive.DateTime

+ type EndpointMetadata struct

+ Secret string

+ Sent bool

+ Status EndpointStatus

+ TargetURL string

+ UID string

+ type EndpointStatus string

+ const ActiveEndpointStatus

+ const InactiveEndpointStatus

+ const PendingEndpointStatus

+ type Event struct

+ AppMetadata *AppMetadata

+ CreatedAt primitive.DateTime

+ Data json.RawMessage

+ DeletedAt primitive.DateTime

+ DocumentStatus DocumentStatus

+ EventType EventType

+ ID primitive.ObjectID

+ MatchedEndpoints int

+ ProviderID string

+ UID string

+ UpdatedAt primitive.DateTime

+ type EventDelivery struct

+ AppMetadata *AppMetadata

+ CreatedAt primitive.DateTime

+ DeletedAt primitive.DateTime

+ DeliveryAttempts []DeliveryAttempt

+ Description string

+ DocumentStatus DocumentStatus

+ EndpointMetadata *EndpointMetadata

+ EventMetadata *EventMetadata

+ ID primitive.ObjectID

+ Metadata *Metadata

+ Status EventDeliveryStatus

+ UID string

+ UpdatedAt primitive.DateTime

+ type EventDeliveryRepository interface

+ CreateEventDelivery func(context.Context, *EventDelivery) error

+ FindEventDeliveriesByEventID func(context.Context, string) ([]EventDelivery, error)

+ FindEventDeliveriesByIDs func(context.Context, []string) ([]EventDelivery, error)

+ FindEventDeliveryByID func(context.Context, string) (*EventDelivery, error)

+ LoadEventDeliveriesPaged func(context.Context, string, string, string, []EventDeliveryStatus, SearchParams, ...) ([]EventDelivery, PaginationData, error)

+ UpdateEventDeliveryWithAttempt func(context.Context, EventDelivery, DeliveryAttempt) error

+ UpdateStatusOfEventDelivery func(context.Context, EventDelivery, EventDeliveryStatus) error

+ type EventDeliveryStatus string

+ const DiscardedEventStatus

+ const FailureEventStatus

+ const ProcessingEventStatus

+ const RetryEventStatus

+ const ScheduledEventStatus

+ const SuccessEventStatus

+ type EventInterval struct

+ Count uint64

+ Data EventIntervalData

+ type EventIntervalData struct

+ Interval int64

+ Time string

+ type EventMetadata struct

+ EventType EventType

+ UID string

+ type EventRepository interface

+ CountGroupMessages func(ctx context.Context, groupID string) (int64, error)

+ CreateEvent func(context.Context, *Event) error

+ DeleteGroupEvents func(context.Context, string) error

+ FindEventByID func(ctx context.Context, id string) (*Event, error)

+ LoadEventIntervals func(context.Context, string, SearchParams, Period, int) ([]EventInterval, error)

+ LoadEventsPaged func(context.Context, string, string, SearchParams, Pageable) ([]Event, PaginationData, error)

+ type EventType string

+ type Group struct

+ Config *GroupConfig

+ CreatedAt primitive.DateTime

+ DeletedAt primitive.DateTime

+ DocumentStatus DocumentStatus

+ ID primitive.ObjectID

+ LogoURL string

+ Name string

+ Statistics *GroupStatistics

+ UID string

+ UpdatedAt primitive.DateTime

+ func (o *Group) IsDeleted() bool

+ func (o *Group) IsOwner(a *Application) bool

+ type GroupConfig struct

+ DisableEndpoint bool

+ Signature SignatureConfiguration

+ Strategy StrategyConfiguration

+ type GroupFilter struct

+ Names []string

+ type GroupRepository interface

+ CreateGroup func(context.Context, *Group) error

+ DeleteGroup func(ctx context.Context, uid string) error

+ FetchGroupByID func(context.Context, string) (*Group, error)

+ FetchGroupsByIDs func(context.Context, []string) ([]Group, error)

+ LoadGroups func(context.Context, *GroupFilter) ([]*Group, error)

+ UpdateGroup func(context.Context, *Group) error

+ type GroupStatistics struct

+ MessagesSent int64

+ TotalApps int64

+ type HttpHeader map[string]string

+ type KeyType string

+ type Metadata struct

+ Data json.RawMessage

+ IntervalSeconds uint64

+ NextSendTime primitive.DateTime

+ NumTrials uint64

+ RetryLimit uint64

+ Strategy config.StrategyProvider

+ func (em Metadata) Value() (driver.Value, error)

+ type Pageable struct

+ Page int

+ PerPage int

+ Sort int

+ type PaginationData struct

+ Next int64

+ Page int64

+ PerPage int64

+ Prev int64

+ Total int64

+ TotalPage int64

+ type Period int

+ const Daily

+ const Monthly

+ const Weekly

+ const Yearly

+ type SearchParams struct

+ CreatedAtEnd int64

+ CreatedAtStart int64

+ type SignatureConfiguration struct

+ Hash string

+ Header config.SignatureHeaderProvider

+ type StrategyConfiguration struct

+ Default DefaultStrategyConfiguration

+ Type config.StrategyProvider