http

type AccessTokenConf struct {
	Url            string `json:"url"`
	Body           string `json:"body"`
	Expire         string `json:"expire"`
	ExpireInSecond int
}

type ClientConf struct {
	// contains filtered or unexported fields
}

type ClientConfOption struct {
	// contains filtered or unexported fields
}

type PullSource struct {
	ClientConf
	// contains filtered or unexported fields
}

type PushConf struct {
	Method       string `json:"method"`
	ContentType  string `json:"contentType"`
	BufferLength int    `json:"bufferLength"`
	Endpoint     string `json:"endpoint"`
}

type PushSource struct {
	// contains filtered or unexported fields
}

type RawConf struct {
	Url       string      `json:"url"`
	Method    string      `json:"method"`
	Body      string      `json:"body"`
	BodyType  string      `json:"bodyType"`
	Headers   interface{} `json:"headers"`
	Timeout   int         `json:"timeout"`
	DebugResp bool        `json:"debugResp"`
	// Could be code or body
	ResponseType string                            `json:"responseType"`
	OAuth        map[string]map[string]interface{} `json:"oauth"`
	// source specific properties
	Interval    int    `json:"interval"`
	Incremental bool   `json:"incremental"`
	ResendUrl   string `json:"resendDestination"`
	// sink specific properties
	SendSingle bool `json:"sendSingle"`
	// inferred properties
	HeadersTemplate string
	HeadersMap      map[string]string
	Compression     string `json:"compression"` // Compression specifies the algorithms used to payload compression
}

type RefreshTokenConf struct {
	Url     string            `json:"url"`
	Headers map[string]string `json:"headers"`
	Body    string            `json:"body"`
}

type RestSink struct {
	ClientConf
}

type WithClientConfOption func(clientConf *ClientConfOption)