integrations

Documentation

Index

• func CollectDestErrorStats(input []byte)
• func CollectIntgTransformErrorStats(input []byte)
• func FilterClientIntegrations(clientEvent types.SingularEventT, ...) (retVal []string)
• func ValidatePostInfo(transformRawParams PostParametersT) error
• type PostParametersT
• type TransResponseT
• type TransStatsT

Functions

func CollectDestErrorStats

func CollectDestErrorStats(input []byte)

func CollectIntgTransformErrorStats

func CollectIntgTransformErrorStats(input []byte)

func FilterClientIntegrations

func FilterClientIntegrations(clientEvent types.SingularEventT, destNameIDMap map[string]backendconfig.DestinationDefinitionT) (retVal []string)

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

func ValidatePostInfo

func ValidatePostInfo(transformRawParams PostParametersT) error

GetPostInfo parses the transformer response

Types

type PostParametersT

type PostParametersT struct {
	Type          string `json:"type"`
	URL           string `json:"endpoint"`
	RequestMethod string `json:"method"`
	// Invalid tag used in struct. skipcq: SCC-SA5008
	UserID      string                 `json:"userId,,optional"` //nolint:staticcheck
	Headers     map[string]interface{} `json:"headers"`
	QueryParams map[string]interface{} `json:"params"`
	Body        map[string]interface{} `json:"body"`
	Files       map[string]interface{} `json:"files"`
}

PostParametersT is a struct for holding all the values from transformerResponse and use them to publish an event to a destination optional is a custom tag introduced by us and is handled by GetMandatoryJSONFieldNames. Its intentionally added after two commas because the tag that comes after the first comma should be known by json parser

type TransResponseT

type TransResponseT struct {
	Message             string      `json:"message"`
	DestinationResponse interface{} `json:"destinationResponse"`
	AuthErrorCategory   string      `json:"authErrorCategory"`
}

type TransStatsT

type TransStatsT struct {
	StatTags map[string]string `json:"statTags"`
}