Versions in this module Expand all Collapse all v0 v0.9.0 Sep 7, 2023 Changes in this version + type TemplateConfig struct + Template string + Type TemplateType + func (tc *TemplateConfig) RecognizeTemplateType() (TemplateType, bool) + type TemplateType string + const TemplateTypeJSON + const TemplateTypeNone + const TemplateTypeText + const TemplateTypeUnspecified v0.8.0 Apr 17, 2023 Changes in this version + const DeadLetterReason + const DefaultNamespace + const DefaultUser + const LastDeliveryError + const LastDeliveryTime + const MaxRetryAttempts + const RetryEventbusName + const SystemEventbusNamePrefix + const SystemNamespace + const TimerEventbusName + const XVanus + const XVanusDeliveryTime + const XVanusEventbus + const XVanusRetryAttempts + const XVanusSubscriptionID + func FillSinkCredential(dst, src SinkCredential) + func GetDeadLetterEventbusName(eventbusID vanus.ID) string + func LoadConfig(filename string, config interface{}) error + type Action struct + Command []interface{} + type AkSkSinkCredential struct + AccessKeyID string + SecretAccessKey string + func (c *AkSkSinkCredential) GetType() CredentialType + type Closer interface + Close func(ctx context.Context) error + type CredentialType string + const AWS + const GCloud + const Plain + const SecretsMask + type GCloudSinkCredential struct + CredentialJSON string + func (c *GCloudSinkCredential) GetType() CredentialType + type Initializer interface + Initialize func(context.Context) error + type KvStorageConfig struct + KeyPrefix string + ServerList []string + type OffsetType int32 + const EarliestOffset + const LatestOffset + const Timestamp + type PlainSinkCredential struct + Identifier string + Secret string + func (c *PlainSinkCredential) GetType() CredentialType + type Protocol string + const AwsLambdaProtocol + const GCloudFunctions + const GRPC + const HTTPProtocol + type ProtocolSetting struct + Headers map[string]string + type ServerState string + const ServerStateCreated + const ServerStateRunning + const ServerStateStarted + const ServerStateStopped + const ServerStateStopping + type SinkCredential interface + GetType func() CredentialType + func NewAkSkSinkCredential(accessKeyID, secretAccessKey string) SinkCredential + func NewGCloudSinkCredential(credentialJSON string) SinkCredential + func NewPlainSinkCredential(identifier, secret string) SinkCredential + type Subscription struct + Config SubscriptionConfig + DeadLetterEventbusID vanus.ID + EventbusID vanus.ID + Filters SubscriptionFilterList + ID vanus.ID + Offsets info.ListOffsetInfo + Protocol Protocol + ProtocolSetting *ProtocolSetting + RetryEventbusID vanus.ID + Sink URI + SinkCredential SinkCredential + TimerEventbusID vanus.ID + Transformer *Transformer + func (sub *Subscription) String() string + type SubscriptionConfig struct + DeliveryTimeout uint32 + DisableDeadLetter bool + MaxRetryAttempts *uint32 + OffsetTimestamp *uint64 + OffsetType OffsetType + OrderedEvent bool + RateLimit uint32 + func (c *SubscriptionConfig) GetMaxRetryAttempts() int32 + func (c *SubscriptionConfig) String() string + type SubscriptionFilter struct + All SubscriptionFilterList + Any SubscriptionFilterList + CEL string + CeSQL string + Exact map[string]string + Not *SubscriptionFilter + Prefix map[string]string + Suffix map[string]string + type SubscriptionFilterList []*SubscriptionFilter + func (l SubscriptionFilterList) String() string + type Transformer struct + Define map[string]string + Pipeline []*Action + Template string + func (t *Transformer) Exist() bool + func (t *Transformer) String() string + type URI string
Go to main page