bus

Documentation

Index

• type Bus
  • func New() *Bus
• type Channel
  • func (c *Channel[T]) Publish(msg T)
  • func (c *Channel[T]) Subscribe(handler func(T))
• type DatabaseUpdateMsg
• type DatabaseUpdateType
• type JobMsg
• type RequestMsg
• type ResultMsg

Types

type Bus

type Bus struct {
	ResultChannel   *Channel[*ResultMsg]
	RequestChannel  *Channel[*RequestMsg]
	JobChannel      *Channel[*JobMsg]
	DatabaseChannel *Channel[*DatabaseUpdateMsg]
}

func New

func New() *Bus

type Channel

type Channel[T any] struct {
	Subscriber []func(T)
}

func (*Channel[T]) Publish

func (c *Channel[T]) Publish(msg T)

func (*Channel[T]) Subscribe

func (c *Channel[T]) Subscribe(handler func(T))

type DatabaseUpdateMsg

type DatabaseUpdateMsg struct {
	IDs  []driver.DocumentID `json:"ids"`
	Type DatabaseUpdateType  `json:"type"`
}

type DatabaseUpdateType

type DatabaseUpdateType string

const (
	DatabaseEntryRead    DatabaseUpdateType = "read"
	DatabaseEntryCreated DatabaseUpdateType = "created"
	DatabaseEntryUpdated DatabaseUpdateType = "updated"
)

type JobMsg

type JobMsg struct {
	ID         string         `json:"id"`
	Automation string         `json:"automation"`
	Origin     *model.Origin  `json:"origin"`
	Message    *model.Message `json:"message"`
}

type RequestMsg

type RequestMsg struct {
	IDs      []driver.DocumentID `json:"ids"`
	Function string              `json:"function"`
	User     string              `json:"user"`
}

type ResultMsg

type ResultMsg struct {
	Automation string         `json:"automation"`
	Data       map[string]any `json:"data,omitempty"`
	Target     *model.Origin  `json:"target"`
}