common

Documentation

Index

• func GetAwsConfig() (*aws.Config, error)
• func HandleHTTPRequest(message string, headers http.Header, data ConnectorMetadata, ...) (*http.Response, error)
• type ConnectorMetadata
  • func ParseConnectorMetadata() (ConnectorMetadata, error)

Functions

func GetAwsConfig

func GetAwsConfig() (*aws.Config, error)

GetAwsConfig get's the configuration required to connect to aws

func HandleHTTPRequest

func HandleHTTPRequest(message string, headers http.Header, data ConnectorMetadata, logger *zap.Logger) (*http.Response, error)

HandleHTTPRequest sends message and headers data to HTTP endpoint using POST method and returns response on success or error in case of failure

Types

type ConnectorMetadata

type ConnectorMetadata struct {
	Topic         string
	ResponseTopic string
	ErrorTopic    string
	HTTPEndpoint  string
	MaxRetries    int
	ContentType   string
	SourceName    string
}

ConnectorMetadata contains common fields used by connectors

func ParseConnectorMetadata

func ParseConnectorMetadata() (ConnectorMetadata, error)

ParseConnectorMetadata parses connector side common fields and returns as ConnectorMetadata or returns error