modelchange

Documentation

Index

• Variables
• func Handle(ctx context.Context, mc model.ClientSet) database.ListenHandler
• func TableNames() []string
• type Event
• type EventType
  • func (t EventType) String() string

Variables

var (
	// Catalog is the topic for model.Catalog.
	Catalog = topic.Topic(migrate.CatalogsTable.Name)
	// Connector is the topic for model.Connector.
	Connector = topic.Topic(migrate.ConnectorsTable.Name)
	// Resource is the topic for model.Resource.
	Resource = topic.Topic(migrate.ResourcesTable.Name)
	// ResourceComponent is the topic for model.ResourceComponent.
	ResourceComponent = topic.Topic(migrate.ResourceComponentsTable.Name)
	// ResourceRevision is the topic for model.ResourceRevision.
	ResourceRevision = topic.Topic(migrate.ResourceRevisionsTable.Name)
	// Template is the topic for model.Template.
	Template = topic.Topic(migrate.TemplatesTable.Name)
	// Workflow is the topic for model.Workflow.
	Workflow = topic.Topic(migrate.WorkflowsTable.Name)
	// WorkflowExecution is the topic for model.WorkflowExecution.
	WorkflowExecution = topic.Topic(migrate.WorkflowExecutionsTable.Name)
	// ResourceDefinition is the topic for model.ResourceDefinition.
	ResourceDefinition = topic.Topic(migrate.ResourceDefinitionsTable.Name)
)

Available topics, which is used for model change subscription.

Functions

func Handle

func Handle(ctx context.Context, mc model.ClientSet) database.ListenHandler

Handle returns an implementation of database.ListenHandler for handling the data changes.

func TableNames

func TableNames() []string

TableNames returns the name list of the interested tables for establishing.

Types

type Event

type Event struct {
	Type EventType
	IDs  []object.ID
}

Event indicates the event of model change, includes Type and changed IDs.

type EventType

type EventType uint8

EventType indicates the type of model change event.

const (
	EventTypeCreate EventType
	EventTypeUpdate
	EventTypeDelete
)

func (EventType) String

func (t EventType) String() string