Versions in this module Expand all Collapse all v0 v0.9.0 Sep 7, 2023 v0.8.0 Apr 17, 2023 Changes in this version + type Subscription struct + Config primitive.SubscriptionConfig + CreatedAt time.Time + DeadLetterEventbusID vanus.ID + Description string + EventbusID vanus.ID + Filters []*primitive.SubscriptionFilter + HeartbeatTime time.Time + ID vanus.ID + Name string + NamespaceID vanus.ID + Phase SubscriptionPhase + Protocol primitive.Protocol + ProtocolSetting *primitive.ProtocolSetting + RetryEventbusID vanus.ID + Sink primitive.URI + SinkCredential primitive.SinkCredential + SinkCredentialType *primitive.CredentialType + Source string + TimerEventbusID vanus.ID + Transformer *primitive.Transformer + TriggerWorker string + Types []string + UpdatedAt time.Time + func (s *Subscription) Update(update *Subscription) bool + type SubscriptionPhase string + const SubscriptionPhaseCreated + const SubscriptionPhasePending + const SubscriptionPhaseRunning + const SubscriptionPhaseStopped + const SubscriptionPhaseStopping + const SubscriptionPhaseToDelete + type TriggerWorkerInfo struct + Addr string + ID string + Phase TriggerWorkerPhase + func NewTriggerWorkerInfo(addr string) *TriggerWorkerInfo + func (tw *TriggerWorkerInfo) String() string + type TriggerWorkerPhase string + const TriggerWorkerPhaseDisconnect + const TriggerWorkerPhasePaused + const TriggerWorkerPhasePending + const TriggerWorkerPhaseRunning