Skip to content

Add HTTP Sink in depot #52

@jesrypandawa

Description

@jesrypandawa
  • Create HttpClient and related classes to include all the HTTP auth and HTTP methods.
  • Implement a bare minimum HttpSink which sends data to the HTTP server.
  • Add support for parsing of list data type in getFieldByName() method in ParsedOdpfMessage.
  • getFieldByName() should return ParsedMessage instead of Object. ParsedMessage should contain more methods like getType(), isReapated(), isStruct(), isPrimitive() etc etc.
  • Add ToJson() method to convert struct into JSON string in ParsedOdpfMessage class.
  • Create HeaderBuilder class
  • Create URI builder and QueryParam class
  • Create Raw Payload builder
  • Create Json Payload builder
  • Create Message Payload Builder
  • Create String Payload builder
  • Create JsonTemplate Payload Builder
  • Create RequestBuilder build() method for Single request
  • Create RequestBuilder build() method for Batch request
  • Create HttpRecordConverter
  • Implement HttpRequestRecord and HttpResponseRecord classes to contain methods like logging based on configs.
  • Add methods to parse the HttpResponseRecord to set correct ErrorTypes.
  • Instrumentation: Add sink related metrics
  • Documentation

Metadata

Metadata

Assignees

No one assigned

    Labels

    No labels
    No labels

    Type

    No type
    No fields configured for issues without a type.

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions