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

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions