pulsar

Documentation

Index

• Constants
• type IHourPulsar
  • func HourPulsar() IHourPulsar
• type IMinutePulsar
  • func MinutePulsar() IMinutePulsar
• type IPulsar
  • func NewPulsar(name string, topic string, interval time.Duration) IPulsar
• type ISecondPulsar
  • func SecondPulsar() ISecondPulsar
• type OnPulseFunc

Constants

const (
	OnSecond = "pulsar.OnSecond"
	OnMinute = "pulsar.OnMinute"
	OnHour   = "pulsar.OnHour"
)

Types

type IHourPulsar

type IHourPulsar interface {
	IPulsar
}

func HourPulsar

func HourPulsar() IHourPulsar

type IMinutePulsar

type IMinutePulsar interface {
	IPulsar
}

func MinutePulsar

func MinutePulsar() IMinutePulsar

type IPulsar

type IPulsar interface {
	comps.ISpokePlugin
	IAmPulsar()
}

IPulsar is an active component that triggers a pulse at a certain interval and publishes it onto the Mediator.

func NewPulsar

func NewPulsar(name string, topic string, interval time.Duration) IPulsar

type ISecondPulsar

type ISecondPulsar interface {
	IPulsar
}

func SecondPulsar

func SecondPulsar() ISecondPulsar

type OnPulseFunc

type OnPulseFunc func(ctx context.Context) error