api

Documentation

Index

• func InitKafkaConsumerRouter(svc *handlers.KafkaConsumerService) func(m *kafka.Message) error
• func InitNatsResponderRouter(svc *handlers.NatsReqReplyService) func(m *nats.Msg) (string, error)
• func InitRouter(svc *handlers.HTTPHandlerService, r *gin.Engine) *gin.Engine
• func InitScheduledJobsRouter(svc *handlers.InAppScheduledJobService)
• func NewGinHTTPServer(lc fx.Lifecycle, svc *handlers.HTTPHandlerService) *http.Server
• type InAppScheduledJobsState
  • func NewInAppJobsStarter(lc fx.Lifecycle, svc *handlers.InAppScheduledJobService) *InAppScheduledJobsState
• type KafkaConsumerListenerState
  • func NewKafkaConsumerServer(lc fx.Lifecycle, svc *handlers.KafkaConsumerService) *KafkaConsumerListenerState
• type NatsResponderState
  • func NewNatsResponderServer(lc fx.Lifecycle, svc *handlers.NatsReqReplyService) *NatsResponderState
• type RespondJson

Functions

func InitKafkaConsumerRouter

func InitKafkaConsumerRouter(svc *handlers.KafkaConsumerService) func(m *kafka.Message) error

func InitNatsResponderRouter

func InitNatsResponderRouter(svc *handlers.NatsReqReplyService) func(m *nats.Msg) (string, error)

func InitRouter

func InitRouter(svc *handlers.HTTPHandlerService, r *gin.Engine) *gin.Engine

func InitScheduledJobsRouter

func InitScheduledJobsRouter(svc *handlers.InAppScheduledJobService)

func NewGinHTTPServer

func NewGinHTTPServer(lc fx.Lifecycle, svc *handlers.HTTPHandlerService) *http.Server

Types

type InAppScheduledJobsState

type InAppScheduledJobsState struct {
	IsStarted bool
	// contains filtered or unexported fields
}

func NewInAppJobsStarter

func NewInAppJobsStarter(lc fx.Lifecycle, svc *handlers.InAppScheduledJobService) *InAppScheduledJobsState

type KafkaConsumerListenerState

type KafkaConsumerListenerState struct {
	IsStarted bool
	// contains filtered or unexported fields
}

func NewKafkaConsumerServer

func NewKafkaConsumerServer(lc fx.Lifecycle, svc *handlers.KafkaConsumerService) *KafkaConsumerListenerState

type NatsResponderState

type NatsResponderState struct {
	IsStarted bool
	// contains filtered or unexported fields
}

func NewNatsResponderServer

func NewNatsResponderServer(lc fx.Lifecycle, svc *handlers.NatsReqReplyService) *NatsResponderState

type RespondJson

type RespondJson struct {
	Status  bool        `json:"status"`
	Intent  string      `json:"intent"`
	Message interface{} `json:"message"`
}