gateway

Documentation

Index

• type LocalGatewayService
  • func NewGateway(opts NewGatewayOpts) (*LocalGatewayService, error)
  • func (s *LocalGatewayService) GetApiAddresses() map[string]string
  • func (s *LocalGatewayService) GetBatchTriggerUrl(jobName 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
• type NewGatewayOpts
• type TLSCredentials

Types

type LocalGatewayService

type LocalGatewayService struct {
	ApiTlsCredentials *TLSCredentials

	gateway.UnimplementedGatewayPlugin
	// contains filtered or unexported fields
}

func NewGateway

func NewGateway(opts NewGatewayOpts) (*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

GetApiAddresses - Returns a map of API names to their addresses, including protocol and port

func (*LocalGatewayService) GetBatchTriggerUrl

func (s *LocalGatewayService) GetBatchTriggerUrl(jobName 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

type NewGatewayOpts

type NewGatewayOpts struct {
	TLSCredentials *TLSCredentials
	LogWriter      io.Writer
	LocalConfig    localconfig.LocalConfiguration
	BatchPlugin    *batch.LocalBatchService
}

type TLSCredentials

type TLSCredentials struct {
	// CertFile - Path to the certificate file
	CertFile string
	// KeyFile - Path to the private key file
	KeyFile string
}