Unexport Request

Author: carsonip

exporter/elasticsearchexporter/factory.go

@@ -97,8 +97,8 @@ func createLogsRequestExporter(
 	}
 
 	batchMergeFunc := func(ctx context.Context, r1, r2 exporterhelper.Request) (exporterhelper.Request, error) {
-		rr1 := r1.(*Request)
-		rr2 := r2.(*Request)
+		rr1 := r1.(*request)
+		rr2 := r2.(*request)
 		req := newRequest(logsExporter.bulkIndexer)
 		req.Items = append(rr1.Items, rr2.Items...)
 		return req, nil
@@ -111,12 +111,12 @@ func createLogsRequestExporter(
 	}
 
 	marshalRequest := func(req exporterhelper.Request) ([]byte, error) {
-		b, err := json.Marshal(*req.(*Request))
+		b, err := json.Marshal(*req.(*request))
 		return b, err
 	}
 
 	unmarshalRequest := func(b []byte) (exporterhelper.Request, error) {
-		var req Request
+		var req request
 		err := json.Unmarshal(b, &req)
 		req.bulkIndexer = logsExporter.bulkIndexer
 		return &req, err

exporter/elasticsearchexporter/request.go

@@ -5,16 +5,16 @@ import (
 	"context"
 )
 
-type Request struct {
+type request struct {
 	bulkIndexer *esBulkIndexerCurrent
 	Items       []bulkIndexerItem
 }
 
-func newRequest(bulkIndexer *esBulkIndexerCurrent) *Request {
-	return &Request{bulkIndexer: bulkIndexer}
+func newRequest(bulkIndexer *esBulkIndexerCurrent) *request {
+	return &request{bulkIndexer: bulkIndexer}
 }
 
-func (r *Request) Export(ctx context.Context) error {
+func (r *request) Export(ctx context.Context) error {
 	batch := make([]esBulkIndexerItem, len(r.Items))
 	for i, item := range r.Items {
 		batch[i] = esBulkIndexerItem{
@@ -25,11 +25,11 @@ func (r *Request) Export(ctx context.Context) error {
 	return r.bulkIndexer.AddBatchAndFlush(ctx, batch)
 }
 
-func (r *Request) ItemsCount() int {
+func (r *request) ItemsCount() int {
 	return len(r.Items)
 }
 
-func (r *Request) Add(item bulkIndexerItem) {
+func (r *request) Add(item bulkIndexerItem) {
 	r.Items = append(r.Items, item)
 }