http

README

Http

Compass is a search and discovery engine built for querying application deployments, datasets and meta resources. It can also optionally track data flow relationships between these resources and allow the user to view a representation of the data flow graph.

Usage

sinks:
  name: http
  config:
    method: POST
    success_code: 200
    url: https://compass.com/v1beta1/asset
    headers:
      Header-1: value11,value12

Config Defination

Key	Value	Example	Description
url	string	http://compass.production.com/v1beta1/asset	URL to the http server, contains all the info needed to make the request, like port and route	required
method	string	POST	the method string of by which the request is to be made, e.g. POST/PATCH/GET	required
success_code	integer	200	to identify the expected success code the http server returns, defult is 200	optional
headers	map	"Content-Type": "application/json"	to add any header/headers that may be required for making the request	optional

Contributing

Refer to the contribution guidelines for information on contributing to this module.

Documentation

Index

• func New(c httpClient, logger log.Logger) plugins.Syncer
• type Config
• type Sink
  • func (*Sink) Close() error
  • func (s *Sink) Init(ctx context.Context, config plugins.Config) error
  • func (s *Sink) Sink(ctx context.Context, batch []models.Record) error

Functions

func New

func New(c httpClient, logger log.Logger) plugins.Syncer

Types

type Config

type Config struct {
	URL         string            `mapstructure:"url" validate:"required"`
	Headers     map[string]string `mapstructure:"headers"`
	Method      string            `mapstructure:"method" validate:"required"`
	SuccessCode int               `mapstructure:"success_code" default:"200"`
}

type Sink

type Sink struct {
	plugins.BasePlugin
	// contains filtered or unexported fields
}

func (*Sink) Close

func (*Sink) Close() error

func (*Sink) Init

func (s *Sink) Init(ctx context.Context, config plugins.Config) error

func (*Sink) Sink

func (s *Sink) Sink(ctx context.Context, batch []models.Record) error