eventing_service

Documentation

Index

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

Functions

func New

func New() (sdk.EventService, error)

Create new Dev EventService

func NewWithClientAndSubs

func NewWithClientAndSubs(client LocalHttpEventingClient, subs map[string][]string) (sdk.EventService, error)

Types

type LocalEventService

type LocalEventService struct {
	sdk.UnimplementedEventingPlugin
	// 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 *sdk.NitricEvent) error

Publish a message to a given topic

type LocalHttpEventingClient

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

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