utils

Documentation

Index

• func DiffDynamoItems(dynamoItems []string, atrsToTrigger []string, accountId string) ([]string, error)
• func GetAtrsFromDynamo(accountId, tableName string, atrs []string, client *goKitDynamo.Client) ([]string, error)
• func GetK8sIntegrationIds(accountId string, uids []string, kinds []string, client *elasticsearch.Client, ...) ([]string, error)
• func ToJsonLines(nodes []map[string]interface{}) (jsonLines []byte, err error)
• func WriteAtrsToDynamo(accountId, tableName string, atrs []string, dynamoTTL int, ...) error
• func WriteFile(cfg *config.Config, path string, content []byte, fileType string) (err error)

Functions

func DiffDynamoItems

func DiffDynamoItems(dynamoItems []string, atrsToTrigger []string, accountId string) ([]string, error)

func GetAtrsFromDynamo

func GetAtrsFromDynamo(accountId, tableName string, atrs []string, client *goKitDynamo.Client) ([]string, error)

func GetK8sIntegrationIds

func GetK8sIntegrationIds(accountId string, uids []string, kinds []string, client *elasticsearch.Client, logger *zerolog.Logger) ([]string, error)

func ToJsonLines

func ToJsonLines(nodes []map[string]interface{}) (jsonLines []byte, err error)

func WriteAtrsToDynamo

func WriteAtrsToDynamo(accountId, tableName string, atrs []string, dynamoTTL int, client *goKitDynamo.Client) error

func WriteFile

func WriteFile(cfg *config.Config, path string, content []byte, fileType string) (err error)