events_service

Documentation

Index

• func New() (events.EventService, error)
• func NewWithClientAndSubs(client LocalHttpeventsClient, subs map[string][]string) (events.EventService, error)
• type LocalEventService
  • func (s *LocalEventService) ListTopics() ([]string, error)
  • func (s *LocalEventService) Publish(topic string, event *events.NitricEvent) error
• type LocalHttpeventsClient

Functions

func New

func New() (events.EventService, error)

Create new Dev EventService

func NewWithClientAndSubs

func NewWithClientAndSubs(client LocalHttpeventsClient, subs map[string][]string) (events.EventService, error)

Types

type LocalEventService

type LocalEventService struct {
	events.UnimplementedeventsPlugin
	// contains filtered or unexported fields
}

func (*LocalEventService) ListTopics

func (s *LocalEventService) ListTopics() ([]string, error)

Get a list of available topics

func (*LocalEventService) Publish

func (s *LocalEventService) Publish(topic string, event *events.NitricEvent) error

Publish a message to a given topic

type LocalHttpeventsClient

type LocalHttpeventsClient interface {
	Do(req *http.Request) (*http.Response, error)
}

Interface for methods utilised by The local pubsub plugin for http events