metadata

type Subscription struct {
	ID                 vanus.ID                        `json:"id"`
	Source             string                          `json:"source,omitempty"`
	Types              []string                        `json:"types,omitempty"`
	Config             primitive.SubscriptionConfig    `json:"config,omitempty"`
	Filters            []*primitive.SubscriptionFilter `json:"filters,omitempty"`
	Sink               primitive.URI                   `json:"sink,omitempty"`
	SinkCredentialType *primitive.CredentialType       `json:"sink_credential_type,omitempty"`
	SinkCredential     primitive.SinkCredential        `json:"-"`
	Protocol           primitive.Protocol              `json:"protocol,omitempty"`
	ProtocolSetting    *primitive.ProtocolSetting      `json:"protocol_settings,omitempty"`
	EventbusID         vanus.ID                        `json:"eventbus_id"`
	NamespaceID        vanus.ID                        `json:"namespace_id"`
	Transformer        *primitive.Transformer          `json:"transformer,omitempty"`
	Name               string                          `json:"name"`
	Description        string                          `json:"description"`
	CreatedAt          time.Time                       `json:"created_at"`
	UpdatedAt          time.Time                       `json:"updated_at"`

	// not from api
	DeadLetterEventbusID vanus.ID          `json:"dead_letter_eventbus_id"`
	RetryEventbusID      vanus.ID          `json:"retry_eventbus_id"`
	TimerEventbusID      vanus.ID          `json:"timer_eventbus_id"`
	Phase                SubscriptionPhase `json:"phase"`
	TriggerWorker        string            `json:"trigger_worker,omitempty"`
	HeartbeatTime        time.Time         `json:"-"`
}

type SubscriptionPhase string

type TriggerWorkerInfo struct {
	ID    string             `json:"-"`
	Addr  string             `json:"addr"`
	Phase TriggerWorkerPhase `json:"phase"`
}

type TriggerWorkerPhase string