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)

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)