shared

type AuthHelper struct {
	HttpHelper HttpHelper
	// contains filtered or unexported fields
}

type FormattedError struct {
	Inner      error
	Message    string
	StackTrace string
	Misc       map[string]interface{}
}

type Header struct {
	Key   string
	Value string
}

type HttpClient interface {
	Do(req *http.Request) (resp *http.Response, err error)
}

type HttpHelper interface {
	HttpRequest(method string, url string, body io.Reader, headers []Header, timeout time.Duration) (out []byte, err error, statusCode int)
}

type LineCount struct {
	Lock    sync.RWMutex
	Counter map[string]int16
}

type LogHelper interface {
	Log(line string, isLastLine bool, taskId string) (jobId string, err error)
}

type LogMessage struct {
	JobId      string `json:"jobId"`
	LineNumber int16  `json:"lineNumber"`
	Payload    string `json:"payload"`
	IsLastLine bool   `json:"isLastLine"`
}