Function TestOTLPWriteHandler

pkg/util/push/otlp_test.go:1051–1154

(t *testing.T)

}

func TestOTLPWriteHandler(t *testing.T) {
	cfg := distributor.OTLPConfig{
		ConvertAllAttributes: false,
		DisableTargetInfo:    false,
	}

	exportRequest := generateOTLPWriteRequest()

	tests := []struct {
		description        string
		maxRecvMsgSize     int
		contentType        string
		expectedStatusCode int
		expectedErrMsg     string
		encodingType       string
	}{
		{
			description:        "Test proto format write with no compression",
			maxRecvMsgSize:     10000,
			contentType:        pbContentType,
			expectedStatusCode: http.StatusOK,
		},
		{
			description:        "Test proto format write with gzip",
			maxRecvMsgSize:     10000,
			contentType:        pbContentType,
			expectedStatusCode: http.StatusOK,
			encodingType:       "gzip",
		},
		{
			description:        "Test json format write with no compression",
			maxRecvMsgSize:     10000,
			contentType:        jsonContentType,
			expectedStatusCode: http.StatusOK,
		},
		{
			description:        "Test json format write with gzip",
			maxRecvMsgSize:     10000,
			contentType:        jsonContentType,
			expectedStatusCode: http.StatusOK,
			encodingType:       "gzip",
		},
		{
			description:        "request too big than maxRecvMsgSize (proto) with no compression",
			maxRecvMsgSize:     10,
			contentType:        pbContentType,
			expectedStatusCode: http.StatusBadRequest,
			expectedErrMsg:     "received message larger than max",
		},
		{
			description:        "request too big than maxRecvMsgSize (proto) with gzip",
			maxRecvMsgSize:     10,
			contentType:        pbContentType,
			expectedStatusCode: http.StatusBadRequest,
			expectedErrMsg:     "received message larger than max",
			encodingType:       "gzip",
		},
		{