metadata

Documentation

Index

• type Subscription
  • func (s *Subscription) Update(update *Subscription) bool
• type SubscriptionPhase
• type TriggerWorkerInfo
  • func NewTriggerWorkerInfo(addr string) *TriggerWorkerInfo
  • func (tw *TriggerWorkerInfo) String() string
• type TriggerWorkerPhase

Types

type Subscription

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:"-"`
}

func (*Subscription) Update

func (s *Subscription) Update(update *Subscription) bool

Update property change from api .

type SubscriptionPhase

type SubscriptionPhase string

const (
	SubscriptionPhaseCreated  SubscriptionPhase = "created"
	SubscriptionPhasePending  SubscriptionPhase = "pending"
	SubscriptionPhaseRunning  SubscriptionPhase = "running"
	SubscriptionPhaseStopping SubscriptionPhase = "stopping"
	SubscriptionPhaseStopped  SubscriptionPhase = "stopped"
	SubscriptionPhaseToDelete SubscriptionPhase = "toDelete"
)

type TriggerWorkerInfo

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

func NewTriggerWorkerInfo

func NewTriggerWorkerInfo(addr string) *TriggerWorkerInfo

func (*TriggerWorkerInfo) String

func (tw *TriggerWorkerInfo) String() string

type TriggerWorkerPhase

type TriggerWorkerPhase string

const (
	TriggerWorkerPhasePending    TriggerWorkerPhase = "pending"
	TriggerWorkerPhaseRunning    TriggerWorkerPhase = "running"
	TriggerWorkerPhasePaused     TriggerWorkerPhase = "paused"
	TriggerWorkerPhaseDisconnect TriggerWorkerPhase = "disconnect"
)