gateway

Documentation

Index

• type LocalGatewayService
  • func NewGateway() (*LocalGatewayService, error)
  • func (s *LocalGatewayService) GetApiAddresses() map[string]string
  • func (s *LocalGatewayService) GetHttpWorkerAddresses() map[string]string
  • func (s *LocalGatewayService) GetScheduleManualTriggerUrl(scheduleName string) string
  • func (s *LocalGatewayService) GetTopicTriggerUrl(topicName string) string
  • func (s *LocalGatewayService) GetTriggerAddress() string
  • func (s *LocalGatewayService) GetWebsocketAddresses() map[string]string
  • func (s *LocalGatewayService) Start(opts *gateway.GatewayStartOpts) error
  • func (s *LocalGatewayService) Stop() error

Types

type LocalGatewayService

type LocalGatewayService struct {
	gateway.UnimplementedGatewayPlugin
	// contains filtered or unexported fields
}

func NewGateway

func NewGateway() (*LocalGatewayService, error)

Create new HTTP gateway XXX: No External Args for function atm (currently the plugin loader does not pass any argument information)

func (*LocalGatewayService) GetApiAddresses

func (s *LocalGatewayService) GetApiAddresses() map[string]string

func (*LocalGatewayService) GetHttpWorkerAddresses

func (s *LocalGatewayService) GetHttpWorkerAddresses() map[string]string

func (*LocalGatewayService) GetScheduleManualTriggerUrl

func (s *LocalGatewayService) GetScheduleManualTriggerUrl(scheduleName string) string

func (*LocalGatewayService) GetTopicTriggerUrl

func (s *LocalGatewayService) GetTopicTriggerUrl(topicName string) string

func (*LocalGatewayService) GetTriggerAddress

func (s *LocalGatewayService) GetTriggerAddress() string

GetTriggerAddress - Returns the base address built-in nitric services, like schedules and topics, will be exposed on.

func (*LocalGatewayService) GetWebsocketAddresses

func (s *LocalGatewayService) GetWebsocketAddresses() map[string]string

func (*LocalGatewayService) Start

func (s *LocalGatewayService) Start(opts *gateway.GatewayStartOpts) error

func (*LocalGatewayService) Stop

func (s *LocalGatewayService) Stop() error