gateway

Documentation

Index

• Constants
• Variables
• func GetStringifiedData(data interface{}) string
• type HandleT
  • func (gateway *HandleT) ProcessAgentRequest(payload string, writeKey string) string
  • func (gateway *HandleT) ProcessRequest(c *gin.Context, reqType string)
  • func (gateway *HandleT) ProcessWorkerRequest(payload []byte, writeKey string)
  • func (gateway *HandleT) Setup(jobsDB *jobsdb.HandleT, routerJobsDB *jobsdb.HandleT, ...)

Constants

const (
	DELIMITER = string("<<>>")
)

Variables

var BatchEvent = []byte(`
	{
		"batch": [
		]
	}
`)

var CustomVal string

Functions

func GetStringifiedData

func GetStringifiedData(data interface{}) string

Types

type HandleT

type HandleT struct {
	// contains filtered or unexported fields
}

func (*HandleT) ProcessAgentRequest

func (gateway *HandleT) ProcessAgentRequest(payload string, writeKey string) string

func (*HandleT) ProcessRequest

func (gateway *HandleT) ProcessRequest(c *gin.Context, reqType string)

func (*HandleT) ProcessWorkerRequest

func (gateway *HandleT) ProcessWorkerRequest(payload []byte, writeKey string)

func (*HandleT) Setup

func (gateway *HandleT) Setup(jobsDB *jobsdb.HandleT, routerJobsDB *jobsdb.HandleT, configDB *backendconfig.HandleT)