sender

Documentation

Index

• Variables
• func RegisterChangeUpdate(id string, changeChannel chan interface{}) error
• func RunGlobalSender()
• func SendChangeUpdate(id string, changeNotify *change.ChangeNotify)
• func SendDeleteObject(id string, deleteObject id.Identifiable)
• func SendNewObject(id string, newObject id.Identifiable)
• type Sender
  • func NewSender(userUuid, portfolioUuid string) *Sender
  • func (s *Sender) CloseOutput(ch chan interface{})
  • func (s *Sender) GetOutput() chan interface{}
  • func (s *Sender) RegisterUpdateInput(ch chan interface{})
  • func (s *Sender) Stop()

Variables

var GlobalMessages = duplicator.MakeDuplicator("global-messages")

Functions

func RegisterChangeUpdate

func RegisterChangeUpdate(id string, changeChannel chan interface{}) error

func RunGlobalSender

func RunGlobalSender()

func SendChangeUpdate

func SendChangeUpdate(id string, changeNotify *change.ChangeNotify)

func SendDeleteObject

func SendDeleteObject(id string, deleteObject id.Identifiable)

func SendNewObject

func SendNewObject(id string, newObject id.Identifiable)

Types

type Sender

type Sender struct {
	NewObjects    *duplicator.ChannelDuplicator
	Updates       *duplicator.ChannelDuplicator
	Notifications *duplicator.ChannelDuplicator
	Deletes       *duplicator.ChannelDuplicator
	Output        *duplicator.ChannelDuplicator
	// contains filtered or unexported fields
}

func NewSender

func NewSender(userUuid, portfolioUuid string) *Sender

func (*Sender) CloseOutput

func (s *Sender) CloseOutput(ch chan interface{})

func (*Sender) GetOutput

func (s *Sender) GetOutput() chan interface{}

func (*Sender) RegisterUpdateInput

func (s *Sender) RegisterUpdateInput(ch chan interface{})

func (*Sender) Stop

func (s *Sender) Stop()