func sendRequestDefault()

in out_writeapi.go [365:377]

• 11 lines of code
• 2 McCabe index (conditional complexity)

func sendRequestDefault(ctx context.Context, data [][]byte, config **outputConfig, streamIndex int) error {
	(*config).mutex.Lock()
	defer (*config).mutex.Unlock()
	currStream := (*(*config).managedStreamSlice)[streamIndex]

	appendResult, err := currStream.managedstream.AppendRows(ctx, data)
	if err != nil {
		return err
	}

	*currStream.appendResults = append(*currStream.appendResults, appendResult)
	return nil
}