integrations

Documentation

Index

• Constants
• func GetDestinationIDs(clientEvent interface{}, ...) (retVal []string)
• func GetDestinationURL(destID string) string
• func GetResponseVersion(response json.RawMessage) string
• func GetUserIDForStreamDestination(jsonData json.RawMessage) string
• func GetUserIDFromTransformerResponse(transformRaw json.RawMessage, destination string) string
• func GetUserTransformURL(processSessions bool) string
• type PostParameterNewT
  • func GetPostInfoNew(transformRaw json.RawMessage) PostParameterNewT
• type PostParameterT
  • func GetPostInfo(transformRaw json.RawMessage) PostParameterT

Constants

const (
	//PostDataKV means post data is sent as KV
	PostDataKV = iota + 1
	//PostDataJSON means post data is sent as JSON
	PostDataJSON
	//PostDataXML means post data is sent as XML
	PostDataXML
)

Functions

func GetDestinationIDs

func GetDestinationIDs(clientEvent interface{}, destNameIDMap map[string]backendconfig.DestinationDefinitionT) (retVal []string)

GetDestinationIDs parses the destination names from the input JSON, matches them with enabled destinations from controle plane and returns the IDSs

func GetDestinationURL

func GetDestinationURL(destID string) string

GetDestinationURL returns node URL

func GetResponseVersion

func GetResponseVersion(response json.RawMessage) string

GetResponseVersion Get version of the transformer response

func GetUserIDForStreamDestination

func GetUserIDForStreamDestination(jsonData json.RawMessage) string

GetUserIDForStreamDestination parses the payload to get userId

func GetUserIDFromTransformerResponse

func GetUserIDFromTransformerResponse(transformRaw json.RawMessage, destination string) string

GetUserIDFromTransformerResponse parses the payload to get userId

func GetUserTransformURL

func GetUserTransformURL(processSessions bool) string

GetUserTransformURL returns the port of running user transform

Types

type PostParameterNewT

type PostParameterNewT struct {
	Type          string
	URL           string
	RequestMethod string
	UserID        string
	Headers       interface{}
	QueryParams   interface{}
	Body          interface{}
	Files         interface{}
}

PostParameterNewT emulates parameters needed tp make a request

func GetPostInfoNew

func GetPostInfoNew(transformRaw json.RawMessage) PostParameterNewT

GetPostInfoNew parses the transformer response

type PostParameterT

type PostParameterT struct {
	URL           string
	Type          int
	UserID        string
	Payload       interface{}
	Header        interface{}
	RequestConfig interface{}
}

PostParameterT has post related parameters, the URL and the data type

func GetPostInfo

func GetPostInfo(transformRaw json.RawMessage) PostParameterT

GetPostInfo provides the post parameters for this destination