models

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

+ func NewListResponse(items []M, fn func(item M) T) []T

+ type AlertConfiguration struct

+ Count int

+ Threshold string

+ func (ac *AlertConfiguration) Transform() *datastore.AlertConfiguration

+ type ApiKey struct

+ HeaderName string

+ HeaderValue string

+ type BasicAuth struct

+ Password string

+ UserName string

type Configuration

+ func (c *Configuration) Validate() error

+ type CreateEndpoint struct

+ AdvancedSignatures bool

+ AppID string

+ Authentication *EndpointAuthentication

+ Description string

+ HttpTimeout string

+ IsDisabled bool

+ Name string

+ OwnerID string

+ RateLimit int

+ RateLimitDuration string

+ Secret string

+ SlackWebhookURL string

+ SupportEmail string

+ URL string

+ func (cE *CreateEndpoint) Validate() error

+ type CreateEvent struct

+ AppID string

+ CustomHeaders map[string]string

+ Data json.RawMessage

+ EndpointID string

+ EventType string

+ IdempotencyKey string

+ func (e *CreateEvent) Validate() error

+ type CreateProject struct

+ Config *ProjectConfig

+ LogoURL string

+ Name string

+ Type string

+ func (cP *CreateProject) Validate() error

+ type CreateSource struct

+ CustomResponse CustomResponse

+ IdempotencyKeys []string

+ IdempotencyTTL string

+ IsDisabled bool

+ Name string

+ Provider datastore.SourceProvider

+ PubSub PubSubConfig

+ Type datastore.SourceType

+ Verifier VerifierConfig

+ func (cs *CreateSource) Validate() error

+ type CreateSubscription struct

+ AlertConfig *AlertConfiguration

+ AppID string

+ EndpointID string

+ FilterConfig *FilterConfiguration

+ Function string

+ Name string

+ RateLimitConfig *RateLimitConfiguration

+ RetryConfig *RetryConfiguration

+ SourceID string

+ func (cs *CreateSubscription) Validate() error

+ type CustomResponse struct

+ Body string

+ ContentType string

+ type DynamicEndpoint struct

+ AdvancedSignatures bool

+ AppID string

+ Authentication *EndpointAuthentication

+ Description string

+ HttpTimeout string

+ IsDisabled bool

+ Name string

+ OwnerID string

+ RateLimit int

+ RateLimitDuration string

+ Secret string

+ SlackWebhookURL string

+ SupportEmail string

+ URL string

+ func (dE *DynamicEndpoint) Validate() error

+ type DynamicEvent struct

+ Endpoint DynamicEndpoint

+ Event DynamicEventStub

+ Subscription DynamicSubscription

+ func (de *DynamicEvent) Validate() error

+ type DynamicEventStub struct

+ CustomHeaders map[string]string

+ Data json.RawMessage

+ EventType string

+ IdempotencyKey string

+ ProjectID string

+ func (ds *DynamicEventStub) Validate() error

+ type DynamicSubscription struct

+ AlertConfig *AlertConfiguration

+ FilterConfig *FilterConfiguration

+ Name string

+ RateLimitConfig *RateLimitConfiguration

+ RetryConfig *RetryConfiguration

+ type EndpointAuthentication struct

+ ApiKey *ApiKey

+ Type datastore.EndpointAuthenticationType

+ func (ea *EndpointAuthentication) Transform() *datastore.EndpointAuthentication

+ type EndpointResponse struct

+ type EventDeliveryResponse struct

+ type EventResponse struct

+ type FS struct

+ Body datastore.M

+ Headers datastore.M

+ func (fs *FS) Transform() datastore.FilterSchema

type FanoutEvent

+ IdempotencyKey string

+ func (fe *FanoutEvent) Validate() error

+ type FilterConfiguration struct

+ EventTypes pq.StringArray

+ Filter FS

+ func (fc *FilterConfiguration) Transform() *datastore.FilterConfiguration

type ForgotPassword

+ func (fp *ForgotPassword) Validate() error

+ type GooglePubSubConfig struct

+ ProjectID string

+ ServiceAccount []byte

+ SubscriptionID string

+ type HMac struct

+ Encoding datastore.EncodingType

+ Hash string

+ Header string

+ Secret string

+ 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 LoginUser

+ func (lu *LoginUser) Validate() error

+ type MetaEventConfiguration struct

+ EventType pq.StringArray

+ IsEnabled bool

+ Secret string

+ Type string

+ URL string

+ type MetaEventResponse struct

+ type OnPremStorage struct

+ Path null.String

+ type Pageable struct

+ Direction datastore.PageDirection

+ NextCursor string

+ PerPage int

+ PrevCursor string

type PortalLink

+ CanManageEndpoint bool

+ OwnerID string

type PortalLinkResponse

+ CanManageEndpoint bool

+ OwnerID string

+ type ProjectConfig struct

+ AddEventIDTraceHeaders bool

+ DisableEndpoint bool

+ IsRetentionPolicyEnabled bool

+ MaxIngestSize uint64

+ MetaEvent *MetaEventConfiguration

+ RateLimit *RateLimitConfiguration

+ ReplayAttacks bool

+ RetentionPolicy *RetentionPolicyConfiguration

+ Signature *SignatureConfiguration

+ Strategy *StrategyConfiguration

+ func (pc *ProjectConfig) Transform() *datastore.ProjectConfig

+ type ProjectResponse struct

+ func NewListProjectResponse(projects []*datastore.Project) []*ProjectResponse

+ type PubSubConfig struct

+ Google *GooglePubSubConfig

+ Kafka *KafkaPubSubConfig

+ Sqs *SQSPubSubConfig

+ Type datastore.PubSubType

+ Workers int

+ func (pc *PubSubConfig) Transform() *datastore.PubSubConfig

+ type QueryBatchReplayEvent struct

+ EndpointID string

+ SourceID string

+ func (qb *QueryBatchReplayEvent) Transform(r *http.Request) (*QueryBatchReplayEventResponse, error)

+ type QueryBatchReplayEventResponse struct

+ type QueryBatchRetryEventDelivery struct

+ EndpointIDs []string

+ EventID string

+ Status []string

+ SubscriptionID string

+ func (qb *QueryBatchRetryEventDelivery) Transform(r *http.Request) (*QueryBatchRetryEventDeliveryResponse, error)

+ type QueryBatchRetryEventDeliveryResponse struct

+ type QueryCountAffectedEventDeliveries struct

+ EndpointIDs []string

+ EventID string

+ Status []string

+ func (qc *QueryCountAffectedEventDeliveries) Transform(r *http.Request) (*QueryCountAffectedEventDeliveriesResponse, error)

+ type QueryCountAffectedEventDeliveriesResponse struct

+ type QueryCountAffectedEvents struct

+ EndpointID string

+ SourceID string

+ func (qc *QueryCountAffectedEvents) Transform(r *http.Request) (*QueryCountAffectedEventsResponse, error)

+ type QueryCountAffectedEventsResponse struct

+ type QueryListEndpoint struct

+ Name string

+ OwnerID string

+ func (q *QueryListEndpoint) Transform(r *http.Request) *QueryListEndpointResponse

+ type QueryListEndpointResponse struct

+ type QueryListEvent struct

+ EndpointIDs []string

+ IdempotencyKey string

+ Query string

+ SourceID string

+ func (qs *QueryListEvent) Transform(r *http.Request) (*QueryListEventResponse, error)

+ type QueryListEventDelivery struct

+ EndpointIDs []string

+ EventID string

+ IdempotencyKey string

+ Status []string

+ SubscriptionID string

+ func (ql *QueryListEventDelivery) Transform(r *http.Request) (*QueryListEventDeliveryResponse, error)

+ type QueryListEventDeliveryResponse struct

+ type QueryListEventResponse struct

+ type QueryListMetaEvent struct

+ func (ql *QueryListMetaEvent) Transform(r *http.Request) (*QueryListMetaEventResponse, error)

+ type QueryListMetaEventResponse struct

+ type QueryListSource struct

+ Provider string

+ Type string

+ func (ls *QueryListSource) Transform(r *http.Request) *QueryListSourceResponse

+ type QueryListSourceResponse struct

+ type QueryListSubscription struct

+ EndpointIDs []string

+ func (qs *QueryListSubscription) Transform(r *http.Request) *QueryListSubscriptionResponse

+ type QueryListSubscriptionResponse struct

+ type RateLimitConfiguration struct

+ Count int

+ Duration uint64

+ func (rc *RateLimitConfiguration) Transform() *datastore.RateLimitConfiguration

type RegisterUser

+ func (ru *RegisterUser) Validate() error

type ResetPassword

+ func (rp *ResetPassword) Validate() error

+ type RetentionPolicyConfiguration struct

+ Policy string

+ SearchPolicy string

type RetryConfiguration

+ func (rc *RetryConfiguration) Transform() (*datastore.RetryConfiguration, error)

+ type S3Storage struct

+ AccessKey null.String

+ Bucket null.String

+ Endpoint null.String

+ Region null.String

+ SecretKey null.String

+ SessionToken null.String

+ type SQSPubSubConfig struct

+ AccessKeyID string

+ DefaultRegion string

+ QueueName string

+ SecretKey string

+ type SearchParams struct

+ EndDate string

+ StartDate string

+ type SignatureConfiguration struct

+ Header config.SignatureHeaderProvider

+ Versions []SignatureVersion

+ type SignatureVersion struct

+ CreatedAt time.Time

+ Encoding string

+ Hash string

+ UID string

+ type StoragePolicyConfiguration struct

+ OnPrem *OnPremStorage

+ S3 *S3Storage

+ Type datastore.StorageType

+ func (sc *StoragePolicyConfiguration) Transform() *datastore.StoragePolicyConfiguration

+ type StrategyConfiguration struct

+ Duration uint64

+ RetryCount uint64

+ Type string

+ type SubscriptionFunctionResponse struct

+ Log []string

+ Payload interface{}

+ type SubscriptionResponse struct

+ type TestWebhookFunction struct

+ Function string

+ Payload map[string]interface{}

type Token

+ func (t *Token) Validate() error

+ type UpdateCustomResponse struct

+ Body *string

+ ContentType *string

type UpdateEndpoint

+ OwnerID string

+ func (uE *UpdateEndpoint) Validate() error

type UpdatePassword

+ func (u *UpdatePassword) Validate() error

type UpdateProject

+ func (uP *UpdateProject) Validate() error

type UpdateSource

+ CustomResponse UpdateCustomResponse

+ IdempotencyKeys []string

+ IdempotencyTTL string

+ func (us *UpdateSource) Validate() error

type UpdateSubscription

+ Function string

+ func (us *UpdateSubscription) Validate() error

type UpdateUser

+ func (u *UpdateUser) Validate() error

type UserExists

+ func (ue *UserExists) Validate() error

+ type UserResponse struct

+ type VerifierConfig struct

+ ApiKey *ApiKey

+ BasicAuth *BasicAuth

+ HMac *HMac

+ Type datastore.VerifierType

+ func (vc *VerifierConfig) Transform() *datastore.VerifierConfig

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

+ type APIKey struct

+ ExpiresAt null.Time

+ Name string

+ Role Role

+ Type datastore.KeyType

+ type APIKeyByIDResponse struct

+ CreatedAt time.Time

+ ExpiresAt null.Time

+ Name string

+ Role auth.Role

+ Type datastore.KeyType

+ UID string

+ UpdatedAt time.Time

+ type APIKeyResponse struct

+ CreatedAt time.Time

+ Key string

+ UID string

+ UserID string

+ type Configuration struct

+ IsAnalyticsEnabled *bool

+ IsSignupEnabled *bool

+ StoragePolicy *datastore.StoragePolicyConfiguration

+ type ConfigurationResponse struct

+ ApiVersion string

+ CreatedAt time.Time

+ DeletedAt null.Time

+ IsAnalyticsEnabled bool

+ IsSignupEnabled bool

+ StoragePolicy *datastore.StoragePolicyConfiguration

+ UID string

+ UpdatedAt time.Time

+ type CreateEndpointApiKey struct

+ BaseUrl string

+ Endpoint *datastore.Endpoint

+ Expiration int

+ KeyType datastore.KeyType

+ Name string

+ Project *datastore.Project

+ type CreateProjectResponse struct

+ APIKey *APIKeyResponse

+ Project *datastore.Project

+ type DashboardSummary struct

+ Applications int

+ EventsSent uint64

+ Period string

+ PeriodData *[]datastore.EventInterval

+ type DeliveryAttempt struct

+ APIVersion string

+ CreatedAt int64

+ IPAddress string

+ MessageID string

+ MessageResponse MessageResponse

+ Status string

+ type Endpoint struct

+ AdvancedSignatures bool

+ AppID string

+ Authentication *datastore.EndpointAuthentication

+ Description string

+ HttpTimeout string

+ IsDisabled bool

+ Name string

+ OwnerID string

+ RateLimit int

+ RateLimitDuration string

+ Secret string

+ SlackWebhookURL string

+ SupportEmail string

+ URL string

+ type Event struct

+ AppID string

+ CustomHeaders map[string]string

+ Data json.RawMessage

+ EndpointID string

+ EventType string

+ type ExpireSecret struct

+ Expiration int

+ Secret string

+ type FanoutEvent struct

+ CustomHeaders map[string]string

+ Data json.RawMessage

+ EventType string

+ OwnerID string

+ type FilterSchema struct

+ Body map[string]interface{}

+ Headers map[string]interface{}

+ type ForgotPassword struct

+ Email string

+ type IDs struct

+ IDs []string

+ type LoginUser struct

+ Password string

+ Username string

+ type LoginUserResponse struct

+ CreatedAt time.Time

+ Email string

+ EmailVerified bool

+ FirstName string

+ LastName string

+ Token Token

+ UID string

+ UpdatedAt time.Time

+ type MessageResponse struct

+ Data json.RawMessage

+ Status int

+ type Organisation struct

+ CustomDomain string

+ Name string

+ type OrganisationInvite struct

+ InviteeEmail string

+ Role auth.Role

+ type PersonalAPIKey struct

+ Expiration int

+ Name string

+ type PortalAPIKeyResponse struct

+ EndpointID string

+ Key string

+ ProjectID string

+ Role auth.Role

+ Type string

+ Url string

+ type PortalLink struct

+ Endpoints []string

+ Name string

+ type PortalLinkResponse struct

+ CreatedAt time.Time

+ DeletedAt null.Time

+ EndpointCount int

+ Endpoints []string

+ EndpointsMetadata datastore.EndpointMetadata

+ Name string

+ ProjectID string

+ Token string

+ UID string

+ URL string

+ UpdatedAt time.Time

+ type Project struct

+ Config *datastore.ProjectConfig

+ LogoURL string

+ Name string

+ Type datastore.ProjectType

+ type RegisterUser struct

+ Email string

+ FirstName string

+ LastName string

+ OrganisationName string

+ Password string

+ type ResetPassword struct

+ Password string

+ PasswordConfirmation string

+ type RetryConfiguration struct

+ Duration string

+ IntervalSeconds uint64

+ RetryCount uint64

+ Type datastore.StrategyProvider

+ type Role struct

+ App string

+ Project string

+ Type auth.RoleType

+ type Source struct

+ IsDisabled bool

+ Name string

+ Provider datastore.SourceProvider

+ PubSub datastore.PubSubConfig

+ Type datastore.SourceType

+ Verifier datastore.VerifierConfig

+ type SourceResponse struct

+ CreatedAt time.Time

+ DeletedAt null.Time

+ IsDisabled bool

+ MaskID string

+ Name string

+ ProjectID string

+ Provider datastore.SourceProvider

+ ProviderConfig *datastore.ProviderConfig

+ PubSub *datastore.PubSubConfig

+ Type datastore.SourceType

+ UID string

+ URL string

+ UpdatedAt time.Time

+ Verifier *datastore.VerifierConfig

+ type Subscription struct

+ AlertConfig *datastore.AlertConfiguration

+ AppID string

+ EndpointID string

+ FilterConfig *datastore.FilterConfiguration

+ Name string

+ RateLimitConfig *datastore.RateLimitConfiguration

+ RetryConfig *RetryConfiguration

+ SourceID string

+ type TestFilter struct

+ Request FilterSchema

+ Schema FilterSchema

+ type Token struct

+ AccessToken string

+ RefreshToken string

+ type UpdateEndpoint struct

+ AdvancedSignatures *bool

+ Authentication *datastore.EndpointAuthentication

+ Description string

+ HttpTimeout string

+ IsDisabled *bool

+ Name *string

+ RateLimit int

+ RateLimitDuration string

+ Secret string

+ SlackWebhookURL *string

+ SupportEmail *string

+ URL string

+ type UpdateOrganisationMember struct

+ Role auth.Role

+ type UpdatePassword struct

+ CurrentPassword string

+ Password string

+ PasswordConfirmation string

+ type UpdateProject struct

+ Config *datastore.ProjectConfig

+ LogoURL string

+ Name string

+ RateLimit int

+ RateLimitDuration string

+ type UpdateSource struct

+ ForwardHeaders []string

+ IsDisabled *bool

+ Name *string

+ PubSub *datastore.PubSubConfig

+ Type datastore.SourceType

+ Verifier datastore.VerifierConfig

+ type UpdateSubscription struct

+ AlertConfig *datastore.AlertConfiguration

+ AppID string

+ EndpointID string

+ FilterConfig *datastore.FilterConfiguration

+ Name string

+ RateLimitConfig *datastore.RateLimitConfiguration

+ RetryConfig *RetryConfiguration

+ SourceID string

+ type UpdateUser struct

+ Email string

+ FirstName string

+ LastName string

+ type User struct

+ Email string

+ FirstName string

+ LastName string

+ Password string

+ Role auth.Role

+ type UserExists struct

+ Email string

+ type UserInviteTokenResponse struct

+ Token *datastore.OrganisationInvite

+ User *datastore.User

+ type WebhookRequest struct

+ Data json.RawMessage

+ Event string

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