pubsub

package
v0.8.4 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 28, 2024 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	PubsubNotifyFunction               = "notify"
	PubsubDisconnectFunction           = "disconnect"
	PubsubDeleteTimerFunction          = "deleteTimer"
	PubsubDeleteInstanceTimersFunction = "deleteInstanceTimers"
	PubsubDeleteActivityTimersFunction = "deleteActivityTimers"
	PubsubCancelWorkflowFunction       = "cancelWorkflow"
	PubsubConfigureRouterFunction      = "configureRouter"
	FlowSync                           = "flowsync"
	PubsubCancelMirrorProcessFunction  = "cancelMirrorProcess"
)

Variables

This section is empty.

Functions

This section is empty.

Types

type ConfigureRouterMessage 

type ConfigureRouterMessage struct {
	ID   string
	Cron string
}

type Notifier 

type Notifier interface {
	NotifyCluster(msg string) error
	NotifyHostname(hostname string, msg string) error
}

type Pubsub 

type Pubsub struct {
	Hostname string
	// contains filtered or unexported fields
}

func InitPubSub 

func InitPubSub(notifier Notifier, database string) (*Pubsub, error)

func (*Pubsub) CancelMirrorProcess 

func (pubsub *Pubsub) CancelMirrorProcess(id uuid.UUID)

func (*Pubsub) CancelWorkflow 

func (pubsub *Pubsub) CancelWorkflow(id, code, message string, soft bool)

func (*Pubsub) Close 

func (pubsub *Pubsub) Close() error

func (*Pubsub) CloseNamespace 

func (pubsub *Pubsub) CloseNamespace(ns *database.Namespace)

func (*Pubsub) ClusterDeleteActivityTimers 

func (pubsub *Pubsub) ClusterDeleteActivityTimers(name string)

func (*Pubsub) ClusterDeleteInstanceTimers 

func (pubsub *Pubsub) ClusterDeleteInstanceTimers(name string)

func (*Pubsub) ClusterDeleteTimer 

func (pubsub *Pubsub) ClusterDeleteTimer(name string)

func (*Pubsub) ConfigureRouterCron 

func (pubsub *Pubsub) ConfigureRouterCron(id, cron string)

func (*Pubsub) Disconnect 

func (pubsub *Pubsub) Disconnect(req *PubsubUpdate)

func (*Pubsub) HostnameDeleteTimer 

func (pubsub *Pubsub) HostnameDeleteTimer(hostname, name string)

func (*Pubsub) Notify 

func (pubsub *Pubsub) Notify(req *PubsubUpdate)

func (*Pubsub) NotifyEventListeners 

func (pubsub *Pubsub) NotifyEventListeners(id uuid.UUID)

func (*Pubsub) NotifyEvents 

func (pubsub *Pubsub) NotifyEvents(ns *database.Namespace)

func (*Pubsub) NotifyInstance 

func (pubsub *Pubsub) NotifyInstance(id uuid.UUID)

func (*Pubsub) NotifyInstanceVariables 

func (pubsub *Pubsub) NotifyInstanceVariables(id uuid.UUID)

func (*Pubsub) NotifyInstances 

func (pubsub *Pubsub) NotifyInstances(ns *database.Namespace)

func (*Pubsub) NotifyLogs 

func (pubsub *Pubsub) NotifyLogs(recipientID uuid.UUID, recipientType recipient.RecipientType)

func (*Pubsub) NotifyNamespaceVariables 

func (pubsub *Pubsub) NotifyNamespaceVariables(nsID uuid.UUID)

func (*Pubsub) NotifyNamespaces 

func (pubsub *Pubsub) NotifyNamespaces()

func (*Pubsub) NotifyWorkflowVariables 

func (pubsub *Pubsub) NotifyWorkflowVariables(id uuid.UUID)

func (*Pubsub) Publish 

func (pubsub *Pubsub) Publish(req *PubsubUpdate)

func (*Pubsub) RegisterFunction 

func (pubsub *Pubsub) RegisterFunction(name string, fn func(*PubsubUpdate))

func (*Pubsub) Subscribe 

func (pubsub *Pubsub) Subscribe(id ...string) *Subscription

func (*Pubsub) SubscribeEventListeners 

func (pubsub *Pubsub) SubscribeEventListeners(ns *database.Namespace) *Subscription

func (*Pubsub) SubscribeEvents 

func (pubsub *Pubsub) SubscribeEvents(ns *database.Namespace) *Subscription

func (*Pubsub) SubscribeInstance 

func (pubsub *Pubsub) SubscribeInstance(instID uuid.UUID) *Subscription

func (*Pubsub) SubscribeInstanceLogs 

func (pubsub *Pubsub) SubscribeInstanceLogs(instID uuid.UUID) *Subscription

func (*Pubsub) SubscribeInstanceVariables 

func (pubsub *Pubsub) SubscribeInstanceVariables(instID uuid.UUID) *Subscription

func (*Pubsub) SubscribeInstances 

func (pubsub *Pubsub) SubscribeInstances(ns *database.Namespace) *Subscription

func (*Pubsub) SubscribeMirrorActivityLogs 

func (pubsub *Pubsub) SubscribeMirrorActivityLogs(namespaceID uuid.UUID, mirrorProcessID uuid.UUID) *Subscription

func (*Pubsub) SubscribeNamespaceLogs 

func (pubsub *Pubsub) SubscribeNamespaceLogs(ns uuid.UUID) *Subscription

func (*Pubsub) SubscribeNamespaceVariables 

func (pubsub *Pubsub) SubscribeNamespaceVariables(ns *database.Namespace) *Subscription

func (*Pubsub) SubscribeNamespaces 

func (pubsub *Pubsub) SubscribeNamespaces() *Subscription

func (*Pubsub) SubscribeServerLogs 

func (pubsub *Pubsub) SubscribeServerLogs() *Subscription

func (*Pubsub) SubscribeWorkflowLogs 

func (pubsub *Pubsub) SubscribeWorkflowLogs(id uuid.UUID) *Subscription

func (*Pubsub) SubscribeWorkflowVariables 

func (pubsub *Pubsub) SubscribeWorkflowVariables(id uuid.UUID) *Subscription

type PubsubUpdate 

type PubsubUpdate struct {
	Handler  string
	Sender   string
	Key      string
	Hostname string
}

type Subscription 

type Subscription struct {
	// contains filtered or unexported fields
}

func (*Subscription) Close 

func (s *Subscription) Close() error

func (*Subscription) Wait 

func (s *Subscription) Wait(ctx context.Context) bool

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.