eventing

package
v1.1.386 Latest Latest
Warning

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

Go to latest
Published: Oct 29, 2019 License: MIT Imports: 3 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Publish added in v1.1.307

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 added in v1.1.307

func SubscribeToTopic(topic string) chan interface{}

SubscribeToTopic creates a channel which will receive event in that topic

func Unsubscribe added in v1.1.170

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 (*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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL