eventing

Documentation

Index

• func Publish(topic string, event interface{})
• func SubscribeToStatusEvents() chan interface{}
• func SubscribeToTopic(topic string) chan interface{}
• func Unsubscribe(ch chan interface{})
• type StatusEvent
  • func SendStatusEvent(s StatusEvent) (StatusEvent, func())
  • func WaitForCompletedStatusEvent(t *testing.T, statusEvents chan interface{}, waitForSec int) StatusEvent
  • func WaitForFailureStatusEvent(t *testing.T, statusEvents chan interface{}, waitForSec int) StatusEvent
  • func WaitForStatusEvent(t *testing.T, statusEvents chan interface{}, waitForSec int, expectError bool) StatusEvent
  • func (s *StatusEvent) CreatedAt() time.Time
  • func (s *StatusEvent) HasExpired() bool
  • func (s *StatusEvent) ID() string
  • func (s *StatusEvent) Update()

Functions

func Publish

func Publish(topic string, event interface{})

Publish publishes any event

func SubscribeToStatusEvents

func SubscribeToStatusEvents() chan interface{}

SubscribeToStatusEvents creates a channel which will receive new `StatusEvent` types

func SubscribeToTopic

func SubscribeToTopic(topic string) chan interface{}

SubscribeToTopic creates a channel which will receive event in that topic WARNING: Subscribers MUST process events QUICKLY when received or the event sender will BLOCK this results in the UI locking up.

func Unsubscribe

func Unsubscribe(ch chan interface{})

Unsubscribe from events

Types

type StatusEvent

type StatusEvent struct {
	Message string
	Timeout time.Duration

	InProgress bool
	Failure    bool
	// contains filtered or unexported fields
}

StatusEvent is used to show status information in the statusbar

func SendStatusEvent

func SendStatusEvent(s StatusEvent) (StatusEvent, func())

SendStatusEvent sends status events

func WaitForCompletedStatusEvent

func WaitForCompletedStatusEvent(t *testing.T, statusEvents chan interface{}, waitForSec int) StatusEvent

WaitForCompletedStatusEvent waits for a completed event

func WaitForFailureStatusEvent

func WaitForFailureStatusEvent(t *testing.T, statusEvents chan interface{}, waitForSec int) StatusEvent

WaitForFailureStatusEvent waits for failure event

func WaitForStatusEvent

func WaitForStatusEvent(t *testing.T, statusEvents chan interface{}, waitForSec int, expectError bool) StatusEvent

WaitForStatusEvent lets you wait on a event

func (*StatusEvent) CreatedAt

func (s *StatusEvent) CreatedAt() time.Time

CreatedAt returns the time of the message creation

func (*StatusEvent) HasExpired

func (s *StatusEvent) HasExpired() bool

HasExpired returns true if the message has expired

func (*StatusEvent) ID

func (s *StatusEvent) ID() string

ID returns the status message ID

func (*StatusEvent) Update

func (s *StatusEvent) Update()

Update sends and update to the status event