events

Documentation

Index

• type CloudEventsStreamer
  • func NewCloudEventsStreamer() *CloudEventsStreamer
  • func (e *CloudEventsStreamer) Publish(event cloudevents.Event)
  • func (e *CloudEventsStreamer) Stop()
  • func (e *CloudEventsStreamer) Subscribe(ch chan cloudevents.Event)
  • func (e *CloudEventsStreamer) Unsubscribe(ch chan cloudevents.Event)
• type EventStreamer

Types

type CloudEventsStreamer

type CloudEventsStreamer struct {
	// contains filtered or unexported fields
}

func NewCloudEventsStreamer

func NewCloudEventsStreamer() *CloudEventsStreamer

func (*CloudEventsStreamer) Publish

func (e *CloudEventsStreamer) Publish(event cloudevents.Event)

func (*CloudEventsStreamer) Stop

func (e *CloudEventsStreamer) Stop()

func (*CloudEventsStreamer) Subscribe

func (e *CloudEventsStreamer) Subscribe(ch chan cloudevents.Event)

func (*CloudEventsStreamer) Unsubscribe

func (e *CloudEventsStreamer) Unsubscribe(ch chan cloudevents.Event)

type EventStreamer

type EventStreamer interface {
	Subscribe(ch chan cloudevents.Event)
	Unsubscribe(ch chan cloudevents.Event)
	Publish(event cloudevents.Event)
	Stop()
}